logservice

package

Go to main page

Versions in this module

v1

v1.2.4

Sep 20, 2024

v1.2.3

Sep 10, 2024

v1.2.3-hotfix-20241101

Oct 31, 2024

v1.2.3-hotfix-20241016

Oct 16, 2024

v1.2.3-hotfix-20241010

Oct 11, 2024

v1.2.3-hotfix-20240916

Sep 14, 2024

v1.2.2

Jul 11, 2024

v1.2.2-20240715

Jul 15, 2024

v1.2.1

Jun 28, 2024

Changes in this version

type CNStore

+ CommitID string

+ func (m *CNStore) GetCommitID() string

type CNStoreHeartbeat

+ CommitID string

+ func (m *CNStoreHeartbeat) GetCommitID() string

type CNStoreInfo

+ CommitID string

+ func (m *CNStoreInfo) GetCommitID() string

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

v1.1.1

Feb 2, 2024

v1.1.0

Dec 29, 2023

Changes in this version

type CNStore

+ ConfigData *ConfigData

+ Resource Resource

+ UpTime int64

+ func (m *CNStore) GetConfigData() *ConfigData

+ func (m *CNStore) GetResource() Resource

+ func (m *CNStore) GetUpTime() int64

type CNStoreHeartbeat

+ ConfigData *ConfigData

+ Resource Resource

+ func (m *CNStoreHeartbeat) GetConfigData() *ConfigData

+ func (m *CNStoreHeartbeat) GetResource() Resource

type CNStoreInfo

+ ConfigData *ConfigData

+ Resource Resource

+ UpTime int64

+ func (m *CNStoreInfo) GetConfigData() *ConfigData

+ func (m *CNStoreInfo) GetResource() Resource

+ func (m *CNStoreInfo) GetUpTime() int64

type CheckerState

+ ProxyState ProxyState

+ Resource Resource

+ func (m *CheckerState) GetProxyState() ProxyState

+ func (m *CheckerState) GetResource() Resource

type ClusterDetails

+ DeletedStores []DeletedStore

+ ProxyStores []ProxyStore

+ func (m *ClusterDetails) GetDeletedStores() []DeletedStore

+ func (m *ClusterDetails) GetProxyStores() []ProxyStore

+ type ConfigData struct

+ Content map[string]*ConfigItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConfigData) Descriptor() ([]byte, []int)

+ func (*ConfigData) ProtoMessage()

+ func (m *ConfigData) GetContent() map[string]*ConfigItem

+ func (m *ConfigData) Marshal() (dAtA []byte, err error)

+ func (m *ConfigData) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigData) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConfigData) Reset()

+ func (m *ConfigData) Size() (n int)

+ func (m *ConfigData) String() string

+ func (m *ConfigData) Unmarshal(dAtA []byte) error

+ func (m *ConfigData) XXX_DiscardUnknown()

+ func (m *ConfigData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConfigData) XXX_Merge(src proto.Message)

+ func (m *ConfigData) XXX_Size() int

+ func (m *ConfigData) XXX_Unmarshal(b []byte) error

+ type ConfigItem struct

+ CurrentValue string

+ DefaultValue string

+ Internal string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConfigItem) Descriptor() ([]byte, []int)

+ func (*ConfigItem) ProtoMessage()

+ func (m *ConfigItem) GetCurrentValue() string

+ func (m *ConfigItem) GetDefaultValue() string

+ func (m *ConfigItem) GetInternal() string

+ func (m *ConfigItem) GetName() string

+ func (m *ConfigItem) Marshal() (dAtA []byte, err error)

+ func (m *ConfigItem) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigItem) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConfigItem) Reset()

+ func (m *ConfigItem) Size() (n int)

+ func (m *ConfigItem) String() string

+ func (m *ConfigItem) Unmarshal(dAtA []byte) error

+ func (m *ConfigItem) XXX_DiscardUnknown()

+ func (m *ConfigItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConfigItem) XXX_Merge(src proto.Message)

+ func (m *ConfigItem) XXX_Size() int

+ func (m *ConfigItem) XXX_Unmarshal(b []byte) error

+ type DeleteProxyStore struct

+ StoreID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteProxyStore) Descriptor() ([]byte, []int)

+ func (*DeleteProxyStore) ProtoMessage()

+ func (m *DeleteProxyStore) GetStoreID() string

+ func (m *DeleteProxyStore) Marshal() (dAtA []byte, err error)

+ func (m *DeleteProxyStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteProxyStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteProxyStore) Reset()

+ func (m *DeleteProxyStore) Size() (n int)

+ func (m *DeleteProxyStore) String() string

+ func (m *DeleteProxyStore) Unmarshal(dAtA []byte) error

+ func (m *DeleteProxyStore) XXX_DiscardUnknown()

+ func (m *DeleteProxyStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteProxyStore) XXX_Merge(src proto.Message)

+ func (m *DeleteProxyStore) XXX_Size() int

+ func (m *DeleteProxyStore) XXX_Unmarshal(b []byte) error

+ type DeletedStore struct

+ Address string

+ DownTime int64

+ StoreType string

+ UUID string

+ UpTime int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletedStore) Descriptor() ([]byte, []int)

+ func (*DeletedStore) ProtoMessage()

+ func (m *DeletedStore) GetAddress() string

+ func (m *DeletedStore) GetDownTime() int64

+ func (m *DeletedStore) GetStoreType() string

+ func (m *DeletedStore) GetUUID() string

+ func (m *DeletedStore) GetUpTime() int64

+ func (m *DeletedStore) Marshal() (dAtA []byte, err error)

+ func (m *DeletedStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeletedStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeletedStore) Reset()

+ func (m *DeletedStore) Size() (n int)

+ func (m *DeletedStore) String() string

+ func (m *DeletedStore) Unmarshal(dAtA []byte) error

+ func (m *DeletedStore) XXX_DiscardUnknown()

+ func (m *DeletedStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeletedStore) XXX_Merge(src proto.Message)

+ func (m *DeletedStore) XXX_Size() int

+ func (m *DeletedStore) XXX_Unmarshal(b []byte) error

type HAKeeperRSMState

+ DeletedStores []DeletedStore

+ ProxyState ProxyState

+ func (m *HAKeeperRSMState) GetDeletedStores() []DeletedStore

+ func (m *HAKeeperRSMState) GetProxyState() ProxyState

type HAKeeperUpdateType

+ const ProxyHeartbeatUpdate

type LogStore

+ ConfigData *ConfigData

+ func (m *LogStore) GetConfigData() *ConfigData

type LogStoreHeartbeat

+ ConfigData *ConfigData

+ func (m *LogStoreHeartbeat) GetConfigData() *ConfigData

type LogStoreInfo

+ ConfigData *ConfigData

+ func (m *LogStoreInfo) GetConfigData() *ConfigData

type MethodType

+ const PROXY_HEARTBEAT

+ type ProxyHeartbeat struct

+ ConfigData *ConfigData

+ ListenAddress string

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProxyHeartbeat) Descriptor() ([]byte, []int)

+ func (*ProxyHeartbeat) ProtoMessage()

+ func (m *ProxyHeartbeat) GetConfigData() *ConfigData

+ func (m *ProxyHeartbeat) GetListenAddress() string

+ func (m *ProxyHeartbeat) GetUUID() string

+ func (m *ProxyHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *ProxyHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxyHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxyHeartbeat) Reset()

+ func (m *ProxyHeartbeat) Size() (n int)

+ func (m *ProxyHeartbeat) String() string

+ func (m *ProxyHeartbeat) Unmarshal(dAtA []byte) error

+ func (m *ProxyHeartbeat) XXX_DiscardUnknown()

+ func (m *ProxyHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxyHeartbeat) XXX_Merge(src proto.Message)

+ func (m *ProxyHeartbeat) XXX_Size() int

+ func (m *ProxyHeartbeat) XXX_Unmarshal(b []byte) error

+ type ProxyState struct

+ Stores map[string]ProxyStore

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewProxyState() ProxyState

+ func (*ProxyState) Descriptor() ([]byte, []int)

+ func (*ProxyState) ProtoMessage()

+ func (m *ProxyState) GetStores() map[string]ProxyStore

+ func (m *ProxyState) Marshal() (dAtA []byte, err error)

+ func (m *ProxyState) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxyState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxyState) Reset()

+ func (m *ProxyState) Size() (n int)

+ func (m *ProxyState) String() string

+ func (m *ProxyState) Unmarshal(dAtA []byte) error

+ func (m *ProxyState) XXX_DiscardUnknown()

+ func (m *ProxyState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxyState) XXX_Merge(src proto.Message)

+ func (m *ProxyState) XXX_Size() int

+ func (m *ProxyState) XXX_Unmarshal(b []byte) error

+ func (s *ProxyState) Update(hb ProxyHeartbeat, tick uint64)

+ type ProxyStore struct

+ ConfigData *ConfigData

+ ListenAddress string

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProxyStore) Descriptor() ([]byte, []int)

+ func (*ProxyStore) ProtoMessage()

+ func (m *ProxyStore) GetConfigData() *ConfigData

+ func (m *ProxyStore) GetListenAddress() string

+ func (m *ProxyStore) GetTick() uint64

+ func (m *ProxyStore) GetUUID() string

+ func (m *ProxyStore) Marshal() (dAtA []byte, err error)

+ func (m *ProxyStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProxyStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProxyStore) Reset()

+ func (m *ProxyStore) Size() (n int)

+ func (m *ProxyStore) String() string

+ func (m *ProxyStore) Unmarshal(dAtA []byte) error

+ func (m *ProxyStore) XXX_DiscardUnknown()

+ func (m *ProxyStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ProxyStore) XXX_Merge(src proto.Message)

+ func (m *ProxyStore) XXX_Size() int

+ func (m *ProxyStore) XXX_Unmarshal(b []byte) error

type Request

+ ProxyHeartbeat *ProxyHeartbeat

+ func (m *Request) GetProxyHeartbeat() *ProxyHeartbeat

+ type Resource struct

+ CPUAvailable float64

+ CPUTotal uint64

+ MemAvailable uint64

+ MemTotal uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource) Descriptor() ([]byte, []int)

+ func (*Resource) ProtoMessage()

+ func (m *Resource) GetCPUAvailable() float64

+ func (m *Resource) GetCPUTotal() uint64

+ func (m *Resource) GetMemAvailable() uint64

+ func (m *Resource) GetMemTotal() uint64

