server

type Client struct {
	*resp.Session

	DB             *engine.Bitalos
	QueryStartTime time.Time
	KeyHash        uint32
	IsMaster       func() bool
	// contains filtered or unexported fields
}

type Cmd struct {
	NArg           int
	Sync           bool
	Name           string
	Handler        func(*Client) error
	NotAllowedInTx bool
	NoKey          bool
	KeySkip        uint8
}

type DB struct {
	*engine.Bitalos

	Info *SInfo
}

type DbSyncStatusType int

type LuaClient struct {
	LState *lua.LState
	Count  int16
}

type ModelType int

type Proc struct {
	Name string

	Start func(*Server)
	Stop  func(*Server, interface{})

	Connect func(*Server, *Client)
	Disconn func(*Server, *Client, interface{})
	Prepare func(*Client, *Cmd, string) bool
	Handled func(*Client, *Cmd, string)

	DoRaftSync func(*Client, *Cmd, string) error
}

type SInfo struct {
	Server         SinfoServer
	Client         SinfoClient
	Cluster        SinfoCluster
	Stats          SinfoStats
	Data           SinfoData
	RuntimeStats   SRuntimeStats
	BitalosdbUsage *bitsdb.BitsUsage
}

type SRuntimeStats struct {
	General struct {
		Alloc   uint64 `json:"runtime_general_alloc"`
		Sys     uint64 `json:"runtime_general_sys"`
		Lookups uint64 `json:"runtime_general_lookups"`
		Mallocs uint64 `json:"runtime_general_mallocs"`
		Frees   uint64 `json:"runtime_general_frees"`
	} `json:"runtime_general"`

	Heap struct {
		Alloc   uint64 `json:"runtime_heap_alloc"`
		Sys     uint64 `json:"runtime_heap_sys"`
		Idle    uint64 `json:"runtime_heap_idle"`
		Inuse   uint64 `json:"runtime_heap_inuse"`
		Objects uint64 `json:"runtime_heap_objects"`
	} `json:"heap"`

	GC struct {
		Num          uint32  `json:"runtime_gc_num"`
		CPUFraction  float64 `json:"runtime_gc_cpu_fraction"`
		TotalPauseMs uint64  `json:"runtime_gc_total_pausems"`
	} `json:"gc"`

	NumProcs      int `json:"runtime_num_procs"`
	NumGoroutines int `json:"runtime_num_goroutines"`

	MemoryTotal int64   `json:"memory_total"`
	MemoryShr   int64   `json:"memory_shr"`
	CPU         float64 `json:"cpu"`
	// contains filtered or unexported fields
}

type Server struct {
	Info              *SInfo
	IsMaster          func() bool
	MigrateDelToSlave func(keyHash uint32, data [][]byte) error
	IsWitness         bool
	// contains filtered or unexported fields
}

type SinfoClient struct {
	ClientTotal atomic.Int64 `json:"total_clients"`
	ClientAlive atomic.Int64 `json:"connected_clients"`
	// contains filtered or unexported fields
}

type SinfoCluster struct {
	StartModel       ModelType `json:"start_model"`
	Status           bool      `json:"status"`
	Role             string    `json:"role"`
	ClusterId        uint64    `json:"cluster_id"`
	CurrentNodeId    uint64    `json:"current_node_id"`
	RaftAddress      string    `json:"raft_address"`
	LeaderNodeId     uint64    `json:"leader_node_id"`
	LeaderAddress    string    `json:"leader_address"`
	ClusterNodes     string    `json:"cluster_nodes"`
	ClusterNodesList string    `json:"cluster_nodes_list"`
	// contains filtered or unexported fields
}

type SinfoData struct {
	UsedSize         int64 `json:"used_size"`
	DataSize         int64 `json:"data_size"`
	RaftNodeHostSize int64 `json:"raft_nodehost_size"`
	RaftWalSize      int64 `json:"raft_wal_size"`
	SnapshotSize     int64 `json:"snapshot_size"`
	// contains filtered or unexported fields
}

type SinfoServer struct {
	MaxProcs      int    `json:"maxprocs"`
	ProcessId     int    `json:"process_id"`
	StartTime     string `json:"start_time"`
	ServerAddress string `json:"server_address"`
	MaxClient     int64  `json:"max_client"`
	SingleDegrade bool   `json:"single_degrade"`
	GitVersion    string `json:"git_version"`
	Compile       string `json:"compile"`
	ConfigFile    string `json:"config_file"`
	// contains filtered or unexported fields
}

type SinfoStats struct {
	TotolCmd      atomic.Uint64
	QPS           atomic.Uint64
	QueueLen      int
	RaftLogIndex  uint64
	IsDelExpire   int
	StartModel    ModelType
	DbSyncRunning atomic.Int32
	DbSyncStatus  DbSyncStatusType
	DbSyncErr     string
	IsMigrate     atomic.Int32 `json:"is_migrate"`
	// contains filtered or unexported fields
}

type TxLocker struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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

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