Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Atsika/aznet
/ functions
Functions
206 in github.com/Atsika/aznet
⨍
Functions
206
◇
Types & classes
31
Method
Close
()
aznet.go:508
Method
Close
()
aznet.go:753
Method
Close
()
azqueue.go:272
Method
CloseWrite
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
Method
CreateBootstrapTokens
()
azblob.go:185
Method
CreateBootstrapTokens
()
aztable.go:178
Method
CreateBootstrapTokens
()
azqueue.go:161
Method
CreateSession
(ctx context.Context, connID string)
azblob.go:202
Method
CreateSession
(ctx context.Context, connID string)
aztable.go:193
Method
CreateSession
(ctx context.Context, connID string)
metrics.go:129
Method
CreateSession
(ctx context.Context, connID string)
azqueue.go:176
Method
DeleteHandshake
(ctx context.Context, id string)
azblob.go:134
Method
DeleteHandshake
(ctx context.Context, id string)
aztable.go:137
Method
DeleteHandshake
(ctx context.Context, id string)
metrics.go:95
Method
DeleteHandshake
(ctx context.Context, id string)
azqueue.go:107
Method
DeleteToken
(ctx context.Context, connID string)
azblob.go:161
Method
DeleteToken
(ctx context.Context, connID string)
aztable.go:159
Method
DeleteToken
(ctx context.Context, connID string)
metrics.go:121
Method
DeleteToken
(ctx context.Context, connID string)
azqueue.go:138
Method
GetBytesReceived
()
metrics.go:60
Method
GetBytesSent
()
metrics.go:59
Method
GetCipherStates
GetCipherStates returns the established cipher states for encrypting/decrypting data. send is for sending, recv is for receiving.
crypto.go:113
Method
GetDeleteTransactionCount
()
metrics.go:56
Function
GetFactories
GetFactories returns a list of registered factory names.
aznet.go:150
Method
GetHandshakes
GetHandshakes lists blobs with metadata included, avoiding per-blob downloads (1 API call instead of N+1).
azblob.go:106
Method
GetHandshakes
(ctx context.Context)
aztable.go:120
Method
GetHandshakes
(ctx context.Context)
metrics.go:86
Method
GetHandshakes
(ctx context.Context)
azqueue.go:92
Method
GetListTransactionCount
()
metrics.go:53
Method
GetMetrics
()
aznet.go:575
Method
GetReadTransactionCount
()
metrics.go:50
Method
GetToken
(ctx context.Context, connID string)
azblob.go:144
Method
GetToken
(ctx context.Context, connID string)
aztable.go:148
Method
GetToken
(ctx context.Context, connID string)
metrics.go:112
Method
GetToken
(ctx context.Context, connID string)
azqueue.go:125
Method
GetWriteTransactionCount
()
metrics.go:47
Method
IncrementBytesReceived
(n int64)
metrics.go:45
Method
IncrementBytesSent
(n int64)
metrics.go:44
Method
IncrementDeleteTransaction
()
metrics.go:43
Method
IncrementListTransaction
()
metrics.go:42
Method
IncrementReadTransaction
()
metrics.go:41
Method
IncrementWriteTransaction
()
metrics.go:40
Method
LocalAddr
()
azblob.go:301
Method
LocalAddr
()
aztable.go:306
Method
LocalAddr
()
aznet.go:550
Method
LocalAddr
()
azqueue.go:274
Method
MaxRawSize
()
azblob.go:300
Method
MaxRawSize
()
aztable.go:305
Method
MaxRawSize
()
azqueue.go:273
Method
Network
()
aznet.go:77
Method
NewDriver
(ep *Endpoint, cfg *Config)
azblob.go:40
Method
NewDriver
(ep *Endpoint, cfg *Config)
aztable.go:64
Method
NewDriver
(ep *Endpoint, cfg *Config)
azqueue.go:30
Method
NewTransport
(ctx context.Context, connID string, tokens SessionTokens, isInitiator bool)
azblob.go:213
Method
NewTransport
(_ context.Context, connID string, tokens SessionTokens, isInitiator bool)
aztable.go:213
Method
NewTransport
(ctx context.Context, connID string, tokens SessionTokens, isInitiator bool)
metrics.go:137
Method
NewTransport
(_ context.Context, connID string, tokens SessionTokens, isInitiator bool)
azqueue.go:195
Method
PostHandshake
(ctx context.Context, connID string, msg []byte)
azblob.go:96
Method
PostHandshake
(ctx context.Context, connID string, msg []byte)
aztable.go:114
Method
PostHandshake
(ctx context.Context, connID string, data []byte)
metrics.go:77
Method
PostHandshake
(ctx context.Context, connID string, msg []byte)
azqueue.go:87
Method
PostToken
(ctx context.Context, connID string, msg []byte)
azblob.go:139
Method
PostToken
(ctx context.Context, connID string, msg []byte)
aztable.go:142
Method
PostToken
(ctx context.Context, connID string, data []byte)
metrics.go:103
Method
PostToken
(ctx context.Context, connID string, msg []byte)
azqueue.go:116
Method
Read
(p []byte)
aznet.go:870
Method
ReadRaw
(ctx context.Context)
azblob.go:277
Method
ReadRaw
(ctx context.Context)
aztable.go:274
Method
ReadRaw
(ctx context.Context)
aznet.go:835
Method
ReadRaw
(ctx context.Context)
azqueue.go:247
Method
RemoteAddr
()
azblob.go:304
Method
RemoteAddr
()
aztable.go:309
Method
RemoteAddr
()
aznet.go:551
Method
RemoteAddr
()
azqueue.go:277
Method
RotateRX
()
azblob.go:328
Method
RotateRX
()
aznet.go:858
Method
RotateTX
(ctx context.Context)
azblob.go:314
Method
RotateTX
(ctx context.Context)
aznet.go:851
Method
SetDeadline
(t time.Time)
aznet.go:553
Method
SetReadDeadline
(t time.Time)
aznet.go:559
Method
SetWriteDeadline
(t time.Time)
aznet.go:564
Method
ShouldRotate
()
azblob.go:308
Method
ShouldRotate
()
aznet.go:844
Function
UnregisterFactory
UnregisterFactory removes the factory registration.
aznet.go:145
Function
WithAcceptPoll
WithAcceptPoll sets how frequently the listener scans for new connections.
options.go:151
Function
WithConnectTimeout
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
Function
WithContext
WithContext sets the base context for all network/SDK calls initiated by Listen/Dial. Useful for cancellation or shared tracing.
options.go:208
Function
WithDataPoll
WithDataPoll sets how often established connections poll for data.
options.go:169
Function
WithFastPoll
WithFastPoll sets the polling interval used when data is actively flowing.
options.go:160
Function
WithIdleTimeout
WithIdleTimeout sets the grace period after which background janitors purge half-closed connections that never completed a FIN handshake. Zero disable
options.go:198
Function
WithMetrics
WithMetrics sets a custom metrics implementation for tracking connection statistics. If not provided, a default implementation with atomic counters wi
options.go:218
Function
WithPing
WithPing sets the keep-alive heartbeat cadence. Zero disables keep-alive.
options.go:178
Function
WithPrefixes
WithPrefixes sets the prefixes that drivers use when creating per-connection request/response artefacts (e.g. blobs or queues).
options.go:129
Method
WriteRaw
(ctx context.Context, data io.ReadSeeker)
azblob.go:267
Method
WriteRaw
(ctx context.Context, data io.ReadSeeker)
aztable.go:263
Method
WriteRaw
(ctx context.Context, data io.ReadSeeker)
aznet.go:819
Method
WriteRaw
(ctx context.Context, data io.ReadSeeker)
azqueue.go:241
Function
init
()
azblob.go:34
Function
init
()
aztable.go:31
Function
init
()
azqueue.go:24
← previous
next →
101–200 of 206, ranked by callers