MCPcopy Create free account

hub / github.com/Atsika/aznet / functions

Functions206 in github.com/Atsika/aznet

MethodClose
()
aznet.go:508
MethodClose
()
aznet.go:753
MethodClose
()
azqueue.go:272
MethodCloseWrite
CloseWrite shuts down the writing side of the connection. It sends a FIN frame to the peer to indicate that no more data will be sent.
aznet.go:539
MethodCreateBootstrapTokens
()
azblob.go:185
MethodCreateBootstrapTokens
()
aztable.go:178
MethodCreateBootstrapTokens
()
azqueue.go:161
MethodCreateSession
(ctx context.Context, connID string)
azblob.go:202
MethodCreateSession
(ctx context.Context, connID string)
aztable.go:193
MethodCreateSession
(ctx context.Context, connID string)
metrics.go:129
MethodCreateSession
(ctx context.Context, connID string)
azqueue.go:176
MethodDeleteHandshake
(ctx context.Context, id string)
azblob.go:134
MethodDeleteHandshake
(ctx context.Context, id string)
aztable.go:137
MethodDeleteHandshake
(ctx context.Context, id string)
metrics.go:95
MethodDeleteHandshake
(ctx context.Context, id string)
azqueue.go:107
MethodDeleteToken
(ctx context.Context, connID string)
azblob.go:161
MethodDeleteToken
(ctx context.Context, connID string)
aztable.go:159
MethodDeleteToken
(ctx context.Context, connID string)
metrics.go:121
MethodDeleteToken
(ctx context.Context, connID string)
azqueue.go:138
MethodGetBytesReceived
()
metrics.go:60
MethodGetBytesSent
()
metrics.go:59
MethodGetCipherStates
GetCipherStates returns the established cipher states for encrypting/decrypting data. send is for sending, recv is for receiving.
crypto.go:113
MethodGetDeleteTransactionCount
()
metrics.go:56
FunctionGetFactories
GetFactories returns a list of registered factory names.
aznet.go:150
MethodGetHandshakes
GetHandshakes lists blobs with metadata included, avoiding per-blob downloads (1 API call instead of N+1).
azblob.go:106
MethodGetHandshakes
(ctx context.Context)
aztable.go:120
MethodGetHandshakes
(ctx context.Context)
metrics.go:86
MethodGetHandshakes
(ctx context.Context)
azqueue.go:92
MethodGetListTransactionCount
()
metrics.go:53
MethodGetMetrics
()
aznet.go:575
MethodGetReadTransactionCount
()
metrics.go:50
MethodGetToken
(ctx context.Context, connID string)
azblob.go:144
MethodGetToken
(ctx context.Context, connID string)
aztable.go:148
MethodGetToken
(ctx context.Context, connID string)
metrics.go:112
MethodGetToken
(ctx context.Context, connID string)
azqueue.go:125
MethodGetWriteTransactionCount
()
metrics.go:47
MethodIncrementBytesReceived
(n int64)
metrics.go:45
MethodIncrementBytesSent
(n int64)
metrics.go:44
MethodIncrementDeleteTransaction
()
metrics.go:43
MethodIncrementListTransaction
()
metrics.go:42
MethodIncrementReadTransaction
()
metrics.go:41
MethodIncrementWriteTransaction
()
metrics.go:40
MethodLocalAddr
()
azblob.go:301
MethodLocalAddr
()
aztable.go:306
MethodLocalAddr
()
aznet.go:550
MethodLocalAddr
()
azqueue.go:274
MethodMaxRawSize
()
azblob.go:300
MethodMaxRawSize
()
aztable.go:305
MethodMaxRawSize
()
azqueue.go:273
MethodNetwork
()
aznet.go:77
MethodNewDriver
(ep *Endpoint, cfg *Config)
azblob.go:40
MethodNewDriver
(ep *Endpoint, cfg *Config)
aztable.go:64
MethodNewDriver
(ep *Endpoint, cfg *Config)
azqueue.go:30
MethodNewTransport
(ctx context.Context, connID string, tokens SessionTokens, isInitiator bool)
azblob.go:213
MethodNewTransport
(_ context.Context, connID string, tokens SessionTokens, isInitiator bool)
aztable.go:213
MethodNewTransport
(ctx context.Context, connID string, tokens SessionTokens, isInitiator bool)
metrics.go:137
MethodNewTransport
(_ context.Context, connID string, tokens SessionTokens, isInitiator bool)
azqueue.go:195
MethodPostHandshake
(ctx context.Context, connID string, msg []byte)
azblob.go:96
MethodPostHandshake
(ctx context.Context, connID string, msg []byte)
aztable.go:114
MethodPostHandshake
(ctx context.Context, connID string, data []byte)
metrics.go:77
MethodPostHandshake
(ctx context.Context, connID string, msg []byte)
azqueue.go:87
MethodPostToken
(ctx context.Context, connID string, msg []byte)
azblob.go:139
MethodPostToken
(ctx context.Context, connID string, msg []byte)
aztable.go:142
MethodPostToken
(ctx context.Context, connID string, data []byte)
metrics.go:103
MethodPostToken
(ctx context.Context, connID string, msg []byte)
azqueue.go:116
MethodRead
(p []byte)
aznet.go:870
MethodReadRaw
(ctx context.Context)
azblob.go:277
MethodReadRaw
(ctx context.Context)
aztable.go:274
MethodReadRaw
(ctx context.Context)
aznet.go:835
MethodReadRaw
(ctx context.Context)
azqueue.go:247
MethodRemoteAddr
()
azblob.go:304
MethodRemoteAddr
()
aztable.go:309
MethodRemoteAddr
()
aznet.go:551
MethodRemoteAddr
()
azqueue.go:277
MethodRotateRX
()
azblob.go:328
MethodRotateRX
()
aznet.go:858
MethodRotateTX
(ctx context.Context)
azblob.go:314
MethodRotateTX
(ctx context.Context)
aznet.go:851
MethodSetDeadline
(t time.Time)
aznet.go:553
MethodSetReadDeadline
(t time.Time)
aznet.go:559
MethodSetWriteDeadline
(t time.Time)
aznet.go:564
MethodShouldRotate
()
azblob.go:308
MethodShouldRotate
()
aznet.go:844
FunctionUnregisterFactory
UnregisterFactory removes the factory registration.
aznet.go:145
FunctionWithAcceptPoll
WithAcceptPoll sets how frequently the listener scans for new connections.
options.go:151
FunctionWithConnectTimeout
WithConnectTimeout sets the maximum duration the client waits for the listener to acknowledge a Dialled connection. Zero or negative disables the time
options.go:188
FunctionWithContext
WithContext sets the base context for all network/SDK calls initiated by Listen/Dial. Useful for cancellation or shared tracing.
options.go:208
FunctionWithDataPoll
WithDataPoll sets how often established connections poll for data.
options.go:169
FunctionWithFastPoll
WithFastPoll sets the polling interval used when data is actively flowing.
options.go:160
FunctionWithIdleTimeout
WithIdleTimeout sets the grace period after which background janitors purge half-closed connections that never completed a FIN handshake. Zero disable
options.go:198
FunctionWithMetrics
WithMetrics sets a custom metrics implementation for tracking connection statistics. If not provided, a default implementation with atomic counters wi
options.go:218
FunctionWithPing
WithPing sets the keep-alive heartbeat cadence. Zero disables keep-alive.
options.go:178
FunctionWithPrefixes
WithPrefixes sets the prefixes that drivers use when creating per-connection request/response artefacts (e.g. blobs or queues).
options.go:129
MethodWriteRaw
(ctx context.Context, data io.ReadSeeker)
azblob.go:267
MethodWriteRaw
(ctx context.Context, data io.ReadSeeker)
aztable.go:263
MethodWriteRaw
(ctx context.Context, data io.ReadSeeker)
aznet.go:819
MethodWriteRaw
(ctx context.Context, data io.ReadSeeker)
azqueue.go:241
Functioninit
()
azblob.go:34
Functioninit
()
aztable.go:31
Functioninit
()
azqueue.go:24
← previousnext →101–200 of 206, ranked by callers