valkey

type Address string

type AuthConfig struct {
	Username  string
	Password  string
	TLSConfig *tls.Config
}

type AuthInfo = AuthConfig

type ClusterNode struct {
	Id        string
	Addr      string
	RawFlag   string
	BusPort   string
	AuxFields ClusterNodeAuxFields
	Role      string
	MasterId  string
	PingSend  int64
	PongRecv  int64
	Epoch     int64
	LinkState string
	// contains filtered or unexported fields
}

type ClusterNodeAuxFields struct {
	ShardID  string `json:"shard-id"`
	NodeName string `json:"nodename"`
	TCPPort  int64  `json:"tcp-port"`
	TLSPort  int64  `json:"tls-port"`
	// contains filtered or unexported fields
}

type ClusterNodeInfo struct {
	ClusterState         string `json:"cluster_state"`
	ClusterSlotsAssigned int    `json:"cluster_slots_assigned"`
	ClusterSlotsOk       int    `json:"cluster_slots_ok"`
	ClusterSlotsPfail    int    `json:"cluster_slots_pfail"`
	ClusterSlotsFail     int    `json:"cluster_slots_fail"`
	ClusterKnownNodes    int    `json:"cluster_known_nodes"`
	ClusterSize          int    `json:"cluster_size"`
	ClusterCurrentEpoch  int    `json:"cluster_current_epoch"`
	ClusterMyEpoch       int    `json:"cluster_my_epoch"`
}

type ClusterNodes []*ClusterNode

type NodeInfo struct {
	Version               string         `json:"valkey_version"`
	ServerMode            string         `json:"server_mode"`
	RunId                 string         `json:"run_id"`
	UptimeInSeconds       int64          `json:"uptime_in_seconds"`
	AOFEnabled            string         `json:"aof_enabled"`
	Role                  string         `json:"role"`
	ConnectedReplicas     int64          `json:"connected_slaves"`
	MasterHost            string         `json:"master_host"`
	MasterPort            string         `json:"master_port"`
	ClusterEnabled        string         `json:"cluster_enabled"`
	MasterLinkStatus      string         `json:"master_link_status"`
	MasterReplId          string         `json:"master_replid"`
	MasterReplOffset      int64          `json:"master_repl_offset"`
	MasterReplId2         string         `json:"master_replid2"`
	SecondReplOffset      int64          `json:"second_repl_offset"`
	UsedMemory            int64          `json:"used_memory"`
	UsedMemoryDataset     int64          `json:"used_memory_dataset"`
	SentinelMasters       int64          `json:"sentinel_masters"`
	SentinelTiLt          int64          `json:"sentinel_tilt"`
	SentinelRunningScript int64          `json:"sentinel_running_scripts"`
	Dbsize                int64          `json:"dbsize"`
	SentinelMaster0       SentinelMaster `json:"master0"`
}

type PipelineResult struct {
	Value any
	Error error
}

type SentinelMaster struct {
	Name            string                `json:"name"`
	Status          string                `json:"status"`
	Address         Address               `json:"address"`
	Replicas        int                   `json:"slaves"`
	Sentinels       int                   `json:"sentinels"`
	MonitorReplicas []SentinelMonitorNode `json:"monitor_replicas"`
}

type SentinelMonitorNode struct {
	Name                  string `json:"name"`
	IP                    string `json:"ip"`
	Port                  string `json:"port"`
	RunId                 string `json:"run_id"`
	Flags                 string `json:"flags"`
	LinkPendingCommands   int32  `json:"link_pending_commands"`
	LinkRefcount          int32  `json:"link_refcount"`
	FailoverState         string `json:"failover_state"`
	LastPingSent          int64  `json:"last_ping_sent"`
	LastOkPingReply       int64  `json:"last_ok_ping_reply"`
	LastPingReply         int64  `json:"last_ping_reply"`
	SDownTime             int64  `json:"s_down_time"`
	ODownTime             int64  `json:"o_down_time"`
	DownAfterMilliseconds int64  `json:"down_after_milliseconds"`
	InfoRefresh           int64  `json:"info_refresh"`
	RoleReported          string `json:"role_reported"`
	RoleReportedTime      int64  `json:"role_reported_time"`
	ConfigEpoch           int64  `json:"config_epoch"`
	NumSlaves             int32  `json:"num_slaves"`
	NumOtherSentinels     int32  `json:"num_other_sentinels"`
	Quorum                int32  `json:"quorum"`
	FailoverTimeout       int64  `json:"failover_timeout"`
	ParallelSyncs         int32  `json:"parallel_syncs"`

	// replica fields
	MasterLinkDownTime int64  `json:"master_link_down_time"`
	MasterLinkStatus   string `json:"master_link_status"`
	MasterHost         string `json:"master_host"`
	MasterPort         string `json:"master_port"`
	SlavePriority      int32  `json:"slave_priority"`
	SlaveReplOffset    int64  `json:"slave_repl_offset"`

	// sentinel node specific fields
	LastHelloMessage string `json:"last_hello_message"`
	VotedLeader      string `json:"voted_leader"`
	VotedLeaderEpoch int64  `json:"voted_leader_epoch"`
}

type ValkeyClient interface {
	Do(ctx context.Context, cmd string, args ...any) (any, error)
	DoWithTimeout(ctx context.Context, timeout time.Duration, cmd string, args ...any) (any, error)
	Tx(ctx context.Context, cmds []string, args [][]any) (any, error)
	Pipeline(ctx context.Context, args [][]any) ([]PipelineResult, error)
	Close() error
	Clone(ctx context.Context, addr string) ValkeyClient

	Ping(ctx context.Context) error
	Info(ctx context.Context, sections ...any) (*NodeInfo, error)
	ClusterInfo(ctx context.Context) (*ClusterNodeInfo, error)
	ConfigGet(ctx context.Context, cate string) (map[string]string, error)
	ConfigSet(ctx context.Context, params map[string]string) error
	Nodes(ctx context.Context) (ClusterNodes, error)
}