dispatch

type ConcurrencyReleaseStore interface {
	ApplyConcurrencyRelease(context.Context, cluster.ConcurrencyReleaseRequest) error
}

type ConnEnv struct {
	SubscribeConfigYAML            func() (int64, error)
	UnsubscribeConfigYAML          func() (int64, error)
	IsSubscribed                   func() bool
	SubscribeMembership            func(context.Context, int, int64) (cluster.ConnectionLifetime, error)
	AttachSubscriptionLifetimeFunc func(cluster.ConnectionLifetime) error
	FenceFingerprint               func(context.Context, string) error
	CloseLocalFingerprint          func()
	PrepareDispatchReply           func() error
	AccountedReplyFailure          func() error
	// contains filtered or unexported fields
}

type Env struct {
	Runtime *home.Runtime
	Conn    *ConnEnv

	// InFlightStore persists in-flight observation frames.
	InFlightStore InFlightSnapshotStore

	// InFlightLimits bounds the in-flight observation frame accepted by InFlightStore.
	InFlightLimits cluster.InFlightLimits

	// ConcurrencyReleaseStore applies cumulative limiter releases from this connection.
	ConcurrencyReleaseStore ConcurrencyReleaseStore

	// ClientIP is the remote TCP client's IP address as resolved by the RESP server.
	// It can be empty when the address cannot be resolved.
	ClientIP string

	// NodeID is the mTLS client certificate common name when available.
	// It can be empty in unit tests or unauthenticated contexts.
	NodeID string

	// ClientCertificateFingerprint is the SHA-256 fingerprint of the mTLS leaf certificate.
	ClientCertificateFingerprint string

	// ConnectionLifetime is fixed when the connection is accepted and cannot be
	// upgraded by a subscription performed on the same socket. Its fingerprint and
	// connected time are the only in-flight snapshot ownership identity.
	ConnectionLifetime cluster.ConnectionLifetime
}

type Handler func(ctx context.Context, env Env, args []string) Reply

type InFlightSnapshotStore interface {
	IngestInFlightFrame(context.Context, cluster.InFlightIngestIdentity, []byte, cluster.InFlightLimits) (cluster.InFlightIngestResult, error)
}

type Registry struct {
	// contains filtered or unexported fields
}

type Reply struct {
	Kind ReplyKind

	// SubscriptionLifetime is server-only metadata and is never serialized.
	SubscriptionLifetime *cluster.ConnectionLifetime

	SimpleString       string
	BulkString         []byte
	RedisError         string
	Integer            int64
	Array              []Reply
	Sensitive          bool
	AccountedAdmission bool
	PreWriteError      error
}

type ReplyKind int