+ func (m *Resource) Marshal() (dAtA []byte, err error)

+ func (m *Resource) MarshalTo(dAtA []byte) (int, error)

+ func (m *Resource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Resource) Reset()

+ func (m *Resource) Size() (n int)

+ func (m *Resource) String() string

+ func (m *Resource) Unmarshal(dAtA []byte) error

+ func (m *Resource) XXX_DiscardUnknown()

+ func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resource) XXX_Merge(src proto.Message)

+ func (m *Resource) XXX_Size() int

+ func (m *Resource) XXX_Unmarshal(b []byte) error

type ScheduleCommand

+ DeleteProxyStore *DeleteProxyStore

+ func (m *ScheduleCommand) GetDeleteProxyStore() *DeleteProxyStore

type ServiceType

+ const ProxyService

type TNStore

+ ConfigData *ConfigData

+ QueryAddress string

+ func (m *TNStore) GetConfigData() *ConfigData

+ func (m *TNStore) GetQueryAddress() string

type TNStoreHeartbeat

+ ConfigData *ConfigData

+ QueryAddress string

+ func (m *TNStoreHeartbeat) GetConfigData() *ConfigData

+ func (m *TNStoreHeartbeat) GetQueryAddress() string

type TNStoreInfo

+ ConfigData *ConfigData

+ QueryAddress string

+ func (m *TNStoreInfo) GetConfigData() *ConfigData

+ func (m *TNStoreInfo) GetQueryAddress() string

v1.0.2

Dec 21, 2023

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

+ type BackupData struct

+ NextID uint64

+ NextIDByKey map[string]uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BackupData) Descriptor() ([]byte, []int)

+ func (*BackupData) ProtoMessage()

+ func (m *BackupData) GetNextID() uint64

+ func (m *BackupData) GetNextIDByKey() map[string]uint64

+ func (m *BackupData) Marshal() (dAtA []byte, err error)

+ func (m *BackupData) MarshalTo(dAtA []byte) (int, error)

+ func (m *BackupData) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BackupData) Reset()

+ func (m *BackupData) Size() (n int)

+ func (m *BackupData) String() string

+ func (m *BackupData) Unmarshal(dAtA []byte) error

+ func (m *BackupData) XXX_DiscardUnknown()

+ func (m *BackupData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BackupData) XXX_Merge(src proto.Message)

+ func (m *BackupData) XXX_Size() int

+ func (m *BackupData) XXX_Unmarshal(b []byte) error

type CNState

+ func (s *CNState) PatchCNStore(stateLabel CNStateLabel)

+ func (s *CNState) UpdateWorkState(state CNWorkState)

+ type CNStateLabel struct

+ Labels map[string]metadata.LabelList

+ State metadata.WorkState

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNStateLabel) Descriptor() ([]byte, []int)

+ func (*CNStateLabel) ProtoMessage()

+ func (m *CNStateLabel) GetLabels() map[string]metadata.LabelList

+ func (m *CNStateLabel) GetState() metadata.WorkState

+ func (m *CNStateLabel) GetUUID() string

+ func (m *CNStateLabel) Marshal() (dAtA []byte, err error)

+ func (m *CNStateLabel) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNStateLabel) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNStateLabel) Reset()

+ func (m *CNStateLabel) Size() (n int)

+ func (m *CNStateLabel) String() string

+ func (m *CNStateLabel) Unmarshal(dAtA []byte) error

+ func (m *CNStateLabel) XXX_DiscardUnknown()

+ func (m *CNStateLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNStateLabel) XXX_Merge(src proto.Message)

+ func (m *CNStateLabel) XXX_Size() int

+ func (m *CNStateLabel) XXX_Unmarshal(b []byte) error

type CNStore

+ QueryAddress string

+ WorkState metadata.WorkState

+ func (m *CNStore) GetQueryAddress() string

+ func (m *CNStore) GetWorkState() metadata.WorkState

type CNStoreHeartbeat

+ GossipAddress string

+ GossipJoined bool

+ InitWorkState string

+ QueryAddress string

+ func (m *CNStoreHeartbeat) GetGossipAddress() string

+ func (m *CNStoreHeartbeat) GetGossipJoined() bool

+ func (m *CNStoreHeartbeat) GetInitWorkState() string

+ func (m *CNStoreHeartbeat) GetQueryAddress() string

type CNStoreInfo

+ GossipAddress string

+ GossipJoined bool

+ QueryAddress string

+ WorkState metadata.WorkState

+ func (m *CNStoreInfo) GetGossipAddress() string

+ func (m *CNStoreInfo) GetGossipJoined() bool

+ func (m *CNStoreInfo) GetQueryAddress() string

+ func (m *CNStoreInfo) GetWorkState() metadata.WorkState

+ type CNWorkState struct

+ State metadata.WorkState

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNWorkState) Descriptor() ([]byte, []int)

+ func (*CNWorkState) ProtoMessage()

+ func (m *CNWorkState) GetState() metadata.WorkState

+ func (m *CNWorkState) GetUUID() string

+ func (m *CNWorkState) Marshal() (dAtA []byte, err error)

+ func (m *CNWorkState) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNWorkState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNWorkState) Reset()

+ func (m *CNWorkState) Size() (n int)

+ func (m *CNWorkState) String() string

+ func (m *CNWorkState) Unmarshal(dAtA []byte) error

+ func (m *CNWorkState) XXX_DiscardUnknown()

+ func (m *CNWorkState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNWorkState) XXX_Merge(src proto.Message)

+ func (m *CNWorkState) XXX_Size() int

+ func (m *CNWorkState) XXX_Unmarshal(b []byte) error

type CheckerState

+ NextIDByKey map[string]uint64

+ TNState TNState

+ func (m *CheckerState) GetNextIDByKey() map[string]uint64

+ func (m *CheckerState) GetTNState() TNState

type ClusterDetails

+ TNStores []TNStore

+ func (m *ClusterDetails) GetTNStores() []TNStore

type ClusterInfo

+ TNShards []metadata.TNShardRecord

+ func (m *ClusterInfo) GetTNShards() []metadata.TNShardRecord

type HAKeeperRSMState

+ Index uint64

+ TNState TNState

+ func (m *HAKeeperRSMState) GetIndex() uint64

+ func (m *HAKeeperRSMState) GetTNState() TNState

type HAKeeperUpdateType

+ const PatchCNStore

+ const RemoveCNStore

+ const TNHeartbeatUpdate

+ const UpdateCNWorkState

type InitialClusterRequest

+ NextID uint64

+ NextIDByKey map[string]uint64

+ NumOfTNShards uint64

+ func (m *InitialClusterRequest) GetNextID() uint64

+ func (m *InitialClusterRequest) GetNextIDByKey() map[string]uint64

+ func (m *InitialClusterRequest) GetNumOfTNShards() uint64

+ type JoinGossipCluster struct

+ Existing []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*JoinGossipCluster) Descriptor() ([]byte, []int)

+ func (*JoinGossipCluster) ProtoMessage()

+ func (m *JoinGossipCluster) GetExisting() []string

+ func (m *JoinGossipCluster) Marshal() (dAtA []byte, err error)

+ func (m *JoinGossipCluster) MarshalTo(dAtA []byte) (int, error)

+ func (m *JoinGossipCluster) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *JoinGossipCluster) Reset()

+ func (m *JoinGossipCluster) Size() (n int)

+ func (m *JoinGossipCluster) String() string

+ func (m *JoinGossipCluster) Unmarshal(dAtA []byte) error

+ func (m *JoinGossipCluster) XXX_DiscardUnknown()

+ func (m *JoinGossipCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *JoinGossipCluster) XXX_Merge(src proto.Message)

+ func (m *JoinGossipCluster) XXX_Size() int

+ func (m *JoinGossipCluster) XXX_Unmarshal(b []byte) error

type LogRequest

+ TNID uint64

+ TNShardID uint64

+ func (m *LogRequest) GetTNID() uint64

+ func (m *LogRequest) GetTNShardID() uint64

type MethodType

+ const DELETE_CN_STORE

+ const PATCH_CN_STORE

+ const TN_HEARTBEAT

+ const UPDATE_CN_WORK_STATE

type Request

+ CNStateLabel *CNStateLabel

+ CNWorkState *CNWorkState

+ DeleteCNStore *DeleteCNStore

+ TNHeartbeat *TNStoreHeartbeat

+ func (m *Request) GetCNStateLabel() *CNStateLabel

+ func (m *Request) GetCNWorkState() *CNWorkState

+ func (m *Request) GetDeleteCNStore() *DeleteCNStore

+ func (m *Request) GetTNHeartbeat() *TNStoreHeartbeat

type ScheduleCommand

+ JoinGossipCluster *JoinGossipCluster

+ func (m *ScheduleCommand) GetJoinGossipCluster() *JoinGossipCluster

type ServiceType

+ const TNService

+ type TNShardInfo struct

+ ReplicaID uint64

+ ShardID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TNShardInfo) Descriptor() ([]byte, []int)

+ func (*TNShardInfo) ProtoMessage()

+ func (m *TNShardInfo) GetReplicaID() uint64

+ func (m *TNShardInfo) GetShardID() uint64

+ func (m *TNShardInfo) Marshal() (dAtA []byte, err error)

+ func (m *TNShardInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNShardInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNShardInfo) Reset()

+ func (m *TNShardInfo) Size() (n int)

+ func (m *TNShardInfo) String() string

+ func (m *TNShardInfo) Unmarshal(dAtA []byte) error

+ func (m *TNShardInfo) XXX_DiscardUnknown()

+ func (m *TNShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNShardInfo) XXX_Merge(src proto.Message)

+ func (m *TNShardInfo) XXX_Size() int

+ func (m *TNShardInfo) XXX_Unmarshal(b []byte) error

+ type TNState struct

+ Stores map[string]TNStoreInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewTNState() TNState

+ func (*TNState) Descriptor() ([]byte, []int)

+ func (*TNState) ProtoMessage()

+ func (m *TNState) GetStores() map[string]TNStoreInfo

+ func (m *TNState) Marshal() (dAtA []byte, err error)

+ func (m *TNState) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNState) Reset()

+ func (m *TNState) Size() (n int)

+ func (m *TNState) String() string

+ func (m *TNState) Unmarshal(dAtA []byte) error

+ func (m *TNState) XXX_DiscardUnknown()

+ func (m *TNState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNState) XXX_Merge(src proto.Message)

+ func (m *TNState) XXX_Size() int

+ func (m *TNState) XXX_Unmarshal(b []byte) error

