Functions — github.com/Atsika/aznet

CodeHub MCPcopy Create free account

hub / github.com/Atsika/aznet / functions

Functions206 in github.com/Atsika/aznet

⨍ Functions 206◇ Types & classes 31

↓ 13 callersMethodClose

Close terminates the transport.

↓ 11 callersMethodServiceURL

ServiceURL returns the base URL for the Azure Storage service.

endpoint.go:109

↓ 11 callersMethodString

↓ 8 callersMethodJoinURL

JoinURL joins the base service URL with a resource name and optional SAS token.

endpoint.go:117

↓ 6 callersMethodRemoteAddr

RemoteAddr returns the remote network address.

↓ 5 callersFunctionBuildFrame

BuildFrame writes a framed message to the write buffer. Frame format: [4 bytes: length][1 byte: type][N bytes: payload] Caller must ensure writeBuf is

↓ 5 callersMethodIncrementDeleteTransaction

↓ 5 callersMethodflush

↓ 4 callersMethodIncrementWriteTransaction

↓ 4 callersMethodReset

Reset moves the current interval back to the fast value.

↓ 4 callersMethodSleep

Sleep waits for the current interval and then backs off exponentially up to Steady.

↓ 4 callersMethodWrite

↓ 4 callersMethodmakeSAS

(name string, permissions aztables.SASPermissions)

↓ 4 callersMethodmakeSAS

(name string, permissions sas.QueuePermissions)

↓ 3 callersMethodConnectionString

ConnectionString returns the connection string for this listener.

↓ 3 callersMethodDeleteToken

(ctx context.Context, connID string)

↓ 3 callersMethodIncrementBytesSent

↓ 3 callersMethodIncrementReadTransaction

↓ 3 callersFunctionListen

Listen is analogous to net.Listen. It takes a network type (e.g. "azblob") and an address (e.g. "account.blob.core.windows.net").

↓ 3 callersMethodLocalAddr

LocalAddr returns the local network address.

↓ 3 callersMethodNewTransport

NewTransport creates a data transporter for an established session.

↓ 3 callersMethodParseSAS

ParseSAS parses the handshake and token SAS tokens from the URL query. It returns the decoded SAS strings (without leading '?').

↓ 3 callersFunctionRegisterFactory

RegisterFactory registers a factory for the given scheme (e.g., "azblob").

↓ 3 callersMethodSASTimes

SASTimes returns the start and end times for a SAS token based on config.

↓ 3 callersMethodWriteRaw

WriteRaw sends raw bytes to the peer.

↓ 3 callersFunctionbuildTableEntity

(pk, rk string, data []byte)

↓ 3 callersFunctionextractTableData

↓ 3 callersFunctionformatRowKey

↓ 3 callersMethodmakeSAS

(name string, permissions sas.ContainerPermissions)

↓ 2 callersMethodAccept

↓ 2 callersMethodCleanupBootstrap

CleanupBootstrap removes shared bootstrap resources (handshake/token endpoints).

↓ 2 callersMethodCleanupSession

CleanupSession removes per-connection resources (req/res channels).

↓ 2 callersMethodCreateSession

Session lifecycle

↓ 2 callersMethodDeleteHandshake

(ctx context.Context, id string)

↓ 2 callersFunctionDial

Dial is analogous to net.Dial. It takes a network type (e.g. "azblob") and an address (e.g. "https://account.blob.core.windows.net/?handshake=...").

↓ 2 callersMethodGetBytesReceived

↓ 2 callersMethodGetBytesSent

↓ 2 callersMethodGetDeleteTransactionCount

↓ 2 callersMethodGetHandshakes

(ctx context.Context)

↓ 2 callersMethodGetListTransactionCount

↓ 2 callersFunctionGetMetrics

GetMetrics returns the metrics from a connection if it supports metrics tracking. It returns nil if the connection doesn't support metrics.

↓ 2 callersMethodGetReadTransactionCount

↓ 2 callersMethodGetToken

(ctx context.Context, connID string)

↓ 2 callersMethodGetWriteTransactionCount

↓ 2 callersMethodIncrementBytesReceived

↓ 2 callersMethodIsComplete

IsComplete returns true if the handshake is complete and session keys are established.

↓ 2 callersMethodMTU

MTU returns the maximum number of application bytes that can fit in a single transport frame for the current connection.

↓ 2 callersMethodMaxRawSize

MaxRawSize returns the maximum raw capacity of the transport in bytes.

↓ 2 callersMethodPostHandshake

Handshake operations

↓ 2 callersMethodPostToken

Token exchange operations

