dispatch

type ConnEnv struct {
	SubscribeConfigYAML   func() (int64, error)
	UnsubscribeConfigYAML func() (int64, error)
	IsSubscribed          func() bool
}

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

	// 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
}

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

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

type Reply struct {
	Kind ReplyKind

	SimpleString string
	BulkString   []byte
	RedisError   string
	Integer      int64
	Array        []Reply
}

type ReplyKind int