+ func (s *TNState) Update(hb TNStoreHeartbeat, tick uint64)

+ type TNStore struct

+ CtlAddress string

+ LockServiceAddress string

+ LogtailServerAddress string

+ ServiceAddress string

+ Shards []TNShardInfo

+ State NodeState

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TNStore) Descriptor() ([]byte, []int)

+ func (*TNStore) ProtoMessage()

+ func (m *TNStore) GetCtlAddress() string

+ func (m *TNStore) GetLockServiceAddress() string

+ func (m *TNStore) GetLogtailServerAddress() string

+ func (m *TNStore) GetServiceAddress() string

+ func (m *TNStore) GetShards() []TNShardInfo

+ func (m *TNStore) GetState() NodeState

+ func (m *TNStore) GetTick() uint64

+ func (m *TNStore) GetUUID() string

+ func (m *TNStore) Marshal() (dAtA []byte, err error)

+ func (m *TNStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNStore) Reset()

+ func (m *TNStore) Size() (n int)

+ func (m *TNStore) String() string

+ func (m *TNStore) Unmarshal(dAtA []byte) error

+ func (m *TNStore) XXX_DiscardUnknown()

+ func (m *TNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNStore) XXX_Merge(src proto.Message)

+ func (m *TNStore) XXX_Size() int

+ func (m *TNStore) XXX_Unmarshal(b []byte) error

+ type TNStoreHeartbeat struct

+ CtlAddress string

+ LockServiceAddress string

+ LogtailServerAddress string

+ ServiceAddress string

+ Shards []TNShardInfo

+ TaskServiceCreated bool

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TNStoreHeartbeat) Descriptor() ([]byte, []int)

+ func (*TNStoreHeartbeat) ProtoMessage()

+ func (m *TNStoreHeartbeat) GetCtlAddress() string

+ func (m *TNStoreHeartbeat) GetLockServiceAddress() string

+ func (m *TNStoreHeartbeat) GetLogtailServerAddress() string

+ func (m *TNStoreHeartbeat) GetServiceAddress() string

+ func (m *TNStoreHeartbeat) GetShards() []TNShardInfo

+ func (m *TNStoreHeartbeat) GetTaskServiceCreated() bool

+ func (m *TNStoreHeartbeat) GetUUID() string

+ func (m *TNStoreHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *TNStoreHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNStoreHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNStoreHeartbeat) Reset()

+ func (m *TNStoreHeartbeat) Size() (n int)

+ func (m *TNStoreHeartbeat) String() string

+ func (m *TNStoreHeartbeat) Unmarshal(dAtA []byte) error

+ func (m *TNStoreHeartbeat) XXX_DiscardUnknown()

+ func (m *TNStoreHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNStoreHeartbeat) XXX_Merge(src proto.Message)

+ func (m *TNStoreHeartbeat) XXX_Size() int

+ func (m *TNStoreHeartbeat) XXX_Unmarshal(b []byte) error

+ type TNStoreInfo struct

+ CtlAddress string

+ LockServiceAddress string

+ LogtailServerAddress string

+ ServiceAddress string

+ Shards []TNShardInfo

+ TaskServiceCreated bool

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TNStoreInfo) Descriptor() ([]byte, []int)

+ func (*TNStoreInfo) ProtoMessage()

+ func (m *TNStoreInfo) GetCtlAddress() string

+ func (m *TNStoreInfo) GetLockServiceAddress() string

+ func (m *TNStoreInfo) GetLogtailServerAddress() string

+ func (m *TNStoreInfo) GetServiceAddress() string

+ func (m *TNStoreInfo) GetShards() []TNShardInfo

+ func (m *TNStoreInfo) GetTaskServiceCreated() bool

+ func (m *TNStoreInfo) GetTick() uint64

+ func (m *TNStoreInfo) Marshal() (dAtA []byte, err error)

+ func (m *TNStoreInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *TNStoreInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TNStoreInfo) Reset()

+ func (m *TNStoreInfo) Size() (n int)

+ func (m *TNStoreInfo) String() string

+ func (m *TNStoreInfo) Unmarshal(dAtA []byte) error

+ func (m *TNStoreInfo) XXX_DiscardUnknown()

+ func (m *TNStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TNStoreInfo) XXX_Merge(src proto.Message)

+ func (m *TNStoreInfo) XXX_Size() int

+ func (m *TNStoreInfo) XXX_Unmarshal(b []byte) error

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

+ var CNLabelOp_name = map[int32]string

+ var CNLabelOp_value = map[string]int32

type CNAllocateID

+ Key string

+ func (m *CNAllocateID) GetKey() string

+ type CNLabelOp int32

+ const DeleteLabel

+ const SetLabel

+ func (CNLabelOp) EnumDescriptor() ([]byte, []int)

+ func (x CNLabelOp) String() string

type CNState

+ func (s *CNState) UpdateLabel(label CNStoreLabel)

type CNStore

+ CtlAddress string

+ Labels map[string]metadata.LabelList

+ LockServiceAddress string

+ func (m *CNStore) GetCtlAddress() string

+ func (m *CNStore) GetLabels() map[string]metadata.LabelList

+ func (m *CNStore) GetLockServiceAddress() string

type CNStoreHeartbeat

+ CtlAddress string

+ LockServiceAddress string

+ func (m *CNStoreHeartbeat) GetCtlAddress() string

+ func (m *CNStoreHeartbeat) GetLockServiceAddress() string

type CNStoreInfo

+ CtlAddress string

+ Labels map[string]metadata.LabelList

+ LockServiceAddress string

+ func (m *CNStoreInfo) GetCtlAddress() string

+ func (m *CNStoreInfo) GetLabels() map[string]metadata.LabelList

+ func (m *CNStoreInfo) GetLockServiceAddress() string

+ type CNStoreLabel struct

+ Labels map[string]metadata.LabelList

+ Operation CNLabelOp

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNStoreLabel) Descriptor() ([]byte, []int)

+ func (*CNStoreLabel) ProtoMessage()

+ func (m *CNStoreLabel) GetLabels() map[string]metadata.LabelList

+ func (m *CNStoreLabel) GetOperation() CNLabelOp

+ func (m *CNStoreLabel) GetUUID() string

+ func (m *CNStoreLabel) Marshal() (dAtA []byte, err error)

+ func (m *CNStoreLabel) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNStoreLabel) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNStoreLabel) Reset()

+ func (m *CNStoreLabel) Size() (n int)

+ func (m *CNStoreLabel) String() string

+ func (m *CNStoreLabel) Unmarshal(dAtA []byte) error

+ func (m *CNStoreLabel) XXX_DiscardUnknown()

+ func (m *CNStoreLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNStoreLabel) XXX_Merge(src proto.Message)

+ func (m *CNStoreLabel) XXX_Size() int

+ func (m *CNStoreLabel) XXX_Unmarshal(b []byte) error

type CheckerState

+ NextId uint64

+ func (m *CheckerState) GetNextId() uint64

type DNStore

+ CtlAddress string

+ LockServiceAddress string

+ func (m *DNStore) GetCtlAddress() string

+ func (m *DNStore) GetLockServiceAddress() string

type DNStoreHeartbeat

+ CtlAddress string

+ LockServiceAddress string

+ func (m *DNStoreHeartbeat) GetCtlAddress() string

+ func (m *DNStoreHeartbeat) GetLockServiceAddress() string

type DNStoreInfo

+ CtlAddress string

+ LockServiceAddress string

+ func (m *DNStoreInfo) GetCtlAddress() string

+ func (m *DNStoreInfo) GetLockServiceAddress() string

type HAKeeperRSMState

+ NextIDByKey map[string]uint64

+ func (m *HAKeeperRSMState) GetNextIDByKey() map[string]uint64

type HAKeeperUpdateType

+ const UpdateCNLabel

type MethodType

+ const UPDATE_CN_LABEL

type Request

+ CNStoreLabel *CNStoreLabel

+ func (m *Request) GetCNStoreLabel() *CNStoreLabel

v0.7.0

Feb 18, 2023

Changes in this version

+ var TaskSchedulerState_name = map[int32]string

+ var TaskSchedulerState_value = map[string]int32

type CheckerState

+ TaskSchedulerState TaskSchedulerState

+ func (m *CheckerState) GetTaskSchedulerState() TaskSchedulerState

type DNStore

+ LogtailServerAddress string

+ func (m *DNStore) GetLogtailServerAddress() string

type DNStoreHeartbeat

+ LogtailServerAddress string

+ func (m *DNStoreHeartbeat) GetLogtailServerAddress() string

type DNStoreInfo

+ LogtailServerAddress string

+ func (m *DNStoreInfo) GetLogtailServerAddress() string

+ type DeleteCNStore struct

+ StoreID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteCNStore) Descriptor() ([]byte, []int)

+ func (*DeleteCNStore) ProtoMessage()

+ func (m *DeleteCNStore) GetStoreID() string

+ func (m *DeleteCNStore) Marshal() (dAtA []byte, err error)

+ func (m *DeleteCNStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteCNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteCNStore) Reset()

+ func (m *DeleteCNStore) Size() (n int)

+ func (m *DeleteCNStore) String() string

+ func (m *DeleteCNStore) Unmarshal(dAtA []byte) error

+ func (m *DeleteCNStore) XXX_DiscardUnknown()

+ func (m *DeleteCNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteCNStore) XXX_Merge(src proto.Message)

+ func (m *DeleteCNStore) XXX_Size() int

+ func (m *DeleteCNStore) XXX_Unmarshal(b []byte) error

type HAKeeperRSMState

+ TaskSchedulerState TaskSchedulerState

+ func (m *HAKeeperRSMState) GetTaskSchedulerState() TaskSchedulerState

type HAKeeperUpdateType

+ const SetTaskSchedulerStateUpdate

+ const SetTaskTableUserUpdate

type ScheduleCommand

+ DeleteCNStore *DeleteCNStore

+ func (m *ScheduleCommand) GetDeleteCNStore() *DeleteCNStore

+ type TaskSchedulerState int32

+ const TaskSchedulerCreated

+ const TaskSchedulerRunning

+ const TaskSchedulerStopped

+ func (TaskSchedulerState) EnumDescriptor() ([]byte, []int)

+ func (x TaskSchedulerState) String() string

v0.6.0

Nov 29, 2022

Changes in this version

+ var NodeState_name = map[int32]string

+ var NodeState_value = map[string]int32

+ var TaskInitState_name = map[int32]string