↓ 2 callersMethodReadMessage

ReadMessage processes a handshake message from the peer, decrypting the payload. It returns the decrypted payload.

↓ 2 callersMethodReadRaw

ReadRaw attempts to read raw bytes from the peer.

↓ 2 callersMethodRotateRX

↓ 2 callersMethodRotateTX

(ctx context.Context)

↓ 2 callersMethodSealData

SealData encrypts plaintext and prepends a 4-byte big-endian length. It uses the provided dst buffer if it has enough capacity.

↓ 2 callersMethodShouldRotate

↓ 2 callersMethodWriteMessage

WriteMessage creates the next handshake message, encrypting the payload. It returns the message to send to the peer.

↓ 2 callersFunctioninitialize

(network, address string, opts []Option)

↓ 2 callersFunctionnewConn

(ctx context.Context, cancel context.CancelFunc, t Transport, cfg *Config, noise *Noise, driver Driver, connID

↓ 2 callersFunctionresolveContainerClient

(client *service.Client, ep *Endpoint, name, sasToken string)

↓ 2 callersFunctionresolveQueueClient

(client *azqueue.ServiceClient, ep *Endpoint, name, sasToken string)

↓ 2 callersFunctionresolveTableClient

(client *aztables.ServiceClient, ep *Endpoint, name, sasToken string)

↓ 1 callersMethodBuildConnURL

BuildConnURL constructs the final aznet connection URL with base64 encoded SAS tokens.

↓ 1 callersMethodCreateBootstrapTokens

↓ 1 callersMethodDecryptData

DecryptData decrypts application data using the established session cipher.

↓ 1 callersMethodEncryptData

EncryptData encrypts application data using the established session cipher.

↓ 1 callersMethodGetMetrics

↓ 1 callersMethodIncrementListTransaction

↓ 1 callersMethodIsInitiator

IsInitiator returns true if the handshake is the initiator.

↓ 1 callersFunctionNewAdaptivePoll

NewAdaptivePoll builds a poller initialized to the fast interval.

↓ 1 callersFunctionNewDefaultMetrics

NewDefaultMetrics creates a new DefaultMetrics instance.

↓ 1 callersMethodNewDriver

NewDriver creates a Driver for the given endpoint and config.

↓ 1 callersFunctionNewEndpoint

NewEndpoint creates a new Endpoint from a URL.

↓ 1 callersFunctionNewNoiseClient

NewNoiseClient creates a new Noise Protocol handshake as the initiator (client). It uses the NN pattern (no static keys, anonymous connection).

↓ 1 callersFunctionNewNoiseServer

NewNoiseServer creates a new Noise Protocol handshake as the responder (server). It uses the NN pattern (no static keys, anonymous connection).

↓ 1 callersMethodRead

↓ 1 callersMethodUnsealData

UnsealData attempts to extract and decrypt a Noise chunk from data. It returns the decrypted plaintext into dst, the remaining data, and an error.

↓ 1 callersMethodValidate

Validate checks if the configuration is sane and valid.

↓ 1 callersFunctionWithEndpoints

WithEndpoints allows overriding the default handshake and token endpoints used during the connection bootstrap phase.

↓ 1 callersFunctionWithSASExpiry

WithSASExpiry sets the validity time for SAS tokens. The token cannot be revoked once generated, so be careful and don't set it too long.

↓ 1 callersFunctionapplyConfig

applyConfig builds a runtime config by applying the given options on top of defaults.

↓ 1 callersFunctiondefaultConfig

defaultConfig returns config with library defaults.

↓ 1 callersMethodjanitor

↓ 1 callersMethodkeepAlive

keepAlive sends periodic Ping frames when the local side is idle. lastActive tracks the time of the most recent flush (local send). peerLastSeen (upda

↓ 1 callersFunctionlookupFactory

(scheme string)

↓ 1 callersFunctionnewBlobClient

↓ 1 callersFunctionnewMetricsTransport

(t Transport, m Metrics)

↓ 1 callersFunctionnewQueueClient

↓ 1 callersFunctionnewTableClient

MethodCleanupBootstrap

(ctx context.Context)

MethodCleanupBootstrap

(ctx context.Context)

MethodCleanupBootstrap

(ctx context.Context)

MethodCleanupBootstrap

(ctx context.Context)

MethodCleanupSession

(ctx context.Context, connID string)

MethodCleanupSession

(ctx context.Context, connID string)

MethodCleanupSession

(ctx context.Context, connID string)

MethodCleanupSession

(ctx context.Context, connID string)

next →1–100 of 206, ranked by callers