+ var TaskInitState_value = map[string]int32

+ type AllocateIDResponse struct

+ FirstID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AllocateIDResponse) Descriptor() ([]byte, []int)

+ func (*AllocateIDResponse) ProtoMessage()

+ func (m *AllocateIDResponse) GetFirstID() uint64

+ func (m *AllocateIDResponse) Marshal() (dAtA []byte, err error)

+ func (m *AllocateIDResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AllocateIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AllocateIDResponse) Reset()

+ func (m *AllocateIDResponse) Size() (n int)

+ func (m *AllocateIDResponse) String() string

+ func (m *AllocateIDResponse) Unmarshal(dAtA []byte) error

+ func (m *AllocateIDResponse) XXX_DiscardUnknown()

+ func (m *AllocateIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AllocateIDResponse) XXX_Merge(src proto.Message)

+ func (m *AllocateIDResponse) XXX_Size() int

+ func (m *AllocateIDResponse) XXX_Unmarshal(b []byte) error

+ type CNAllocateID struct

+ Batch uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNAllocateID) Descriptor() ([]byte, []int)

+ func (*CNAllocateID) ProtoMessage()

+ func (m *CNAllocateID) GetBatch() uint64

+ func (m *CNAllocateID) Marshal() (dAtA []byte, err error)

+ func (m *CNAllocateID) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNAllocateID) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNAllocateID) Reset()

+ func (m *CNAllocateID) Size() (n int)

+ func (m *CNAllocateID) String() string

+ func (m *CNAllocateID) Unmarshal(dAtA []byte) error

+ func (m *CNAllocateID) XXX_DiscardUnknown()

+ func (m *CNAllocateID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNAllocateID) XXX_Merge(src proto.Message)

+ func (m *CNAllocateID) XXX_Size() int

+ func (m *CNAllocateID) XXX_Unmarshal(b []byte) error

+ type CNStore struct

+ Role metadata.CNRole

+ SQLAddress string

+ ServiceAddress string

+ State NodeState

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNStore) Descriptor() ([]byte, []int)

+ func (*CNStore) ProtoMessage()

+ func (m *CNStore) GetRole() metadata.CNRole

+ func (m *CNStore) GetSQLAddress() string

+ func (m *CNStore) GetServiceAddress() string

+ func (m *CNStore) GetState() NodeState

+ func (m *CNStore) GetTick() uint64

+ func (m *CNStore) GetUUID() string

+ func (m *CNStore) Marshal() (dAtA []byte, err error)

+ func (m *CNStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNStore) Reset()

+ func (m *CNStore) Size() (n int)

+ func (m *CNStore) String() string

+ func (m *CNStore) Unmarshal(dAtA []byte) error

+ func (m *CNStore) XXX_DiscardUnknown()

+ func (m *CNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNStore) XXX_Merge(src proto.Message)

+ func (m *CNStore) XXX_Size() int

+ func (m *CNStore) XXX_Unmarshal(b []byte) error

type CNStoreHeartbeat

+ Role metadata.CNRole

+ SQLAddress string

+ TaskServiceCreated bool

+ func (m *CNStoreHeartbeat) GetRole() metadata.CNRole

+ func (m *CNStoreHeartbeat) GetSQLAddress() string

+ func (m *CNStoreHeartbeat) GetTaskServiceCreated() bool

type CNStoreInfo

+ Role metadata.CNRole

+ SQLAddress string

+ TaskServiceCreated bool

+ func (m *CNStoreInfo) GetRole() metadata.CNRole

+ func (m *CNStoreInfo) GetSQLAddress() string

+ func (m *CNStoreInfo) GetTaskServiceCreated() bool

type CheckerState

+ CNState CNState

+ TaskState TaskInitState

+ TaskTableUser TaskTableUser

+ func (m *CheckerState) GetCNState() CNState

+ func (m *CheckerState) GetTaskState() TaskInitState

+ func (m *CheckerState) GetTaskTableUser() TaskTableUser

type ClusterDetails

+ CNStores []CNStore

+ DNStores []DNStore

+ LogStores []LogStore

+ func (m *ClusterDetails) GetCNStores() []CNStore

+ func (m *ClusterDetails) GetDNStores() []DNStore

+ func (m *ClusterDetails) GetLogStores() []LogStore

type ConfigChangeType

+ const KillZombie

+ type CreateTaskService struct

+ TaskDatabase string

+ User TaskTableUser

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateTaskService) Descriptor() ([]byte, []int)

+ func (*CreateTaskService) ProtoMessage()

+ func (m *CreateTaskService) GetTaskDatabase() string

+ func (m *CreateTaskService) GetUser() TaskTableUser

+ func (m *CreateTaskService) Marshal() (dAtA []byte, err error)

+ func (m *CreateTaskService) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateTaskService) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateTaskService) Reset()

+ func (m *CreateTaskService) Size() (n int)

+ func (m *CreateTaskService) String() string

+ func (m *CreateTaskService) Unmarshal(dAtA []byte) error

+ func (m *CreateTaskService) XXX_DiscardUnknown()

+ func (m *CreateTaskService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CreateTaskService) XXX_Merge(src proto.Message)

+ func (m *CreateTaskService) XXX_Size() int

+ func (m *CreateTaskService) XXX_Unmarshal(b []byte) error

+ type DNStore struct

+ ServiceAddress string

+ Shards []DNShardInfo

+ State NodeState

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DNStore) Descriptor() ([]byte, []int)

+ func (*DNStore) ProtoMessage()

+ func (m *DNStore) GetServiceAddress() string

+ func (m *DNStore) GetShards() []DNShardInfo

+ func (m *DNStore) GetState() NodeState

+ func (m *DNStore) GetTick() uint64

+ func (m *DNStore) GetUUID() string

+ func (m *DNStore) Marshal() (dAtA []byte, err error)

+ func (m *DNStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNStore) Reset()

+ func (m *DNStore) Size() (n int)

+ func (m *DNStore) String() string

+ func (m *DNStore) Unmarshal(dAtA []byte) error

+ func (m *DNStore) XXX_DiscardUnknown()

+ func (m *DNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNStore) XXX_Merge(src proto.Message)

+ func (m *DNStore) XXX_Size() int

+ func (m *DNStore) XXX_Unmarshal(b []byte) error

type DNStoreHeartbeat

+ TaskServiceCreated bool

+ func (m *DNStoreHeartbeat) GetTaskServiceCreated() bool

type DNStoreInfo

+ TaskServiceCreated bool

+ func (m *DNStoreInfo) GetTaskServiceCreated() bool

type HAKeeperRSMState

+ TaskInitState TaskInitState

+ TaskTableUser TaskTableUser

+ func (m *HAKeeperRSMState) GetTaskInitState() TaskInitState

+ func (m *HAKeeperRSMState) GetTaskTableUser() TaskTableUser

type HAKeeperUpdateType

+ const SetInitTaskStateUpdate

+ const TaskTableUserUpdate

+ type LogStore struct

+ Replicas []LogReplicaInfo

+ ServiceAddress string

+ State NodeState

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStore) Descriptor() ([]byte, []int)

+ func (*LogStore) ProtoMessage()

+ func (m *LogStore) GetReplicas() []LogReplicaInfo

+ func (m *LogStore) GetServiceAddress() string

+ func (m *LogStore) GetState() NodeState

+ func (m *LogStore) GetTick() uint64

+ func (m *LogStore) GetUUID() string

+ func (m *LogStore) Marshal() (dAtA []byte, err error)

+ func (m *LogStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogStore) Reset()

+ func (m *LogStore) Size() (n int)

+ func (m *LogStore) String() string

+ func (m *LogStore) Unmarshal(dAtA []byte) error

+ func (m *LogStore) XXX_DiscardUnknown()

+ func (m *LogStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogStore) XXX_Merge(src proto.Message)

+ func (m *LogStore) XXX_Size() int

+ func (m *LogStore) XXX_Unmarshal(b []byte) error

type LogStoreHeartbeat

+ TaskServiceCreated bool

+ func (m *LogStoreHeartbeat) GetTaskServiceCreated() bool

type LogStoreInfo

+ TaskServiceCreated bool

+ func (m *LogStoreInfo) GetTaskServiceCreated() bool

type MethodType

+ const CN_ALLOCATE_ID

+ const GET_CLUSTER_STATE

+ const GET_SHARD_INFO

+ type NodeState int32

+ const NormalState

+ const TimeoutState

+ func (NodeState) EnumDescriptor() ([]byte, []int)

+ func (x NodeState) String() string

type Replica

+ LogShardID uint64

+ func (m *Replica) GetLogShardID() uint64

+ type ReplicaInfo struct

+ ServiceAddress string

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReplicaInfo) Descriptor() ([]byte, []int)

+ func (*ReplicaInfo) ProtoMessage()

+ func (m *ReplicaInfo) GetServiceAddress() string

+ func (m *ReplicaInfo) GetUUID() string

+ func (m *ReplicaInfo) Marshal() (dAtA []byte, err error)

+ func (m *ReplicaInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReplicaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ReplicaInfo) Reset()

+ func (m *ReplicaInfo) Size() (n int)

+ func (m *ReplicaInfo) String() string

+ func (m *ReplicaInfo) Unmarshal(dAtA []byte) error

+ func (m *ReplicaInfo) XXX_DiscardUnknown()

+ func (m *ReplicaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReplicaInfo) XXX_Merge(src proto.Message)

+ func (m *ReplicaInfo) XXX_Size() int

+ func (m *ReplicaInfo) XXX_Unmarshal(b []byte) error

type Request

+ CNAllocateID *CNAllocateID

+ func (m *Request) GetCNAllocateID() *CNAllocateID

type Response

+ AllocateID *AllocateIDResponse

+ CheckerState *CheckerState

+ ShardInfo *ShardInfoQueryResult

+ func (m *Response) GetAllocateID() *AllocateIDResponse

+ func (m *Response) GetCheckerState() *CheckerState

+ func (m *Response) GetShardInfo() *ShardInfoQueryResult

type ScheduleCommand

+ CreateTaskService *CreateTaskService

+ func (m *ScheduleCommand) GetCreateTaskService() *CreateTaskService

type ServiceType

+ const CNService

+ const DNService

+ type ShardInfoQueryResult struct

+ Epoch uint64

+ LeaderID uint64

+ Replicas map[uint64]ReplicaInfo

+ ShardID uint64

+ Term uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ShardInfoQueryResult) Descriptor() ([]byte, []int)

+ func (*ShardInfoQueryResult) ProtoMessage()

+ func (m *ShardInfoQueryResult) GetEpoch() uint64

+ func (m *ShardInfoQueryResult) GetLeaderID() uint64

+ func (m *ShardInfoQueryResult) GetReplicas() map[uint64]ReplicaInfo

+ func (m *ShardInfoQueryResult) GetShardID() uint64

+ func (m *ShardInfoQueryResult) GetTerm() uint64

+ func (m *ShardInfoQueryResult) Marshal() (dAtA []byte, err error)

+ func (m *ShardInfoQueryResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShardInfoQueryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShardInfoQueryResult) Reset()

+ func (m *ShardInfoQueryResult) Size() (n int)

+ func (m *ShardInfoQueryResult) String() string

+ func (m *ShardInfoQueryResult) Unmarshal(dAtA []byte) error

+ func (m *ShardInfoQueryResult) XXX_DiscardUnknown()

+ func (m *ShardInfoQueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShardInfoQueryResult) XXX_Merge(src proto.Message)

+ func (m *ShardInfoQueryResult) XXX_Size() int

+ func (m *ShardInfoQueryResult) XXX_Unmarshal(b []byte) error

+ type TaskInitState int32

+ const TaskInitCompleted

+ const TaskInitFailed

+ const TaskInitNotStart

+ const TaskInitStarted

+ func (TaskInitState) EnumDescriptor() ([]byte, []int)

+ func (x TaskInitState) String() string

+ type TaskTableUser struct

+ Password string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskTableUser) Descriptor() ([]byte, []int)

+ func (*TaskTableUser) ProtoMessage()

+ func (m *TaskTableUser) GetPassword() string

+ func (m *TaskTableUser) GetUsername() string

+ func (m *TaskTableUser) Marshal() (dAtA []byte, err error)

+ func (m *TaskTableUser) MarshalTo(dAtA []byte) (int, error)

+ func (m *TaskTableUser) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TaskTableUser) Reset()

+ func (m *TaskTableUser) Size() (n int)

+ func (m *TaskTableUser) String() string

+ func (m *TaskTableUser) Unmarshal(dAtA []byte) error

+ func (m *TaskTableUser) XXX_DiscardUnknown()

+ func (m *TaskTableUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskTableUser) XXX_Merge(src proto.Message)

+ func (m *TaskTableUser) XXX_Size() int

+ func (m *TaskTableUser) XXX_Unmarshal(b []byte) error

v0.5.1

Aug 17, 2022

Changes in this version

+ type CNNode struct

+ ServiceAddress string

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNNode) Descriptor() ([]byte, []int)

+ func (*CNNode) ProtoMessage()

+ func (m *CNNode) GetServiceAddress() string

+ func (m *CNNode) GetTick() uint64

+ func (m *CNNode) GetUUID() string

+ func (m *CNNode) Marshal() (dAtA []byte, err error)

+ func (m *CNNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNNode) Reset()

+ func (m *CNNode) Size() (n int)

+ func (m *CNNode) String() string

+ func (m *CNNode) Unmarshal(dAtA []byte) error

+ func (m *CNNode) XXX_DiscardUnknown()

+ func (m *CNNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNNode) XXX_Merge(src proto.Message)

+ func (m *CNNode) XXX_Size() int

+ func (m *CNNode) XXX_Unmarshal(b []byte) error

type CNStoreHeartbeat

+ ServiceAddress string

+ func (m *CNStoreHeartbeat) GetServiceAddress() string

type CNStoreInfo

+ ServiceAddress string

+ func (m *CNStoreInfo) GetServiceAddress() string

+ type ClusterDetails struct

+ CNNodes []CNNode

+ DNNodes []DNNode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterDetails) Descriptor() ([]byte, []int)

+ func (*ClusterDetails) ProtoMessage()

+ func (m *ClusterDetails) GetCNNodes() []CNNode

+ func (m *ClusterDetails) GetDNNodes() []DNNode

+ func (m *ClusterDetails) Marshal() (dAtA []byte, err error)

+ func (m *ClusterDetails) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterDetails) Reset()

+ func (m *ClusterDetails) Size() (n int)

+ func (m *ClusterDetails) String() string

+ func (m *ClusterDetails) Unmarshal(dAtA []byte) error

+ func (m *ClusterDetails) XXX_DiscardUnknown()

+ func (m *ClusterDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterDetails) XXX_Merge(src proto.Message)

+ func (m *ClusterDetails) XXX_Size() int

+ func (m *ClusterDetails) XXX_Unmarshal(b []byte) error

+ type DNNode struct

+ ServiceAddress string

+ Tick uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DNNode) Descriptor() ([]byte, []int)

+ func (*DNNode) ProtoMessage()

+ func (m *DNNode) GetServiceAddress() string

+ func (m *DNNode) GetTick() uint64

+ func (m *DNNode) GetUUID() string

+ func (m *DNNode) Marshal() (dAtA []byte, err error)

+ func (m *DNNode) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNNode) Reset()

+ func (m *DNNode) Size() (n int)

+ func (m *DNNode) String() string

+ func (m *DNNode) Unmarshal(dAtA []byte) error

+ func (m *DNNode) XXX_DiscardUnknown()

+ func (m *DNNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNNode) XXX_Merge(src proto.Message)

+ func (m *DNNode) XXX_Size() int

+ func (m *DNNode) XXX_Unmarshal(b []byte) error

type DNStoreHeartbeat

+ ServiceAddress string

+ func (m *DNStoreHeartbeat) GetServiceAddress() string

type DNStoreInfo

+ ServiceAddress string

+ func (m *DNStoreInfo) GetServiceAddress() string

type MethodType

+ const CHECK_HAKEEPER

+ const GET_CLUSTER_DETAILS

type Response

+ ClusterDetails ClusterDetails

+ IsHAKeeper bool

+ func (m *Response) GetClusterDetails() ClusterDetails

+ func (m *Response) GetIsHAKeeper() bool

type ScheduleCommand

+ func (m *ScheduleCommand) LogString() string

v0.5.0

Jul 14, 2022

Changes in this version

+ const HeaderSize

+ const NoLeader

+ var ConfigChangeType_name = map[int32]string

+ var ConfigChangeType_value = map[string]int32

+ var ErrIntOverflowLogservice = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthLogservice = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupLogservice = fmt.Errorf("proto: unexpected end of group")

+ var ErrorCode_name = map[int32]string

+ var ErrorCode_value = map[string]int32

+ var HAKeeperState_name = map[int32]string

+ var HAKeeperState_value = map[string]int32

+ var HAKeeperUpdateType_name = map[int32]string

+ var HAKeeperUpdateType_value = map[string]int32

+ var MethodType_name = map[int32]string

+ var MethodType_value = map[string]int32

+ var RecordType_name = map[int32]string

+ var RecordType_value = map[string]int32

+ var ServiceType_name = map[int32]string

+ var ServiceType_value = map[string]int32

+ var UpdateType_name = map[int32]string

+ var UpdateType_value = map[string]int32

+ type CNState struct

+ Stores map[string]CNStoreInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewCNState() CNState

+ func (*CNState) Descriptor() ([]byte, []int)

+ func (*CNState) ProtoMessage()

+ func (m *CNState) GetStores() map[string]CNStoreInfo

+ func (m *CNState) Marshal() (dAtA []byte, err error)

+ func (m *CNState) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNState) Reset()

+ func (m *CNState) Size() (n int)

+ func (m *CNState) String() string

+ func (m *CNState) Unmarshal(dAtA []byte) error

+ func (m *CNState) XXX_DiscardUnknown()

+ func (m *CNState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNState) XXX_Merge(src proto.Message)

+ func (m *CNState) XXX_Size() int

+ func (m *CNState) XXX_Unmarshal(b []byte) error

+ func (s *CNState) Update(hb CNStoreHeartbeat, tick uint64)

+ type CNStoreHeartbeat struct

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNStoreHeartbeat) Descriptor() ([]byte, []int)

+ func (*CNStoreHeartbeat) ProtoMessage()

+ func (m *CNStoreHeartbeat) GetUUID() string

+ func (m *CNStoreHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *CNStoreHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNStoreHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNStoreHeartbeat) Reset()

+ func (m *CNStoreHeartbeat) Size() (n int)

+ func (m *CNStoreHeartbeat) String() string

+ func (m *CNStoreHeartbeat) Unmarshal(dAtA []byte) error

+ func (m *CNStoreHeartbeat) XXX_DiscardUnknown()

+ func (m *CNStoreHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNStoreHeartbeat) XXX_Merge(src proto.Message)

+ func (m *CNStoreHeartbeat) XXX_Size() int

+ func (m *CNStoreHeartbeat) XXX_Unmarshal(b []byte) error

+ type CNStoreInfo struct

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CNStoreInfo) Descriptor() ([]byte, []int)

+ func (*CNStoreInfo) ProtoMessage()

+ func (m *CNStoreInfo) GetTick() uint64

+ func (m *CNStoreInfo) Marshal() (dAtA []byte, err error)

+ func (m *CNStoreInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *CNStoreInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CNStoreInfo) Reset()

+ func (m *CNStoreInfo) Size() (n int)

+ func (m *CNStoreInfo) String() string

+ func (m *CNStoreInfo) Unmarshal(dAtA []byte) error

+ func (m *CNStoreInfo) XXX_DiscardUnknown()

+ func (m *CNStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CNStoreInfo) XXX_Merge(src proto.Message)

+ func (m *CNStoreInfo) XXX_Size() int

+ func (m *CNStoreInfo) XXX_Unmarshal(b []byte) error

+ type CheckerState struct

+ ClusterInfo ClusterInfo

+ DNState DNState

+ LogState LogState

+ State HAKeeperState

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CheckerState) Descriptor() ([]byte, []int)

+ func (*CheckerState) ProtoMessage()

+ func (m *CheckerState) GetClusterInfo() ClusterInfo

+ func (m *CheckerState) GetDNState() DNState

+ func (m *CheckerState) GetLogState() LogState

+ func (m *CheckerState) GetState() HAKeeperState

+ func (m *CheckerState) GetTick() uint64

+ func (m *CheckerState) Marshal() (dAtA []byte, err error)

+ func (m *CheckerState) MarshalTo(dAtA []byte) (int, error)

+ func (m *CheckerState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CheckerState) Reset()

+ func (m *CheckerState) Size() (n int)

+ func (m *CheckerState) String() string

+ func (m *CheckerState) Unmarshal(dAtA []byte) error

+ func (m *CheckerState) XXX_DiscardUnknown()

+ func (m *CheckerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CheckerState) XXX_Merge(src proto.Message)

+ func (m *CheckerState) XXX_Size() int

+ func (m *CheckerState) XXX_Unmarshal(b []byte) error

+ type ClusterInfo struct

+ DNShards []metadata.DNShardRecord

+ LogShards []metadata.LogShardRecord

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterInfo) Descriptor() ([]byte, []int)

+ func (*ClusterInfo) ProtoMessage()

+ func (m *ClusterInfo) GetDNShards() []metadata.DNShardRecord

+ func (m *ClusterInfo) GetLogShards() []metadata.LogShardRecord

+ func (m *ClusterInfo) Marshal() (dAtA []byte, err error)

+ func (m *ClusterInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClusterInfo) Reset()

+ func (m *ClusterInfo) Size() (n int)

+ func (m *ClusterInfo) String() string

+ func (m *ClusterInfo) Unmarshal(dAtA []byte) error

+ func (m *ClusterInfo) XXX_DiscardUnknown()

+ func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterInfo) XXX_Merge(src proto.Message)

+ func (m *ClusterInfo) XXX_Size() int

+ func (m *ClusterInfo) XXX_Unmarshal(b []byte) error

+ type CommandBatch struct

+ Commands []ScheduleCommand

+ Term uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommandBatch) Descriptor() ([]byte, []int)

+ func (*CommandBatch) ProtoMessage()

+ func (m *CommandBatch) GetCommands() []ScheduleCommand

+ func (m *CommandBatch) GetTerm() uint64

+ func (m *CommandBatch) Marshal() (dAtA []byte, err error)

+ func (m *CommandBatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *CommandBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CommandBatch) Reset()

+ func (m *CommandBatch) Size() (n int)

+ func (m *CommandBatch) String() string

+ func (m *CommandBatch) Unmarshal(dAtA []byte) error

+ func (m *CommandBatch) XXX_DiscardUnknown()

+ func (m *CommandBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommandBatch) XXX_Merge(src proto.Message)

+ func (m *CommandBatch) XXX_Size() int

+ func (m *CommandBatch) XXX_Unmarshal(b []byte) error

+ type ConfigChange struct

+ ChangeType ConfigChangeType

+ InitialMembers map[uint64]string

+ Replica Replica

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConfigChange) Descriptor() ([]byte, []int)

+ func (*ConfigChange) ProtoMessage()

+ func (m *ConfigChange) GetChangeType() ConfigChangeType

+ func (m *ConfigChange) GetInitialMembers() map[uint64]string

+ func (m *ConfigChange) GetReplica() Replica

+ func (m *ConfigChange) Marshal() (dAtA []byte, err error)

+ func (m *ConfigChange) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConfigChange) Reset()

+ func (m *ConfigChange) Size() (n int)

+ func (m *ConfigChange) String() string

+ func (m *ConfigChange) Unmarshal(dAtA []byte) error

+ func (m *ConfigChange) XXX_DiscardUnknown()

+ func (m *ConfigChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConfigChange) XXX_Merge(src proto.Message)

+ func (m *ConfigChange) XXX_Size() int

+ func (m *ConfigChange) XXX_Unmarshal(b []byte) error

+ type ConfigChangeType int32

+ const AddReplica

+ const RemoveReplica

+ const StartReplica

+ const StopReplica

+ func (ConfigChangeType) EnumDescriptor() ([]byte, []int)

+ func (x ConfigChangeType) String() string

+ type DNShardInfo struct

+ ReplicaID uint64

+ ShardID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DNShardInfo) Descriptor() ([]byte, []int)

+ func (*DNShardInfo) ProtoMessage()

+ func (m *DNShardInfo) GetReplicaID() uint64

+ func (m *DNShardInfo) GetShardID() uint64

+ func (m *DNShardInfo) Marshal() (dAtA []byte, err error)

+ func (m *DNShardInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNShardInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNShardInfo) Reset()

+ func (m *DNShardInfo) Size() (n int)

+ func (m *DNShardInfo) String() string

+ func (m *DNShardInfo) Unmarshal(dAtA []byte) error

+ func (m *DNShardInfo) XXX_DiscardUnknown()

+ func (m *DNShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNShardInfo) XXX_Merge(src proto.Message)

+ func (m *DNShardInfo) XXX_Size() int

+ func (m *DNShardInfo) XXX_Unmarshal(b []byte) error

+ type DNState struct

+ Stores map[string]DNStoreInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewDNState() DNState

+ func (*DNState) Descriptor() ([]byte, []int)

+ func (*DNState) ProtoMessage()

+ func (m *DNState) GetStores() map[string]DNStoreInfo

+ func (m *DNState) Marshal() (dAtA []byte, err error)

+ func (m *DNState) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNState) Reset()

+ func (m *DNState) Size() (n int)

+ func (m *DNState) String() string

+ func (m *DNState) Unmarshal(dAtA []byte) error

+ func (m *DNState) XXX_DiscardUnknown()

+ func (m *DNState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNState) XXX_Merge(src proto.Message)

+ func (m *DNState) XXX_Size() int

+ func (m *DNState) XXX_Unmarshal(b []byte) error

+ func (s *DNState) Update(hb DNStoreHeartbeat, tick uint64)

+ type DNStoreHeartbeat struct

+ Shards []DNShardInfo

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DNStoreHeartbeat) Descriptor() ([]byte, []int)

+ func (*DNStoreHeartbeat) ProtoMessage()

+ func (m *DNStoreHeartbeat) GetShards() []DNShardInfo

+ func (m *DNStoreHeartbeat) GetUUID() string

+ func (m *DNStoreHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *DNStoreHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNStoreHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNStoreHeartbeat) Reset()

+ func (m *DNStoreHeartbeat) Size() (n int)

+ func (m *DNStoreHeartbeat) String() string

+ func (m *DNStoreHeartbeat) Unmarshal(dAtA []byte) error

+ func (m *DNStoreHeartbeat) XXX_DiscardUnknown()

+ func (m *DNStoreHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNStoreHeartbeat) XXX_Merge(src proto.Message)

+ func (m *DNStoreHeartbeat) XXX_Size() int

+ func (m *DNStoreHeartbeat) XXX_Unmarshal(b []byte) error

+ type DNStoreInfo struct

+ Shards []DNShardInfo

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DNStoreInfo) Descriptor() ([]byte, []int)

+ func (*DNStoreInfo) ProtoMessage()

+ func (m *DNStoreInfo) GetShards() []DNShardInfo

+ func (m *DNStoreInfo) GetTick() uint64

+ func (m *DNStoreInfo) Marshal() (dAtA []byte, err error)

+ func (m *DNStoreInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *DNStoreInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DNStoreInfo) Reset()

+ func (m *DNStoreInfo) Size() (n int)

+ func (m *DNStoreInfo) String() string

+ func (m *DNStoreInfo) Unmarshal(dAtA []byte) error

+ func (m *DNStoreInfo) XXX_DiscardUnknown()

+ func (m *DNStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DNStoreInfo) XXX_Merge(src proto.Message)

+ func (m *DNStoreInfo) XXX_Size() int

+ func (m *DNStoreInfo) XXX_Unmarshal(b []byte) error

+ type ErrorCode int32

+ const Canceled

+ const InvalidPayload

+ const InvalidPayloadSize

+ const InvalidShard

+ const InvalidTimeout

+ const LsnAlreadyTruncated

+ const NoError

+ const NotLeaseHolder

+ const OtherSystemError

+ const OutOfRange

+ const Rejected

+ const ShardNotReady

+ const SystemClosed

+ const Timeout

+ func (ErrorCode) EnumDescriptor() ([]byte, []int)

+ func (x ErrorCode) String() string

+ type HAKeeperRSMState struct

+ CNState CNState

+ ClusterInfo ClusterInfo

+ DNState DNState

+ LogShards map[string]uint64

+ LogState LogState

+ NextID uint64

+ ScheduleCommands map[string]CommandBatch

+ State HAKeeperState

+ Term uint64

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewRSMState() HAKeeperRSMState

+ func (*HAKeeperRSMState) Descriptor() ([]byte, []int)

+ func (*HAKeeperRSMState) ProtoMessage()

+ func (m *HAKeeperRSMState) GetCNState() CNState

+ func (m *HAKeeperRSMState) GetClusterInfo() ClusterInfo

+ func (m *HAKeeperRSMState) GetDNState() DNState

+ func (m *HAKeeperRSMState) GetLogShards() map[string]uint64

+ func (m *HAKeeperRSMState) GetLogState() LogState

+ func (m *HAKeeperRSMState) GetNextID() uint64

+ func (m *HAKeeperRSMState) GetScheduleCommands() map[string]CommandBatch

+ func (m *HAKeeperRSMState) GetState() HAKeeperState

+ func (m *HAKeeperRSMState) GetTerm() uint64

+ func (m *HAKeeperRSMState) GetTick() uint64

+ func (m *HAKeeperRSMState) Marshal() (dAtA []byte, err error)

+ func (m *HAKeeperRSMState) MarshalTo(dAtA []byte) (int, error)

+ func (m *HAKeeperRSMState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HAKeeperRSMState) Reset()

+ func (m *HAKeeperRSMState) Size() (n int)

+ func (m *HAKeeperRSMState) String() string

+ func (m *HAKeeperRSMState) Unmarshal(dAtA []byte) error

+ func (m *HAKeeperRSMState) XXX_DiscardUnknown()

+ func (m *HAKeeperRSMState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HAKeeperRSMState) XXX_Merge(src proto.Message)

+ func (m *HAKeeperRSMState) XXX_Size() int

+ func (m *HAKeeperRSMState) XXX_Unmarshal(b []byte) error

+ type HAKeeperState int32

+ const HAKeeperBootstrapCommandsReceived

+ const HAKeeperBootstrapFailed

+ const HAKeeperBootstrapping

+ const HAKeeperCreated

+ const HAKeeperRunning

+ func (HAKeeperState) EnumDescriptor() ([]byte, []int)

+ func (x HAKeeperState) String() string

+ type HAKeeperUpdateType int32

+ const CNHeartbeatUpdate

+ const DNHeartbeatUpdate

+ const GetIDUpdate

+ const InitialClusterUpdate

+ const LogHeartbeatUpdate

+ const ScheduleCommandUpdate

+ const SetStateUpdate

+ const TickUpdate

+ func (HAKeeperUpdateType) EnumDescriptor() ([]byte, []int)

+ func (x HAKeeperUpdateType) String() string

+ type InitialClusterRequest struct

+ NumOfDNShards uint64

+ NumOfLogReplicas uint64

+ NumOfLogShards uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InitialClusterRequest) Descriptor() ([]byte, []int)

+ func (*InitialClusterRequest) ProtoMessage()

+ func (m *InitialClusterRequest) GetNumOfDNShards() uint64

+ func (m *InitialClusterRequest) GetNumOfLogReplicas() uint64

+ func (m *InitialClusterRequest) GetNumOfLogShards() uint64

+ func (m *InitialClusterRequest) Marshal() (dAtA []byte, err error)

+ func (m *InitialClusterRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InitialClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *InitialClusterRequest) Reset()

+ func (m *InitialClusterRequest) Size() (n int)

+ func (m *InitialClusterRequest) String() string

+ func (m *InitialClusterRequest) Unmarshal(dAtA []byte) error

+ func (m *InitialClusterRequest) XXX_DiscardUnknown()

+ func (m *InitialClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InitialClusterRequest) XXX_Merge(src proto.Message)

+ func (m *InitialClusterRequest) XXX_Size() int

+ func (m *InitialClusterRequest) XXX_Unmarshal(b []byte) error

+ type LogRecord struct

+ Data []byte

+ Lsn uint64

+ Type RecordType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogRecord) Descriptor() ([]byte, []int)

+ func (*LogRecord) ProtoMessage()

+ func (m *LogRecord) GetData() []byte

+ func (m *LogRecord) GetLsn() uint64

+ func (m *LogRecord) GetType() RecordType

+ func (m *LogRecord) Marshal() (dAtA []byte, err error)

+ func (m *LogRecord) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogRecord) Payload() []byte

+ func (m *LogRecord) Reset()

+ func (m *LogRecord) ResizePayload(length int)

+ func (m *LogRecord) Size() (n int)

+ func (m *LogRecord) String() string

+ func (m *LogRecord) Unmarshal(dAtA []byte) error

+ func (m *LogRecord) XXX_DiscardUnknown()

+ func (m *LogRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogRecord) XXX_Merge(src proto.Message)

+ func (m *LogRecord) XXX_Size() int

+ func (m *LogRecord) XXX_Unmarshal(b []byte) error

+ type LogRecordResponse struct

+ Records []LogRecord

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogRecordResponse) Descriptor() ([]byte, []int)

+ func (*LogRecordResponse) ProtoMessage()

+ func (m *LogRecordResponse) GetRecords() []LogRecord

+ func (m *LogRecordResponse) Marshal() (dAtA []byte, err error)

+ func (m *LogRecordResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogRecordResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogRecordResponse) Reset()

+ func (m *LogRecordResponse) Size() (n int)

+ func (m *LogRecordResponse) String() string

+ func (m *LogRecordResponse) Unmarshal(dAtA []byte) error

+ func (m *LogRecordResponse) XXX_DiscardUnknown()

+ func (m *LogRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogRecordResponse) XXX_Merge(src proto.Message)

+ func (m *LogRecordResponse) XXX_Size() int

+ func (m *LogRecordResponse) XXX_Unmarshal(b []byte) error

+ type LogReplicaInfo struct

+ ReplicaID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogReplicaInfo) Descriptor() ([]byte, []int)

+ func (*LogReplicaInfo) ProtoMessage()

+ func (m *LogReplicaInfo) GetReplicaID() uint64

+ func (m *LogReplicaInfo) Marshal() (dAtA []byte, err error)

+ func (m *LogReplicaInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogReplicaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogReplicaInfo) Reset()

+ func (m *LogReplicaInfo) Size() (n int)

+ func (m *LogReplicaInfo) String() string

+ func (m *LogReplicaInfo) Unmarshal(dAtA []byte) error

+ func (m *LogReplicaInfo) XXX_DiscardUnknown()

+ func (m *LogReplicaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogReplicaInfo) XXX_Merge(src proto.Message)

+ func (m *LogReplicaInfo) XXX_Size() int

+ func (m *LogReplicaInfo) XXX_Unmarshal(b []byte) error

+ type LogRequest struct

+ DNID uint64

+ DNShardID uint64

+ Lsn uint64

+ MaxSize uint64

+ Name string

+ ShardID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogRequest) Descriptor() ([]byte, []int)

+ func (*LogRequest) ProtoMessage()

+ func (m *LogRequest) GetDNID() uint64

+ func (m *LogRequest) GetDNShardID() uint64

+ func (m *LogRequest) GetLsn() uint64

+ func (m *LogRequest) GetMaxSize() uint64

+ func (m *LogRequest) GetName() string

+ func (m *LogRequest) GetShardID() uint64

+ func (m *LogRequest) Marshal() (dAtA []byte, err error)

+ func (m *LogRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogRequest) Reset()

+ func (m *LogRequest) Size() (n int)

+ func (m *LogRequest) String() string

+ func (m *LogRequest) Unmarshal(dAtA []byte) error

+ func (m *LogRequest) XXX_DiscardUnknown()

+ func (m *LogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogRequest) XXX_Merge(src proto.Message)

+ func (m *LogRequest) XXX_Size() int

+ func (m *LogRequest) XXX_Unmarshal(b []byte) error

+ type LogResponse struct

+ LastLsn uint64

+ Lsn uint64

+ ShardID uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogResponse) Descriptor() ([]byte, []int)

+ func (*LogResponse) ProtoMessage()

+ func (m *LogResponse) GetLastLsn() uint64

+ func (m *LogResponse) GetLsn() uint64

+ func (m *LogResponse) GetShardID() uint64

+ func (m *LogResponse) Marshal() (dAtA []byte, err error)

+ func (m *LogResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogResponse) Reset()

+ func (m *LogResponse) Size() (n int)

+ func (m *LogResponse) String() string

+ func (m *LogResponse) Unmarshal(dAtA []byte) error

+ func (m *LogResponse) XXX_DiscardUnknown()

+ func (m *LogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogResponse) XXX_Merge(src proto.Message)

+ func (m *LogResponse) XXX_Size() int

+ func (m *LogResponse) XXX_Unmarshal(b []byte) error

+ type LogShardInfo struct

+ Epoch uint64

+ LeaderID uint64

+ Replicas map[uint64]string

+ ShardID uint64

+ Term uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogShardInfo) Descriptor() ([]byte, []int)

+ func (*LogShardInfo) ProtoMessage()

+ func (m *LogShardInfo) GetEpoch() uint64

+ func (m *LogShardInfo) GetLeaderID() uint64

+ func (m *LogShardInfo) GetReplicas() map[uint64]string

+ func (m *LogShardInfo) GetShardID() uint64

+ func (m *LogShardInfo) GetTerm() uint64

+ func (m *LogShardInfo) Marshal() (dAtA []byte, err error)

+ func (m *LogShardInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogShardInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogShardInfo) Reset()

+ func (m *LogShardInfo) Size() (n int)

+ func (m *LogShardInfo) String() string

+ func (m *LogShardInfo) Unmarshal(dAtA []byte) error

+ func (m *LogShardInfo) XXX_DiscardUnknown()

+ func (m *LogShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogShardInfo) XXX_Merge(src proto.Message)

+ func (m *LogShardInfo) XXX_Size() int

+ func (m *LogShardInfo) XXX_Unmarshal(b []byte) error

+ type LogState struct

+ Shards map[uint64]LogShardInfo

+ Stores map[string]LogStoreInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewLogState() LogState

+ func (*LogState) Descriptor() ([]byte, []int)

+ func (*LogState) ProtoMessage()

+ func (m *LogState) GetShards() map[uint64]LogShardInfo

+ func (m *LogState) GetStores() map[string]LogStoreInfo

+ func (m *LogState) Marshal() (dAtA []byte, err error)

+ func (m *LogState) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogState) Reset()

+ func (m *LogState) Size() (n int)

+ func (m *LogState) String() string

+ func (m *LogState) Unmarshal(dAtA []byte) error

+ func (m *LogState) XXX_DiscardUnknown()

+ func (m *LogState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogState) XXX_Merge(src proto.Message)

+ func (m *LogState) XXX_Size() int

+ func (m *LogState) XXX_Unmarshal(b []byte) error

+ func (s *LogState) Update(hb LogStoreHeartbeat, tick uint64)

+ type LogStoreHeartbeat struct

+ GossipAddress string

+ RaftAddress string

+ Replicas []LogReplicaInfo

+ ServiceAddress string

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStoreHeartbeat) Descriptor() ([]byte, []int)

+ func (*LogStoreHeartbeat) ProtoMessage()

+ func (m *LogStoreHeartbeat) GetGossipAddress() string

+ func (m *LogStoreHeartbeat) GetRaftAddress() string

+ func (m *LogStoreHeartbeat) GetReplicas() []LogReplicaInfo

+ func (m *LogStoreHeartbeat) GetServiceAddress() string

+ func (m *LogStoreHeartbeat) GetUUID() string

+ func (m *LogStoreHeartbeat) Marshal() (dAtA []byte, err error)

+ func (m *LogStoreHeartbeat) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogStoreHeartbeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogStoreHeartbeat) Reset()

+ func (m *LogStoreHeartbeat) Size() (n int)

+ func (m *LogStoreHeartbeat) String() string

+ func (m *LogStoreHeartbeat) Unmarshal(dAtA []byte) error

+ func (m *LogStoreHeartbeat) XXX_DiscardUnknown()

+ func (m *LogStoreHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogStoreHeartbeat) XXX_Merge(src proto.Message)

+ func (m *LogStoreHeartbeat) XXX_Size() int

+ func (m *LogStoreHeartbeat) XXX_Unmarshal(b []byte) error

+ type LogStoreInfo struct

+ GossipAddress string

+ RaftAddress string

+ Replicas []LogReplicaInfo

+ ServiceAddress string

+ Tick uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStoreInfo) Descriptor() ([]byte, []int)

+ func (*LogStoreInfo) ProtoMessage()

+ func (m *LogStoreInfo) GetGossipAddress() string

+ func (m *LogStoreInfo) GetRaftAddress() string

+ func (m *LogStoreInfo) GetReplicas() []LogReplicaInfo

+ func (m *LogStoreInfo) GetServiceAddress() string

+ func (m *LogStoreInfo) GetTick() uint64

+ func (m *LogStoreInfo) Marshal() (dAtA []byte, err error)

+ func (m *LogStoreInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogStoreInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogStoreInfo) Reset()

+ func (m *LogStoreInfo) Size() (n int)

+ func (m *LogStoreInfo) String() string

+ func (m *LogStoreInfo) Unmarshal(dAtA []byte) error

+ func (m *LogStoreInfo) XXX_DiscardUnknown()

+ func (m *LogStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LogStoreInfo) XXX_Merge(src proto.Message)

+ func (m *LogStoreInfo) XXX_Size() int

+ func (m *LogStoreInfo) XXX_Unmarshal(b []byte) error

+ type MethodType int32

+ const APPEND

+ const CN_HEARTBEAT

+ const CONNECT

+ const CONNECT_RO

+ const DN_HEARTBEAT

+ const GET_TRUNCATE

+ const LOG_HEARTBEAT

+ const READ

+ const TRUNCATE

+ const TSO_UPDATE

+ func (MethodType) EnumDescriptor() ([]byte, []int)

+ func (x MethodType) String() string

+ type RSMState struct

+ Index uint64

+ LeaseHistory map[uint64]uint64

+ LeaseHolderID uint64

+ TruncatedLsn uint64

+ Tso uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RSMState) Descriptor() ([]byte, []int)

+ func (*RSMState) ProtoMessage()

+ func (m *RSMState) GetIndex() uint64

+ func (m *RSMState) GetLeaseHistory() map[uint64]uint64

+ func (m *RSMState) GetLeaseHolderID() uint64

+ func (m *RSMState) GetTruncatedLsn() uint64

+ func (m *RSMState) GetTso() uint64

+ func (m *RSMState) Marshal() (dAtA []byte, err error)

+ func (m *RSMState) MarshalTo(dAtA []byte) (int, error)

+ func (m *RSMState) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RSMState) Reset()

+ func (m *RSMState) Size() (n int)

+ func (m *RSMState) String() string

+ func (m *RSMState) Unmarshal(dAtA []byte) error

+ func (m *RSMState) XXX_DiscardUnknown()

+ func (m *RSMState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RSMState) XXX_Merge(src proto.Message)

+ func (m *RSMState) XXX_Size() int

+ func (m *RSMState) XXX_Unmarshal(b []byte) error

+ type RecordType int32

+ const Internal

+ const LeaseRejected

+ const LeaseUpdate

+ const UserRecord

+ func (RecordType) EnumDescriptor() ([]byte, []int)

+ func (x RecordType) String() string

+ type Replica struct

+ Epoch uint64

+ ReplicaID uint64

+ ShardID uint64

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Replica) Descriptor() ([]byte, []int)

+ func (*Replica) ProtoMessage()

+ func (m *Replica) GetEpoch() uint64

+ func (m *Replica) GetReplicaID() uint64

+ func (m *Replica) GetShardID() uint64

+ func (m *Replica) GetUUID() string

+ func (m *Replica) Marshal() (dAtA []byte, err error)

+ func (m *Replica) MarshalTo(dAtA []byte) (int, error)

+ func (m *Replica) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Replica) Reset()

+ func (m *Replica) Size() (n int)

+ func (m *Replica) String() string

+ func (m *Replica) Unmarshal(dAtA []byte) error

+ func (m *Replica) XXX_DiscardUnknown()

+ func (m *Replica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Replica) XXX_Merge(src proto.Message)

+ func (m *Replica) XXX_Size() int

+ func (m *Replica) XXX_Unmarshal(b []byte) error

+ type Request struct

+ CNHeartbeat CNStoreHeartbeat

+ DNHeartbeat DNStoreHeartbeat

+ LogHeartbeat LogStoreHeartbeat

+ LogRequest LogRequest

+ Method MethodType

+ RequestID uint64

+ Timeout int64

+ TsoRequest TsoRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Request) Descriptor() ([]byte, []int)

+ func (*Request) ProtoMessage()

+ func (m *Request) GetCNHeartbeat() CNStoreHeartbeat

+ func (m *Request) GetDNHeartbeat() DNStoreHeartbeat

+ func (m *Request) GetLogHeartbeat() LogStoreHeartbeat

+ func (m *Request) GetLogRequest() LogRequest

+ func (m *Request) GetMethod() MethodType

+ func (m *Request) GetRequestID() uint64

+ func (m *Request) GetTimeout() int64

+ func (m *Request) GetTsoRequest() TsoRequest

+ func (m *Request) Marshal() (dAtA []byte, err error)

+ func (m *Request) MarshalTo(dAtA []byte) (int, error)

+ func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Request) Reset()

+ func (m *Request) Size() (n int)

+ func (m *Request) String() string

+ func (m *Request) Unmarshal(dAtA []byte) error

+ func (m *Request) XXX_DiscardUnknown()

+ func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Request) XXX_Merge(src proto.Message)

+ func (m *Request) XXX_Size() int

+ func (m *Request) XXX_Unmarshal(b []byte) error

+ type Response struct

+ CommandBatch CommandBatch

+ ErrorCode ErrorCode

+ ErrorMessage string

+ LogResponse LogResponse

+ Method MethodType

+ RequestID uint64

+ TsoResponse TsoResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Response) Descriptor() ([]byte, []int)

+ func (*Response) ProtoMessage()

+ func (m *Response) GetCommandBatch() CommandBatch

+ func (m *Response) GetErrorCode() ErrorCode

+ func (m *Response) GetErrorMessage() string

+ func (m *Response) GetLogResponse() LogResponse

+ func (m *Response) GetMethod() MethodType

+ func (m *Response) GetRequestID() uint64

+ func (m *Response) GetTsoResponse() TsoResponse

+ func (m *Response) Marshal() (dAtA []byte, err error)

+ func (m *Response) MarshalTo(dAtA []byte) (int, error)

+ func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Response) Reset()

+ func (m *Response) Size() (n int)

+ func (m *Response) String() string

+ func (m *Response) Unmarshal(dAtA []byte) error

+ func (m *Response) XXX_DiscardUnknown()

+ func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Response) XXX_Merge(src proto.Message)

+ func (m *Response) XXX_Size() int

+ func (m *Response) XXX_Unmarshal(b []byte) error

+ type ScheduleCommand struct

+ Bootstrapping bool

+ ConfigChange *ConfigChange

+ ServiceType ServiceType

+ ShutdownStore *ShutdownStore

+ UUID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ScheduleCommand) Descriptor() ([]byte, []int)

+ func (*ScheduleCommand) ProtoMessage()

+ func (m *ScheduleCommand) GetBootstrapping() bool

+ func (m *ScheduleCommand) GetConfigChange() *ConfigChange

+ func (m *ScheduleCommand) GetServiceType() ServiceType

+ func (m *ScheduleCommand) GetShutdownStore() *ShutdownStore

+ func (m *ScheduleCommand) GetUUID() string

+ func (m *ScheduleCommand) Marshal() (dAtA []byte, err error)

+ func (m *ScheduleCommand) MarshalTo(dAtA []byte) (int, error)

+ func (m *ScheduleCommand) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ScheduleCommand) Reset()

+ func (m *ScheduleCommand) Size() (n int)

+ func (m *ScheduleCommand) String() string

+ func (m *ScheduleCommand) Unmarshal(dAtA []byte) error

+ func (m *ScheduleCommand) XXX_DiscardUnknown()

+ func (m *ScheduleCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ScheduleCommand) XXX_Merge(src proto.Message)

+ func (m *ScheduleCommand) XXX_Size() int

+ func (m *ScheduleCommand) XXX_Unmarshal(b []byte) error

+ type ServiceType int32

+ const DnService

+ const LogService

+ func (ServiceType) EnumDescriptor() ([]byte, []int)

+ func (x ServiceType) String() string

+ type ShutdownStore struct

+ StoreID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ShutdownStore) Descriptor() ([]byte, []int)

+ func (*ShutdownStore) ProtoMessage()

+ func (m *ShutdownStore) GetStoreID() string

+ func (m *ShutdownStore) Marshal() (dAtA []byte, err error)

+ func (m *ShutdownStore) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShutdownStore) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShutdownStore) Reset()

+ func (m *ShutdownStore) Size() (n int)

+ func (m *ShutdownStore) String() string

+ func (m *ShutdownStore) Unmarshal(dAtA []byte) error

+ func (m *ShutdownStore) XXX_DiscardUnknown()

+ func (m *ShutdownStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShutdownStore) XXX_Merge(src proto.Message)

+ func (m *ShutdownStore) XXX_Size() int

+ func (m *ShutdownStore) XXX_Unmarshal(b []byte) error

+ type TsoRequest struct

+ Count uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TsoRequest) Descriptor() ([]byte, []int)

+ func (*TsoRequest) ProtoMessage()

+ func (m *TsoRequest) GetCount() uint64

+ func (m *TsoRequest) Marshal() (dAtA []byte, err error)

+ func (m *TsoRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *TsoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TsoRequest) Reset()

+ func (m *TsoRequest) Size() (n int)

+ func (m *TsoRequest) String() string

+ func (m *TsoRequest) Unmarshal(dAtA []byte) error

+ func (m *TsoRequest) XXX_DiscardUnknown()

+ func (m *TsoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TsoRequest) XXX_Merge(src proto.Message)

+ func (m *TsoRequest) XXX_Size() int

+ func (m *TsoRequest) XXX_Unmarshal(b []byte) error

+ type TsoResponse struct

+ Value uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TsoResponse) Descriptor() ([]byte, []int)

+ func (*TsoResponse) ProtoMessage()

+ func (m *TsoResponse) GetValue() uint64

+ func (m *TsoResponse) Marshal() (dAtA []byte, err error)

+ func (m *TsoResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *TsoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TsoResponse) Reset()

+ func (m *TsoResponse) Size() (n int)

+ func (m *TsoResponse) String() string

+ func (m *TsoResponse) Unmarshal(dAtA []byte) error

+ func (m *TsoResponse) XXX_DiscardUnknown()

+ func (m *TsoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TsoResponse) XXX_Merge(src proto.Message)

+ func (m *TsoResponse) XXX_Size() int

+ func (m *TsoResponse) XXX_Unmarshal(b []byte) error

+ type UpdateType int32

+ const LeaseHolderIDUpdate

+ const TSOUpdate

+ const TruncateLSNUpdate

+ const UserEntryUpdate

+ func (UpdateType) EnumDescriptor() ([]byte, []int)

+ func (x UpdateType) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL