logservice

package
v1.0.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	// NoLeader is the replica ID of the leader node.
	NoLeader uint64 = 0
	// HeaderSize is the size of the header for each logservice and
	// hakeeper command.
	HeaderSize = 4
)

Variables

View Source 
var (
	ErrInvalidLengthLogservice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogservice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogservice = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CNLabelOp_name = map[int32]string{
	0: "SetLabel",
	1: "DeleteLabel",
}
View Source 
var CNLabelOp_value = map[string]int32{
	"SetLabel":    0,
	"DeleteLabel": 1,
}
View Source 
var ConfigChangeType_name = map[int32]string{
	0: "AddReplica",
	1: "RemoveReplica",
	2: "StartReplica",
	3: "StopReplica",
	4: "KillZombie",
}
View Source 
var ConfigChangeType_value = map[string]int32{
	"AddReplica":    0,
	"RemoveReplica": 1,
	"StartReplica":  2,
	"StopReplica":   3,
	"KillZombie":    4,
}
View Source 
var HAKeeperState_name = map[int32]string{
	0: "HAKeeperCreated",
	1: "HAKeeperBootstrapping",
	2: "HAKeeperBootstrapCommandsReceived",
	3: "HAKeeperBootstrapFailed",
	4: "HAKeeperRunning",
}
View Source 
var HAKeeperState_value = map[string]int32{
	"HAKeeperCreated":                   0,
	"HAKeeperBootstrapping":             1,
	"HAKeeperBootstrapCommandsReceived": 2,
	"HAKeeperBootstrapFailed":           3,
	"HAKeeperRunning":                   4,
}
View Source 
var HAKeeperUpdateType_name = map[int32]string{
	0:  "TickUpdate",
	1:  "CNHeartbeatUpdate",
	2:  "TNHeartbeatUpdate",
	3:  "LogHeartbeatUpdate",
	4:  "GetIDUpdate",
	5:  "ScheduleCommandUpdate",
	6:  "SetStateUpdate",
	7:  "InitialClusterUpdate",
	8:  "SetTaskSchedulerStateUpdate",
	9:  "SetTaskTableUserUpdate",
	10: "UpdateCNLabel",
	11: "UpdateCNWorkState",
	12: "PatchCNStore",
	13: "RemoveCNStore",
}
View Source 
var HAKeeperUpdateType_value = map[string]int32{
	"TickUpdate":                  0,
	"CNHeartbeatUpdate":           1,
	"TNHeartbeatUpdate":           2,
	"LogHeartbeatUpdate":          3,
	"GetIDUpdate":                 4,
	"ScheduleCommandUpdate":       5,
	"SetStateUpdate":              6,
	"InitialClusterUpdate":        7,
	"SetTaskSchedulerStateUpdate": 8,
	"SetTaskTableUserUpdate":      9,
	"UpdateCNLabel":               10,
	"UpdateCNWorkState":           11,
	"PatchCNStore":                12,
	"RemoveCNStore":               13,
}
View Source 
var MethodType_name = map[int32]string{
	0:  "TSO_UPDATE",
	1:  "APPEND",
	2:  "READ",
	3:  "TRUNCATE",
	4:  "GET_TRUNCATE",
	5:  "CONNECT",
	6:  "CONNECT_RO",
	7:  "LOG_HEARTBEAT",
	8:  "CN_HEARTBEAT",
	9:  "TN_HEARTBEAT",
	10: "CHECK_HAKEEPER",
	11: "GET_CLUSTER_DETAILS",
	12: "GET_SHARD_INFO",
	13: "CN_ALLOCATE_ID",
	14: "GET_CLUSTER_STATE",
	15: "UPDATE_CN_LABEL",
	16: "UPDATE_CN_WORK_STATE",
	17: "PATCH_CN_STORE",
	18: "DELETE_CN_STORE",
}
View Source 
var MethodType_value = map[string]int32{
	"TSO_UPDATE":           0,
	"APPEND":               1,
	"READ":                 2,
	"TRUNCATE":             3,
	"GET_TRUNCATE":         4,
	"CONNECT":              5,
	"CONNECT_RO":           6,
	"LOG_HEARTBEAT":        7,
	"CN_HEARTBEAT":         8,
	"TN_HEARTBEAT":         9,
	"CHECK_HAKEEPER":       10,
	"GET_CLUSTER_DETAILS":  11,
	"GET_SHARD_INFO":       12,
	"CN_ALLOCATE_ID":       13,
	"GET_CLUSTER_STATE":    14,
	"UPDATE_CN_LABEL":      15,
	"UPDATE_CN_WORK_STATE": 16,
	"PATCH_CN_STORE":       17,
	"DELETE_CN_STORE":      18,
}
View Source 
var NodeState_name = map[int32]string{
	0: "NormalState",
	1: "TimeoutState",
}
View Source 
var NodeState_value = map[string]int32{
	"NormalState":  0,
	"TimeoutState": 1,
}
View Source 
var RecordType_name = map[int32]string{
	0: "UserRecord",
	1: "Internal",
	2: "LeaseUpdate",
	3: "LeaseRejected",
}
View Source 
var RecordType_value = map[string]int32{
	"UserRecord":    0,
	"Internal":      1,
	"LeaseUpdate":   2,
	"LeaseRejected": 3,
}
View Source 
var ServiceType_name = map[int32]string{
	0: "LogService",
	1: "TNService",
	2: "CNService",
}
View Source 
var ServiceType_value = map[string]int32{
	"LogService": 0,
	"TNService":  1,
	"CNService":  2,
}
View Source 
var TaskSchedulerState_name = map[int32]string{
	0: "TaskSchedulerCreated",
	1: "TaskSchedulerRunning",
	2: "TaskSchedulerStopped",
}
View Source 
var TaskSchedulerState_value = map[string]int32{
	"TaskSchedulerCreated": 0,
	"TaskSchedulerRunning": 1,
	"TaskSchedulerStopped": 2,
}
View Source 
var UpdateType_name = map[int32]string{
	0: "LeaseHolderIDUpdate",
	1: "TruncateLSNUpdate",
	2: "UserEntryUpdate",
	3: "TSOUpdate",
}
View Source 
var UpdateType_value = map[string]int32{
	"LeaseHolderIDUpdate": 0,
	"TruncateLSNUpdate":   1,
	"UserEntryUpdate":     2,
	"TSOUpdate":           3,
}

Functions

This section is empty.

Types

type AllocateIDResponse added in v0.6.0 

type AllocateIDResponse struct {
	FirstID              uint64   `protobuf:"varint,1,opt,name=FirstID,proto3" json:"FirstID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllocateIDResponse) Descriptor added in v0.6.0 

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

func (*AllocateIDResponse) GetFirstID added in v0.6.0 

func (m *AllocateIDResponse) GetFirstID() uint64

func (*AllocateIDResponse) Marshal added in v0.6.0 

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

func (*AllocateIDResponse) MarshalTo added in v0.6.0 

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

func (*AllocateIDResponse) MarshalToSizedBuffer added in v0.6.0 

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

func (*AllocateIDResponse) ProtoMessage added in v0.6.0 

func (*AllocateIDResponse) ProtoMessage()

func (*AllocateIDResponse) Reset added in v0.6.0 

func (m *AllocateIDResponse) Reset()

func (*AllocateIDResponse) Size added in v0.6.0 

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

func (*AllocateIDResponse) String added in v0.6.0 

func (m *AllocateIDResponse) String() string

func (*AllocateIDResponse) Unmarshal added in v0.6.0 

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

func (*AllocateIDResponse) XXX_DiscardUnknown added in v0.6.0 

func (m *AllocateIDResponse) XXX_DiscardUnknown()

func (*AllocateIDResponse) XXX_Marshal added in v0.6.0 

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

func (*AllocateIDResponse) XXX_Merge added in v0.6.0 

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

func (*AllocateIDResponse) XXX_Size added in v0.6.0 

func (m *AllocateIDResponse) XXX_Size() int

func (*AllocateIDResponse) XXX_Unmarshal added in v0.6.0 

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

type BackupData added in v1.0.0 

type BackupData struct {
	// NextID is a shared, global ID.
	NextID uint64 `protobuf:"varint,1,opt,name=NextID,proto3" json:"NextID,omitempty"`
	// NextIDByKey is IDs isolated by keys.
	NextIDByKey          map[string]uint64 `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

BackupData is the information that needs to backup, including NextID and NextIDByKey in HAKeeperRSMState.

func (*BackupData) Descriptor added in v1.0.0 

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

func (*BackupData) GetNextID added in v1.0.0 

func (m *BackupData) GetNextID() uint64

func (*BackupData) GetNextIDByKey added in v1.0.0 

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

func (*BackupData) Marshal added in v1.0.0 

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

func (*BackupData) MarshalTo added in v1.0.0 

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

func (*BackupData) MarshalToSizedBuffer added in v1.0.0 

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

func (*BackupData) ProtoMessage added in v1.0.0 

func (*BackupData) ProtoMessage()

func (*BackupData) Reset added in v1.0.0 

func (m *BackupData) Reset()

func (*BackupData) Size added in v1.0.0 

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

func (*BackupData) String added in v1.0.0 

func (m *BackupData) String() string

func (*BackupData) Unmarshal added in v1.0.0 

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

func (*BackupData) XXX_DiscardUnknown added in v1.0.0 

func (m *BackupData) XXX_DiscardUnknown()

func (*BackupData) XXX_Marshal added in v1.0.0 

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

func (*BackupData) XXX_Merge added in v1.0.0 

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

func (*BackupData) XXX_Size added in v1.0.0 

func (m *BackupData) XXX_Size() int

func (*BackupData) XXX_Unmarshal added in v1.0.0 

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

type CNAllocateID added in v0.6.0 

type CNAllocateID struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Batch                uint64   `protobuf:"varint,2,opt,name=Batch,proto3" json:"Batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CNAllocateID is the periodic message sent tp the HAKeeper by CN stores.

func (*CNAllocateID) Descriptor added in v0.6.0 

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

func (*CNAllocateID) GetBatch added in v0.6.0 

func (m *CNAllocateID) GetBatch() uint64

func (*CNAllocateID) GetKey added in v0.8.0 

func (m *CNAllocateID) GetKey() string

func (*CNAllocateID) Marshal added in v0.6.0 

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

func (*CNAllocateID) MarshalTo added in v0.6.0 

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

func (*CNAllocateID) MarshalToSizedBuffer added in v0.6.0 

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

func (*CNAllocateID) ProtoMessage added in v0.6.0 

func (*CNAllocateID) ProtoMessage()

func (*CNAllocateID) Reset added in v0.6.0 

func (m *CNAllocateID) Reset()

func (*CNAllocateID) Size added in v0.6.0 

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

func (*CNAllocateID) String added in v0.6.0 

func (m *CNAllocateID) String() string

func (*CNAllocateID) Unmarshal added in v0.6.0 

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

func (*CNAllocateID) XXX_DiscardUnknown added in v0.6.0 

func (m *CNAllocateID) XXX_DiscardUnknown()

func (*CNAllocateID) XXX_Marshal added in v0.6.0 

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

func (*CNAllocateID) XXX_Merge added in v0.6.0 

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

func (*CNAllocateID) XXX_Size added in v0.6.0 

func (m *CNAllocateID) XXX_Size() int

func (*CNAllocateID) XXX_Unmarshal added in v0.6.0 

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

type CNLabelOp added in v0.8.0 

type CNLabelOp int32
const (
	SetLabel    CNLabelOp = 0
	DeleteLabel CNLabelOp = 1
)

func (CNLabelOp) EnumDescriptor added in v0.8.0 

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

func (CNLabelOp) String added in v0.8.0 

func (x CNLabelOp) String() string

type CNState 

type CNState struct {
	// Stores is keyed by CN store UUID.
	Stores               map[string]CNStoreInfo `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

CNState contains all CN details known to the HAKeeper.

func NewCNState 

func NewCNState() CNState

NewCNState creates a new CNState.

func (*CNState) Descriptor 

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

func (*CNState) GetStores 

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

func (*CNState) Marshal 

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

func (*CNState) MarshalTo 

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

func (*CNState) MarshalToSizedBuffer 

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

func (*CNState) PatchCNStore added in v1.0.0 

func (s *CNState) PatchCNStore(stateLabel CNStateLabel)

PatchCNStore updates work state and labels of CN store.

func (*CNState) ProtoMessage 

func (*CNState) ProtoMessage()

func (*CNState) Reset 

func (m *CNState) Reset()

func (*CNState) Size 

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

func (*CNState) String 

func (m *CNState) String() string

func (*CNState) Unmarshal 

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

func (*CNState) Update 

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

Update applies the incoming CNStoreHeartbeat into HAKeeper. Tick is the current tick of the HAKeeper which is used as the timestamp of the heartbeat.

func (*CNState) UpdateLabel added in v0.8.0 

func (s *CNState) UpdateLabel(label CNStoreLabel)

UpdateLabel updates labels of CN store.

func (*CNState) UpdateWorkState added in v1.0.0 

func (s *CNState) UpdateWorkState(state CNWorkState)

UpdateWorkState updates work state of CN store.

func (*CNState) XXX_DiscardUnknown 

func (m *CNState) XXX_DiscardUnknown()

func (*CNState) XXX_Marshal 

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

func (*CNState) XXX_Merge 

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

func (*CNState) XXX_Size 

func (m *CNState) XXX_Size() int

func (*CNState) XXX_Unmarshal 

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

type CNStateLabel added in v1.0.0 

type CNStateLabel struct {
	// UUID is the uuid of the CN store.
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// State is the CN work state.
	State metadata.WorkState `protobuf:"varint,2,opt,name=State,proto3,enum=metadata.WorkState" json:"State,omitempty"`
	// Labels is the labels of the CN store.
	Labels               map[string]metadata.LabelList `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CNStateLabel) Descriptor added in v1.0.0 

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

func (*CNStateLabel) GetLabels added in v1.0.0 

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

func (*CNStateLabel) GetState added in v1.0.0 

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

func (*CNStateLabel) GetUUID added in v1.0.0 

func (m *CNStateLabel) GetUUID() string

func (*CNStateLabel) Marshal added in v1.0.0 

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

func (*CNStateLabel) MarshalTo added in v1.0.0 

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

func (*CNStateLabel) MarshalToSizedBuffer added in v1.0.0 

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

func (*CNStateLabel) ProtoMessage added in v1.0.0 

func (*CNStateLabel) ProtoMessage()

func (*CNStateLabel) Reset added in v1.0.0 

func (m *CNStateLabel) Reset()

func (*CNStateLabel) Size added in v1.0.0 

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

func (*CNStateLabel) String added in v1.0.0 

func (m *CNStateLabel) String() string

func (*CNStateLabel) Unmarshal added in v1.0.0 

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

func (*CNStateLabel) XXX_DiscardUnknown added in v1.0.0 

func (m *CNStateLabel) XXX_DiscardUnknown()

func (*CNStateLabel) XXX_Marshal added in v1.0.0 

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

func (*CNStateLabel) XXX_Merge added in v1.0.0 

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

func (*CNStateLabel) XXX_Size added in v1.0.0 

func (m *CNStateLabel) XXX_Size() int

func (*CNStateLabel) XXX_Unmarshal added in v1.0.0 

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

type CNStore added in v0.6.0 

type CNStore struct {
	UUID                 string                        `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress       string                        `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	SQLAddress           string                        `protobuf:"bytes,3,opt,name=SQLAddress,proto3" json:"SQLAddress,omitempty"`
	LockServiceAddress   string                        `protobuf:"bytes,4,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string                        `protobuf:"bytes,5,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	Role                 metadata.CNRole               `protobuf:"varint,6,opt,name=Role,proto3,enum=metadata.CNRole" json:"Role,omitempty"`
	Tick                 uint64                        `protobuf:"varint,7,opt,name=Tick,proto3" json:"Tick,omitempty"`
	State                NodeState                     `protobuf:"varint,8,opt,name=State,proto3,enum=logservice.NodeState" json:"State,omitempty"`
	Labels               map[string]metadata.LabelList `` /* 143-byte string literal not displayed */
	WorkState            metadata.WorkState            `protobuf:"varint,10,opt,name=WorkState,proto3,enum=metadata.WorkState" json:"WorkState,omitempty"`
	QueryAddress         string                        `protobuf:"bytes,11,opt,name=QueryAddress,proto3" json:"QueryAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CNStore) Descriptor added in v0.6.0 

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

func (*CNStore) GetCtlAddress added in v0.8.0 

func (m *CNStore) GetCtlAddress() string

func (*CNStore) GetLabels added in v0.8.0 

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

func (*CNStore) GetLockServiceAddress added in v0.8.0 

func (m *CNStore) GetLockServiceAddress() string

func (*CNStore) GetQueryAddress added in v1.0.0 

func (m *CNStore) GetQueryAddress() string

func (*CNStore) GetRole added in v0.6.0 

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

func (*CNStore) GetSQLAddress added in v0.6.0 

func (m *CNStore) GetSQLAddress() string

func (*CNStore) GetServiceAddress added in v0.6.0 

func (m *CNStore) GetServiceAddress() string

func (*CNStore) GetState added in v0.6.0 

func (m *CNStore) GetState() NodeState

func (*CNStore) GetTick added in v0.6.0 

func (m *CNStore) GetTick() uint64

func (*CNStore) GetUUID added in v0.6.0 

func (m *CNStore) GetUUID() string

func (*CNStore) GetWorkState added in v1.0.0 

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

func (*CNStore) Marshal added in v0.6.0 

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

func (*CNStore) MarshalTo added in v0.6.0 

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

func (*CNStore) MarshalToSizedBuffer added in v0.6.0 

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

func (*CNStore) ProtoMessage added in v0.6.0 

func (*CNStore) ProtoMessage()

func (*CNStore) Reset added in v0.6.0 

func (m *CNStore) Reset()

func (*CNStore) Size added in v0.6.0 

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

func (*CNStore) String added in v0.6.0 

func (m *CNStore) String() string

func (*CNStore) Unmarshal added in v0.6.0 

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

func (*CNStore) XXX_DiscardUnknown added in v0.6.0 

func (m *CNStore) XXX_DiscardUnknown()

func (*CNStore) XXX_Marshal added in v0.6.0 

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

func (*CNStore) XXX_Merge added in v0.6.0 

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

func (*CNStore) XXX_Size added in v0.6.0 

func (m *CNStore) XXX_Size() int

func (*CNStore) XXX_Unmarshal added in v0.6.0 

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

type CNStoreHeartbeat 

type CNStoreHeartbeat struct {
	UUID                 string          `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress       string          `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	SQLAddress           string          `protobuf:"bytes,3,opt,name=SQLAddress,proto3" json:"SQLAddress,omitempty"`
	LockServiceAddress   string          `protobuf:"bytes,4,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string          `protobuf:"bytes,5,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	Role                 metadata.CNRole `protobuf:"varint,6,opt,name=Role,proto3,enum=metadata.CNRole" json:"Role,omitempty"`
	TaskServiceCreated   bool            `protobuf:"varint,7,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	QueryAddress         string          `protobuf:"bytes,8,opt,name=QueryAddress,proto3" json:"QueryAddress,omitempty"`
	InitWorkState        string          `protobuf:"bytes,9,opt,name=InitWorkState,proto3" json:"InitWorkState,omitempty"`
	GossipAddress        string          `protobuf:"bytes,10,opt,name=GossipAddress,proto3" json:"GossipAddress,omitempty"`
	GossipJoined         bool            `protobuf:"varint,11,opt,name=GossipJoined,proto3" json:"GossipJoined,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CNStoreHeartbeat is the periodic message sent tp the HAKeeper by CN stores.

func (*CNStoreHeartbeat) Descriptor 

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

func (*CNStoreHeartbeat) GetCtlAddress added in v0.8.0 

func (m *CNStoreHeartbeat) GetCtlAddress() string

func (*CNStoreHeartbeat) GetGossipAddress added in v1.0.0 

func (m *CNStoreHeartbeat) GetGossipAddress() string

func (*CNStoreHeartbeat) GetGossipJoined added in v1.0.0 

func (m *CNStoreHeartbeat) GetGossipJoined() bool

func (*CNStoreHeartbeat) GetInitWorkState added in v1.0.0 

func (m *CNStoreHeartbeat) GetInitWorkState() string

func (*CNStoreHeartbeat) GetLockServiceAddress added in v0.8.0 

func (m *CNStoreHeartbeat) GetLockServiceAddress() string

func (*CNStoreHeartbeat) GetQueryAddress added in v1.0.0 

func (m *CNStoreHeartbeat) GetQueryAddress() string

func (*CNStoreHeartbeat) GetRole added in v0.6.0 

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

func (*CNStoreHeartbeat) GetSQLAddress added in v0.6.0 

func (m *CNStoreHeartbeat) GetSQLAddress() string

func (*CNStoreHeartbeat) GetServiceAddress added in v0.5.1 

func (m *CNStoreHeartbeat) GetServiceAddress() string

func (*CNStoreHeartbeat) GetTaskServiceCreated added in v0.6.0 

func (m *CNStoreHeartbeat) GetTaskServiceCreated() bool

func (*CNStoreHeartbeat) GetUUID 

func (m *CNStoreHeartbeat) GetUUID() string

func (*CNStoreHeartbeat) Marshal 

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

func (*CNStoreHeartbeat) MarshalTo 

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

func (*CNStoreHeartbeat) MarshalToSizedBuffer 

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

func (*CNStoreHeartbeat) ProtoMessage 

func (*CNStoreHeartbeat) ProtoMessage()

func (*CNStoreHeartbeat) Reset 

func (m *CNStoreHeartbeat) Reset()

func (*CNStoreHeartbeat) Size 

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

func (*CNStoreHeartbeat) String 

func (m *CNStoreHeartbeat) String() string

func (*CNStoreHeartbeat) Unmarshal 

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

func (*CNStoreHeartbeat) XXX_DiscardUnknown 

func (m *CNStoreHeartbeat) XXX_DiscardUnknown()

func (*CNStoreHeartbeat) XXX_Marshal 

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

func (*CNStoreHeartbeat) XXX_Merge 

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

func (*CNStoreHeartbeat) XXX_Size 

func (m *CNStoreHeartbeat) XXX_Size() int

func (*CNStoreHeartbeat) XXX_Unmarshal 

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

type CNStoreInfo 

type CNStoreInfo struct {
	Tick                 uint64                        `protobuf:"varint,1,opt,name=Tick,proto3" json:"Tick,omitempty"`
	ServiceAddress       string                        `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	SQLAddress           string                        `protobuf:"bytes,3,opt,name=SQLAddress,proto3" json:"SQLAddress,omitempty"`
	LockServiceAddress   string                        `protobuf:"bytes,4,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string                        `protobuf:"bytes,5,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	Role                 metadata.CNRole               `protobuf:"varint,6,opt,name=Role,proto3,enum=metadata.CNRole" json:"Role,omitempty"`
	TaskServiceCreated   bool                          `protobuf:"varint,7,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	Labels               map[string]metadata.LabelList `` /* 143-byte string literal not displayed */
	WorkState            metadata.WorkState            `protobuf:"varint,9,opt,name=WorkState,proto3,enum=metadata.WorkState" json:"WorkState,omitempty"`
	QueryAddress         string                        `protobuf:"bytes,10,opt,name=QueryAddress,proto3" json:"QueryAddress,omitempty"`
	GossipAddress        string                        `protobuf:"bytes,11,opt,name=GossipAddress,proto3" json:"GossipAddress,omitempty"`
	GossipJoined         bool                          `protobuf:"varint,12,opt,name=GossipJoined,proto3" json:"GossipJoined,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

CNStoreInfo contains information on a CN store.

func (*CNStoreInfo) Descriptor 

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

func (*CNStoreInfo) GetCtlAddress added in v0.8.0 

func (m *CNStoreInfo) GetCtlAddress() string

func (*CNStoreInfo) GetGossipAddress added in v1.0.0 

func (m *CNStoreInfo) GetGossipAddress() string

func (*CNStoreInfo) GetGossipJoined added in v1.0.0 

func (m *CNStoreInfo) GetGossipJoined() bool

func (*CNStoreInfo) GetLabels added in v0.8.0 

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

func (*CNStoreInfo) GetLockServiceAddress added in v0.8.0 

func (m *CNStoreInfo) GetLockServiceAddress() string

func (*CNStoreInfo) GetQueryAddress added in v1.0.0 

func (m *CNStoreInfo) GetQueryAddress() string

func (*CNStoreInfo) GetRole added in v0.6.0 

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

func (*CNStoreInfo) GetSQLAddress added in v0.6.0 

func (m *CNStoreInfo) GetSQLAddress() string

func (*CNStoreInfo) GetServiceAddress added in v0.5.1 

func (m *CNStoreInfo) GetServiceAddress() string

func (*CNStoreInfo) GetTaskServiceCreated added in v0.6.0 

func (m *CNStoreInfo) GetTaskServiceCreated() bool

func (*CNStoreInfo) GetTick 

func (m *CNStoreInfo) GetTick() uint64

func (*CNStoreInfo) GetWorkState added in v1.0.0 

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

func (*CNStoreInfo) Marshal 

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

func (*CNStoreInfo) MarshalTo 

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

func (*CNStoreInfo) MarshalToSizedBuffer 

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

func (*CNStoreInfo) ProtoMessage 

func (*CNStoreInfo) ProtoMessage()

func (*CNStoreInfo) Reset 

func (m *CNStoreInfo) Reset()

func (*CNStoreInfo) Size 

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

func (*CNStoreInfo) String 

func (m *CNStoreInfo) String() string

func (*CNStoreInfo) Unmarshal 

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

func (*CNStoreInfo) XXX_DiscardUnknown 

func (m *CNStoreInfo) XXX_DiscardUnknown()

func (*CNStoreInfo) XXX_Marshal 

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

func (*CNStoreInfo) XXX_Merge 

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

func (*CNStoreInfo) XXX_Size 

func (m *CNStoreInfo) XXX_Size() int

func (*CNStoreInfo) XXX_Unmarshal 

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

type CNStoreLabel added in v0.8.0 

type CNStoreLabel struct {
	// UUID is the uuid of the CN store.
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Operation is the CN label operation.
	// TODO(volgariver6): Unused field.
	Operation CNLabelOp `protobuf:"varint,2,opt,name=Operation,proto3,enum=logservice.CNLabelOp" json:"Operation,omitempty"`
	// Labels is the labels of the CN store.
	Labels               map[string]metadata.LabelList `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CNStoreLabel) Descriptor added in v0.8.0 

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

func (*CNStoreLabel) GetLabels added in v0.8.0 

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

func (*CNStoreLabel) GetOperation added in v0.8.0 

func (m *CNStoreLabel) GetOperation() CNLabelOp

func (*CNStoreLabel) GetUUID added in v0.8.0 

func (m *CNStoreLabel) GetUUID() string

func (*CNStoreLabel) Marshal added in v0.8.0 

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

func (*CNStoreLabel) MarshalTo added in v0.8.0 

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

func (*CNStoreLabel) MarshalToSizedBuffer added in v0.8.0 

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

func (*CNStoreLabel) ProtoMessage added in v0.8.0 

func (*CNStoreLabel) ProtoMessage()

func (*CNStoreLabel) Reset added in v0.8.0 

func (m *CNStoreLabel) Reset()

func (*CNStoreLabel) Size added in v0.8.0 

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

func (*CNStoreLabel) String added in v0.8.0 

func (m *CNStoreLabel) String() string

func (*CNStoreLabel) Unmarshal added in v0.8.0 

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

func (*CNStoreLabel) XXX_DiscardUnknown added in v0.8.0 

func (m *CNStoreLabel) XXX_DiscardUnknown()

func (*CNStoreLabel) XXX_Marshal added in v0.8.0 

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

func (*CNStoreLabel) XXX_Merge added in v0.8.0 

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

func (*CNStoreLabel) XXX_Size added in v0.8.0 

func (m *CNStoreLabel) XXX_Size() int

func (*CNStoreLabel) XXX_Unmarshal added in v0.8.0 

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

type CNWorkState added in v1.0.0 

type CNWorkState struct {
	// UUID is the uuid of the CN store.
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// State is the CN work state.
	State                metadata.WorkState `protobuf:"varint,2,opt,name=State,proto3,enum=metadata.WorkState" json:"State,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CNWorkState) Descriptor added in v1.0.0 

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

func (*CNWorkState) GetState added in v1.0.0 

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

func (*CNWorkState) GetUUID added in v1.0.0 

func (m *CNWorkState) GetUUID() string

func (*CNWorkState) Marshal added in v1.0.0 

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

func (*CNWorkState) MarshalTo added in v1.0.0 

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

func (*CNWorkState) MarshalToSizedBuffer added in v1.0.0 

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

func (*CNWorkState) ProtoMessage added in v1.0.0 

func (*CNWorkState) ProtoMessage()

func (*CNWorkState) Reset added in v1.0.0 

func (m *CNWorkState) Reset()

func (*CNWorkState) Size added in v1.0.0 

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

func (*CNWorkState) String added in v1.0.0 

func (m *CNWorkState) String() string

func (*CNWorkState) Unmarshal added in v1.0.0 

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

func (*CNWorkState) XXX_DiscardUnknown added in v1.0.0 

func (m *CNWorkState) XXX_DiscardUnknown()

func (*CNWorkState) XXX_Marshal added in v1.0.0 

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

func (*CNWorkState) XXX_Merge added in v1.0.0 

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

func (*CNWorkState) XXX_Size added in v1.0.0 

func (m *CNWorkState) XXX_Size() int

func (*CNWorkState) XXX_Unmarshal added in v1.0.0 

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

type CheckerState 

type CheckerState struct {
	Tick                 uint64             `protobuf:"varint,1,opt,name=Tick,proto3" json:"Tick,omitempty"`
	ClusterInfo          ClusterInfo        `protobuf:"bytes,2,opt,name=ClusterInfo,proto3" json:"ClusterInfo"`
	TNState              TNState            `protobuf:"bytes,3,opt,name=TNState,proto3" json:"TNState"`
	LogState             LogState           `protobuf:"bytes,4,opt,name=LogState,proto3" json:"LogState"`
	CNState              CNState            `protobuf:"bytes,5,opt,name=CNState,proto3" json:"CNState"`
	State                HAKeeperState      `protobuf:"varint,6,opt,name=State,proto3,enum=logservice.HAKeeperState" json:"State,omitempty"`
	TaskSchedulerState   TaskSchedulerState `protobuf:"varint,7,opt,name=TaskSchedulerState,proto3,enum=logservice.TaskSchedulerState" json:"TaskSchedulerState,omitempty"`
	TaskTableUser        TaskTableUser      `protobuf:"bytes,8,opt,name=TaskTableUser,proto3" json:"TaskTableUser"`
	NextId               uint64             `protobuf:"varint,9,opt,name=NextId,proto3" json:"NextId,omitempty"`
	NextIDByKey          map[string]uint64  `` /* 165-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

CheckerState contains all HAKeeper state required for making schedule commands.

func (*CheckerState) Descriptor 

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

func (*CheckerState) GetCNState added in v0.6.0 

func (m *CheckerState) GetCNState() CNState

func (*CheckerState) GetClusterInfo 

func (m *CheckerState) GetClusterInfo() ClusterInfo

func (*CheckerState) GetLogState 

func (m *CheckerState) GetLogState() LogState

func (*CheckerState) GetNextIDByKey added in v1.0.0 

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

func (*CheckerState) GetNextId added in v0.8.0 

func (m *CheckerState) GetNextId() uint64

func (*CheckerState) GetState 

func (m *CheckerState) GetState() HAKeeperState

func (*CheckerState) GetTNState added in v1.0.0 

func (m *CheckerState) GetTNState() TNState

func (*CheckerState) GetTaskSchedulerState added in v0.7.0 

func (m *CheckerState) GetTaskSchedulerState() TaskSchedulerState

func (*CheckerState) GetTaskTableUser added in v0.6.0 

func (m *CheckerState) GetTaskTableUser() TaskTableUser

func (*CheckerState) GetTick 

func (m *CheckerState) GetTick() uint64

func (*CheckerState) Marshal 

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

func (*CheckerState) MarshalTo 

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

func (*CheckerState) MarshalToSizedBuffer 

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

func (*CheckerState) ProtoMessage 

func (*CheckerState) ProtoMessage()

func (*CheckerState) Reset 

func (m *CheckerState) Reset()

func (*CheckerState) Size 

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

func (*CheckerState) String 

func (m *CheckerState) String() string

func (*CheckerState) Unmarshal 

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

func (*CheckerState) XXX_DiscardUnknown 

func (m *CheckerState) XXX_DiscardUnknown()

func (*CheckerState) XXX_Marshal 

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

func (*CheckerState) XXX_Merge 

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

func (*CheckerState) XXX_Size 

func (m *CheckerState) XXX_Size() int

func (*CheckerState) XXX_Unmarshal 

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

type ClusterDetails added in v0.5.1 

type ClusterDetails struct {
	TNStores             []TNStore  `protobuf:"bytes,1,rep,name=TNStores,proto3" json:"TNStores"`
	CNStores             []CNStore  `protobuf:"bytes,2,rep,name=CNStores,proto3" json:"CNStores"`
	LogStores            []LogStore `protobuf:"bytes,3,rep,name=LogStores,proto3" json:"LogStores"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ClusterDetails) Descriptor added in v0.5.1 

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

func (*ClusterDetails) GetCNStores added in v0.6.0 

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

func (*ClusterDetails) GetLogStores added in v0.6.0 

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

func (*ClusterDetails) GetTNStores added in v1.0.0 

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

func (*ClusterDetails) Marshal added in v0.5.1 

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

func (*ClusterDetails) MarshalTo added in v0.5.1 

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

func (*ClusterDetails) MarshalToSizedBuffer added in v0.5.1 

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

func (*ClusterDetails) ProtoMessage added in v0.5.1 

func (*ClusterDetails) ProtoMessage()

func (*ClusterDetails) Reset added in v0.5.1 

func (m *ClusterDetails) Reset()

func (*ClusterDetails) Size added in v0.5.1 

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

func (*ClusterDetails) String added in v0.5.1 

func (m *ClusterDetails) String() string

func (*ClusterDetails) Unmarshal added in v0.5.1 

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

func (*ClusterDetails) XXX_DiscardUnknown added in v0.5.1 

func (m *ClusterDetails) XXX_DiscardUnknown()

func (*ClusterDetails) XXX_Marshal added in v0.5.1 

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

func (*ClusterDetails) XXX_Merge added in v0.5.1 

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

func (*ClusterDetails) XXX_Size added in v0.5.1 

func (m *ClusterDetails) XXX_Size() int

func (*ClusterDetails) XXX_Unmarshal added in v0.5.1 

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

type ClusterInfo 

type ClusterInfo struct {
	TNShards             []metadata.TNShardRecord  `protobuf:"bytes,1,rep,name=TNShards,proto3" json:"TNShards"`
	LogShards            []metadata.LogShardRecord `protobuf:"bytes,2,rep,name=LogShards,proto3" json:"LogShards"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

ClusterInfo provides a global view of all shards in the cluster. It describes the logical sharding of the system, rather than physical distribution of all replicas that belong to those shards.

func (*ClusterInfo) Descriptor 

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

func (*ClusterInfo) GetLogShards 

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

func (*ClusterInfo) GetTNShards added in v1.0.0 

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

func (*ClusterInfo) Marshal 

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

func (*ClusterInfo) MarshalTo 

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

func (*ClusterInfo) MarshalToSizedBuffer 

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

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset 

func (m *ClusterInfo) Reset()

func (*ClusterInfo) Size 

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

func (*ClusterInfo) String 

func (m *ClusterInfo) String() string

func (*ClusterInfo) Unmarshal 

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

func (*ClusterInfo) XXX_DiscardUnknown 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal 

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

func (*ClusterInfo) XXX_Merge 

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

func (*ClusterInfo) XXX_Size 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal 

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

type CommandBatch 

type CommandBatch struct {
	Term                 uint64            `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Commands             []ScheduleCommand `protobuf:"bytes,2,rep,name=Commands,proto3" json:"Commands"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CommandBatch) Descriptor 

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

func (*CommandBatch) GetCommands 

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

func (*CommandBatch) GetTerm 

func (m *CommandBatch) GetTerm() uint64

func (*CommandBatch) Marshal 

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

func (*CommandBatch) MarshalTo 

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

func (*CommandBatch) MarshalToSizedBuffer 

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

func (*CommandBatch) ProtoMessage 

func (*CommandBatch) ProtoMessage()

func (*CommandBatch) Reset 

func (m *CommandBatch) Reset()

func (*CommandBatch) Size 

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

func (*CommandBatch) String 

func (m *CommandBatch) String() string

func (*CommandBatch) Unmarshal 

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

func (*CommandBatch) XXX_DiscardUnknown 

func (m *CommandBatch) XXX_DiscardUnknown()

func (*CommandBatch) XXX_Marshal 

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

func (*CommandBatch) XXX_Merge 

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

func (*CommandBatch) XXX_Size 

func (m *CommandBatch) XXX_Size() int

func (*CommandBatch) XXX_Unmarshal 

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

type ConfigChange 

type ConfigChange struct {
	Replica    Replica          `protobuf:"bytes,1,opt,name=Replica,proto3" json:"Replica"`
	ChangeType ConfigChangeType `protobuf:"varint,2,opt,name=ChangeType,proto3,enum=logservice.ConfigChangeType" json:"ChangeType,omitempty"`
	// only used for bootstrap
	InitialMembers       map[uint64]string `` /* 170-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

ConfigChange is the detail of a config change.

func (*ConfigChange) Descriptor 

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

func (*ConfigChange) GetChangeType 

func (m *ConfigChange) GetChangeType() ConfigChangeType

func (*ConfigChange) GetInitialMembers 

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

func (*ConfigChange) GetReplica 

func (m *ConfigChange) GetReplica() Replica

func (*ConfigChange) Marshal 

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

func (*ConfigChange) MarshalTo 

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

func (*ConfigChange) MarshalToSizedBuffer 

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

func (*ConfigChange) ProtoMessage 

func (*ConfigChange) ProtoMessage()

func (*ConfigChange) Reset 

func (m *ConfigChange) Reset()

func (*ConfigChange) Size 

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

func (*ConfigChange) String 

func (m *ConfigChange) String() string

func (*ConfigChange) Unmarshal 

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

func (*ConfigChange) XXX_DiscardUnknown 

func (m *ConfigChange) XXX_DiscardUnknown()

func (*ConfigChange) XXX_Marshal 

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

func (*ConfigChange) XXX_Merge 

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

func (*ConfigChange) XXX_Size 

func (m *ConfigChange) XXX_Size() int

func (*ConfigChange) XXX_Unmarshal 

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

type ConfigChangeType 

type ConfigChangeType int32

ConfigChangeType indicates config change command type. 

const (
	AddReplica    ConfigChangeType = 0
	RemoveReplica ConfigChangeType = 1
	StartReplica  ConfigChangeType = 2
	StopReplica   ConfigChangeType = 3
	KillZombie    ConfigChangeType = 4
)

func (ConfigChangeType) EnumDescriptor 

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

func (ConfigChangeType) String 

func (x ConfigChangeType) String() string

type CreateTaskService added in v0.6.0 

type CreateTaskService struct {
	// User used to connect to the task database.
	User TaskTableUser `protobuf:"bytes,1,opt,name=User,proto3" json:"User"`
	// TaskDatabase task framework database.
	TaskDatabase         string   `protobuf:"bytes,2,opt,name=TaskDatabase,proto3" json:"TaskDatabase,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateTaskService start task service at current node

func (*CreateTaskService) Descriptor added in v0.6.0 

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

func (*CreateTaskService) GetTaskDatabase added in v0.6.0 

func (m *CreateTaskService) GetTaskDatabase() string

func (*CreateTaskService) GetUser added in v0.6.0 

func (m *CreateTaskService) GetUser() TaskTableUser

func (*CreateTaskService) Marshal added in v0.6.0 

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

func (*CreateTaskService) MarshalTo added in v0.6.0 

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

func (*CreateTaskService) MarshalToSizedBuffer added in v0.6.0 

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

func (*CreateTaskService) ProtoMessage added in v0.6.0 

func (*CreateTaskService) ProtoMessage()

func (*CreateTaskService) Reset added in v0.6.0 

func (m *CreateTaskService) Reset()

func (*CreateTaskService) Size added in v0.6.0 

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

func (*CreateTaskService) String added in v0.6.0 

func (m *CreateTaskService) String() string

func (*CreateTaskService) Unmarshal added in v0.6.0 

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

func (*CreateTaskService) XXX_DiscardUnknown added in v0.6.0 

func (m *CreateTaskService) XXX_DiscardUnknown()

func (*CreateTaskService) XXX_Marshal added in v0.6.0 

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

func (*CreateTaskService) XXX_Merge added in v0.6.0 

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

func (*CreateTaskService) XXX_Size added in v0.6.0 

func (m *CreateTaskService) XXX_Size() int

func (*CreateTaskService) XXX_Unmarshal added in v0.6.0 

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

type DeleteCNStore added in v0.7.0 

type DeleteCNStore struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteCNStore deletes CN store from CNState to save hakeeper's memory.

func (*DeleteCNStore) Descriptor added in v0.7.0 

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

func (*DeleteCNStore) GetStoreID added in v0.7.0 

func (m *DeleteCNStore) GetStoreID() string

func (*DeleteCNStore) Marshal added in v0.7.0 

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

func (*DeleteCNStore) MarshalTo added in v0.7.0 

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

func (*DeleteCNStore) MarshalToSizedBuffer added in v0.7.0 

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

func (*DeleteCNStore) ProtoMessage added in v0.7.0 

func (*DeleteCNStore) ProtoMessage()

func (*DeleteCNStore) Reset added in v0.7.0 

func (m *DeleteCNStore) Reset()

func (*DeleteCNStore) Size added in v0.7.0 

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

func (*DeleteCNStore) String added in v0.7.0 

func (m *DeleteCNStore) String() string

func (*DeleteCNStore) Unmarshal added in v0.7.0 

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

func (*DeleteCNStore) XXX_DiscardUnknown added in v0.7.0 

func (m *DeleteCNStore) XXX_DiscardUnknown()

func (*DeleteCNStore) XXX_Marshal added in v0.7.0 

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

func (*DeleteCNStore) XXX_Merge added in v0.7.0 

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

func (*DeleteCNStore) XXX_Size added in v0.7.0 

func (m *DeleteCNStore) XXX_Size() int

func (*DeleteCNStore) XXX_Unmarshal added in v0.7.0 

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

type HAKeeperRSMState 

type HAKeeperRSMState struct {
	Index uint64 `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Tick  uint64 `protobuf:"varint,2,opt,name=Tick,proto3" json:"Tick,omitempty"`
	// NextID is a shared, global ID.
	NextID uint64 `protobuf:"varint,3,opt,name=NextID,proto3" json:"NextID,omitempty"`
	// NextIDByKey is IDs isolated by keys.
	NextIDByKey          map[string]uint64       `` /* 164-byte string literal not displayed */
	Term                 uint64                  `protobuf:"varint,5,opt,name=Term,proto3" json:"Term,omitempty"`
	State                HAKeeperState           `protobuf:"varint,6,opt,name=State,proto3,enum=logservice.HAKeeperState" json:"State,omitempty"`
	TaskSchedulerState   TaskSchedulerState      `protobuf:"varint,7,opt,name=TaskSchedulerState,proto3,enum=logservice.TaskSchedulerState" json:"TaskSchedulerState,omitempty"`
	ScheduleCommands     map[string]CommandBatch `` /* 163-byte string literal not displayed */
	LogShards            map[string]uint64       `` /* 160-byte string literal not displayed */
	CNState              CNState                 `protobuf:"bytes,10,opt,name=CNState,proto3" json:"CNState"`
	TNState              TNState                 `protobuf:"bytes,11,opt,name=TNState,proto3" json:"TNState"`
	LogState             LogState                `protobuf:"bytes,12,opt,name=LogState,proto3" json:"LogState"`
	ClusterInfo          ClusterInfo             `protobuf:"bytes,13,opt,name=ClusterInfo,proto3" json:"ClusterInfo"`
	TaskTableUser        TaskTableUser           `protobuf:"bytes,14,opt,name=TaskTableUser,proto3" json:"TaskTableUser"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

HAKeeperRSMState contains state maintained by HAKeeper's RSM.

func NewRSMState 

func NewRSMState() HAKeeperRSMState

NewRSMState creates a new HAKeeperRSMState instance.

func (*HAKeeperRSMState) Descriptor 

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

func (*HAKeeperRSMState) GetCNState 

func (m *HAKeeperRSMState) GetCNState() CNState

func (*HAKeeperRSMState) GetClusterInfo 

func (m *HAKeeperRSMState) GetClusterInfo() ClusterInfo

func (*HAKeeperRSMState) GetIndex added in v1.0.0 

func (m *HAKeeperRSMState) GetIndex() uint64

func (*HAKeeperRSMState) GetLogShards 

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

func (*HAKeeperRSMState) GetLogState 

func (m *HAKeeperRSMState) GetLogState() LogState

func (*HAKeeperRSMState) GetNextID 

func (m *HAKeeperRSMState) GetNextID() uint64

func (*HAKeeperRSMState) GetNextIDByKey added in v0.8.0 

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

func (*HAKeeperRSMState) GetScheduleCommands 

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

func (*HAKeeperRSMState) GetState 

func (m *HAKeeperRSMState) GetState() HAKeeperState

func (*HAKeeperRSMState) GetTNState added in v1.0.0 

func (m *HAKeeperRSMState) GetTNState() TNState

func (*HAKeeperRSMState) GetTaskSchedulerState added in v0.7.0 

func (m *HAKeeperRSMState) GetTaskSchedulerState() TaskSchedulerState

func (*HAKeeperRSMState) GetTaskTableUser added in v0.6.0 

func (m *HAKeeperRSMState) GetTaskTableUser() TaskTableUser

func (*HAKeeperRSMState) GetTerm 

func (m *HAKeeperRSMState) GetTerm() uint64

func (*HAKeeperRSMState) GetTick 

func (m *HAKeeperRSMState) GetTick() uint64

func (*HAKeeperRSMState) Marshal 

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

func (*HAKeeperRSMState) MarshalTo 

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

func (*HAKeeperRSMState) MarshalToSizedBuffer 

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

func (*HAKeeperRSMState) ProtoMessage 

func (*HAKeeperRSMState) ProtoMessage()

func (*HAKeeperRSMState) Reset 

func (m *HAKeeperRSMState) Reset()

func (*HAKeeperRSMState) Size 

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

func (*HAKeeperRSMState) String 

func (m *HAKeeperRSMState) String() string

func (*HAKeeperRSMState) Unmarshal 

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

func (*HAKeeperRSMState) XXX_DiscardUnknown 

func (m *HAKeeperRSMState) XXX_DiscardUnknown()

func (*HAKeeperRSMState) XXX_Marshal 

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

func (*HAKeeperRSMState) XXX_Merge 

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

func (*HAKeeperRSMState) XXX_Size 

func (m *HAKeeperRSMState) XXX_Size() int

func (*HAKeeperRSMState) XXX_Unmarshal 

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

type HAKeeperState 

type HAKeeperState int32

HAKeeperState state transition diagram 

          HAKeeperCreated
                │
                │ cluster init info set
                ▼
      HAKeeperBootstrapping
                │
                │ init schedule commands received
                ▼
HAKeeperBootstrapCommandsReceived
                │
                │
    ┌───────────┴───────────┐
    │ time out              │ bootstrap successfully
    ▼                       ▼

HAKeeperBootstrapFailed HAKeeperRunning 

const (
	HAKeeperCreated                   HAKeeperState = 0
	HAKeeperBootstrapping             HAKeeperState = 1
	HAKeeperBootstrapCommandsReceived HAKeeperState = 2
	HAKeeperBootstrapFailed           HAKeeperState = 3
	HAKeeperRunning                   HAKeeperState = 4
)

func (HAKeeperState) EnumDescriptor 

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

func (HAKeeperState) String 

func (x HAKeeperState) String() string

type HAKeeperUpdateType 

type HAKeeperUpdateType int32
const (
	TickUpdate                  HAKeeperUpdateType = 0
	CNHeartbeatUpdate           HAKeeperUpdateType = 1
	TNHeartbeatUpdate           HAKeeperUpdateType = 2
	LogHeartbeatUpdate          HAKeeperUpdateType = 3
	GetIDUpdate                 HAKeeperUpdateType = 4
	ScheduleCommandUpdate       HAKeeperUpdateType = 5
	SetStateUpdate              HAKeeperUpdateType = 6
	InitialClusterUpdate        HAKeeperUpdateType = 7
	SetTaskSchedulerStateUpdate HAKeeperUpdateType = 8
	SetTaskTableUserUpdate      HAKeeperUpdateType = 9
	UpdateCNLabel               HAKeeperUpdateType = 10
	UpdateCNWorkState           HAKeeperUpdateType = 11
	PatchCNStore                HAKeeperUpdateType = 12
	RemoveCNStore               HAKeeperUpdateType = 13
)

func (HAKeeperUpdateType) EnumDescriptor 

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

func (HAKeeperUpdateType) String 

func (x HAKeeperUpdateType) String() string

type InitialClusterRequest 

type InitialClusterRequest struct {
	NumOfLogShards       uint64            `protobuf:"varint,1,opt,name=NumOfLogShards,proto3" json:"NumOfLogShards,omitempty"`
	NumOfTNShards        uint64            `protobuf:"varint,2,opt,name=NumOfTNShards,proto3" json:"NumOfTNShards,omitempty"`
	NumOfLogReplicas     uint64            `protobuf:"varint,3,opt,name=NumOfLogReplicas,proto3" json:"NumOfLogReplicas,omitempty"`
	NextID               uint64            `protobuf:"varint,4,opt,name=NextID,proto3" json:"NextID,omitempty"`
	NextIDByKey          map[string]uint64 `` /* 164-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*InitialClusterRequest) Descriptor 

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

func (*InitialClusterRequest) GetNextID added in v1.0.0 

func (m *InitialClusterRequest) GetNextID() uint64

func (*InitialClusterRequest) GetNextIDByKey added in v1.0.0 

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

func (*InitialClusterRequest) GetNumOfLogReplicas 

func (m *InitialClusterRequest) GetNumOfLogReplicas() uint64

func (*InitialClusterRequest) GetNumOfLogShards 

func (m *InitialClusterRequest) GetNumOfLogShards() uint64

func (*InitialClusterRequest) GetNumOfTNShards added in v1.0.0 

func (m *InitialClusterRequest) GetNumOfTNShards() uint64

func (*InitialClusterRequest) Marshal 

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

func (*InitialClusterRequest) MarshalTo 

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

func (*InitialClusterRequest) MarshalToSizedBuffer 

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

func (*InitialClusterRequest) ProtoMessage 

func (*InitialClusterRequest) ProtoMessage()

func (*InitialClusterRequest) Reset 

func (m *InitialClusterRequest) Reset()

func (*InitialClusterRequest) Size 

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

func (*InitialClusterRequest) String 

func (m *InitialClusterRequest) String() string

func (*InitialClusterRequest) Unmarshal 

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

func (*InitialClusterRequest) XXX_DiscardUnknown 

func (m *InitialClusterRequest) XXX_DiscardUnknown()

func (*InitialClusterRequest) XXX_Marshal 

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

func (*InitialClusterRequest) XXX_Merge 

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

func (*InitialClusterRequest) XXX_Size 

func (m *InitialClusterRequest) XXX_Size() int

func (*InitialClusterRequest) XXX_Unmarshal 

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

type JoinGossipCluster added in v1.0.0 

type JoinGossipCluster struct {
	Existing             []string `protobuf:"bytes,1,rep,name=Existing,proto3" json:"Existing,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinGossipCluster) Descriptor added in v1.0.0 

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

func (*JoinGossipCluster) GetExisting added in v1.0.0 

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

func (*JoinGossipCluster) Marshal added in v1.0.0 

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

func (*JoinGossipCluster) MarshalTo added in v1.0.0 

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

func (*JoinGossipCluster) MarshalToSizedBuffer added in v1.0.0 

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

func (*JoinGossipCluster) ProtoMessage added in v1.0.0 

func (*JoinGossipCluster) ProtoMessage()

func (*JoinGossipCluster) Reset added in v1.0.0 

func (m *JoinGossipCluster) Reset()

func (*JoinGossipCluster) Size added in v1.0.0 

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

func (*JoinGossipCluster) String added in v1.0.0 

func (m *JoinGossipCluster) String() string

func (*JoinGossipCluster) Unmarshal added in v1.0.0 

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

func (*JoinGossipCluster) XXX_DiscardUnknown added in v1.0.0 

func (m *JoinGossipCluster) XXX_DiscardUnknown()

func (*JoinGossipCluster) XXX_Marshal added in v1.0.0 

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

func (*JoinGossipCluster) XXX_Merge added in v1.0.0 

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

func (*JoinGossipCluster) XXX_Size added in v1.0.0 

func (m *JoinGossipCluster) XXX_Size() int

func (*JoinGossipCluster) XXX_Unmarshal added in v1.0.0 

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

type LogRecord 

type LogRecord struct {
	Lsn                  uint64     `protobuf:"varint,1,opt,name=Lsn,proto3" json:"Lsn,omitempty"`
	Type                 RecordType `protobuf:"varint,2,opt,name=Type,proto3,enum=logservice.RecordType" json:"Type,omitempty"`
	Data                 []byte     `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

LogRecord is what we store into the LogService.

func (*LogRecord) Descriptor 

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

func (*LogRecord) GetData 

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

func (*LogRecord) GetLsn 

func (m *LogRecord) GetLsn() uint64

func (*LogRecord) GetType 

func (m *LogRecord) GetType() RecordType

func (*LogRecord) Marshal 

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

func (*LogRecord) MarshalTo 

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

func (*LogRecord) MarshalToSizedBuffer 

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

func (*LogRecord) Payload 

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

Payload returns the payload byte slice.

func (*LogRecord) ProtoMessage 

func (*LogRecord) ProtoMessage()

func (*LogRecord) Reset 

func (m *LogRecord) Reset()

func (*LogRecord) ResizePayload 

func (m *LogRecord) ResizePayload(length int)

ResizePayload resizes the payload length to length bytes.

func (*LogRecord) Size 

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

func (*LogRecord) String 

func (m *LogRecord) String() string

func (*LogRecord) Unmarshal 

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

func (*LogRecord) XXX_DiscardUnknown 

func (m *LogRecord) XXX_DiscardUnknown()

func (*LogRecord) XXX_Marshal 

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

func (*LogRecord) XXX_Merge 

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

func (*LogRecord) XXX_Size 

func (m *LogRecord) XXX_Size() int

func (*LogRecord) XXX_Unmarshal 

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

type LogRecordResponse 

type LogRecordResponse struct {
	Records              []LogRecord `protobuf:"bytes,1,rep,name=Records,proto3" json:"Records"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*LogRecordResponse) Descriptor 

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

func (*LogRecordResponse) GetRecords 

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

func (*LogRecordResponse) Marshal 

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

func (*LogRecordResponse) MarshalTo 

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

func (*LogRecordResponse) MarshalToSizedBuffer 

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

func (*LogRecordResponse) ProtoMessage 

func (*LogRecordResponse) ProtoMessage()

func (*LogRecordResponse) Reset 

func (m *LogRecordResponse) Reset()

func (*LogRecordResponse) Size 

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

func (*LogRecordResponse) String 

func (m *LogRecordResponse) String() string

func (*LogRecordResponse) Unmarshal 

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

func (*LogRecordResponse) XXX_DiscardUnknown 

func (m *LogRecordResponse) XXX_DiscardUnknown()

func (*LogRecordResponse) XXX_Marshal 

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

func (*LogRecordResponse) XXX_Merge 

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

func (*LogRecordResponse) XXX_Size 

func (m *LogRecordResponse) XXX_Size() int

func (*LogRecordResponse) XXX_Unmarshal 

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

type LogReplicaInfo 

type LogReplicaInfo struct {
	LogShardInfo `protobuf:"bytes,1,opt,name=LogShardInfo,proto3,embedded=LogShardInfo" json:"LogShardInfo"`
	// ReplicaID is the ID of a replica within the Log shard.
	ReplicaID            uint64   `protobuf:"varint,2,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogReplicaInfo contains information of a log replica.

func (*LogReplicaInfo) Descriptor 

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

func (*LogReplicaInfo) GetReplicaID 

func (m *LogReplicaInfo) GetReplicaID() uint64

func (*LogReplicaInfo) Marshal 

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

func (*LogReplicaInfo) MarshalTo 

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

func (*LogReplicaInfo) MarshalToSizedBuffer 

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

func (*LogReplicaInfo) ProtoMessage 

func (*LogReplicaInfo) ProtoMessage()

func (*LogReplicaInfo) Reset 

func (m *LogReplicaInfo) Reset()

func (*LogReplicaInfo) Size 

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

func (*LogReplicaInfo) String 

func (m *LogReplicaInfo) String() string

func (*LogReplicaInfo) Unmarshal 

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

func (*LogReplicaInfo) XXX_DiscardUnknown 

func (m *LogReplicaInfo) XXX_DiscardUnknown()

func (*LogReplicaInfo) XXX_Marshal 

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

func (*LogReplicaInfo) XXX_Merge 

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

func (*LogReplicaInfo) XXX_Size 

func (m *LogReplicaInfo) XXX_Size() int

func (*LogReplicaInfo) XXX_Unmarshal 

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

type LogRequest 

type LogRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ShardID              uint64   `protobuf:"varint,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Lsn                  uint64   `protobuf:"varint,3,opt,name=Lsn,proto3" json:"Lsn,omitempty"`
	MaxSize              uint64   `protobuf:"varint,4,opt,name=MaxSize,proto3" json:"MaxSize,omitempty"`
	TNShardID            uint64   `protobuf:"varint,5,opt,name=TNShardID,proto3" json:"TNShardID,omitempty"`
	TNID                 uint64   `protobuf:"varint,6,opt,name=TNID,proto3" json:"TNID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogRequest) Descriptor 

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

func (*LogRequest) GetLsn 

func (m *LogRequest) GetLsn() uint64

func (*LogRequest) GetMaxSize 

func (m *LogRequest) GetMaxSize() uint64

func (*LogRequest) GetName 

func (m *LogRequest) GetName() string

func (*LogRequest) GetShardID 

func (m *LogRequest) GetShardID() uint64

func (*LogRequest) GetTNID added in v1.0.0 

func (m *LogRequest) GetTNID() uint64

func (*LogRequest) GetTNShardID added in v1.0.0 

func (m *LogRequest) GetTNShardID() uint64

func (*LogRequest) Marshal 

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

func (*LogRequest) MarshalTo 

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

func (*LogRequest) MarshalToSizedBuffer 

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

func (*LogRequest) ProtoMessage 

func (*LogRequest) ProtoMessage()

func (*LogRequest) Reset 

func (m *LogRequest) Reset()

func (*LogRequest) Size 

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

func (*LogRequest) String 

func (m *LogRequest) String() string

func (*LogRequest) Unmarshal 

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

func (*LogRequest) XXX_DiscardUnknown 

func (m *LogRequest) XXX_DiscardUnknown()

func (*LogRequest) XXX_Marshal 

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

func (*LogRequest) XXX_Merge 

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

func (*LogRequest) XXX_Size 

func (m *LogRequest) XXX_Size() int

func (*LogRequest) XXX_Unmarshal 

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

type LogResponse 

type LogResponse struct {
	ShardID              uint64   `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Lsn                  uint64   `protobuf:"varint,2,opt,name=Lsn,proto3" json:"Lsn,omitempty"`
	LastLsn              uint64   `protobuf:"varint,3,opt,name=LastLsn,proto3" json:"LastLsn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogResponse) Descriptor 

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

func (*LogResponse) GetLastLsn 

func (m *LogResponse) GetLastLsn() uint64

func (*LogResponse) GetLsn 

func (m *LogResponse) GetLsn() uint64

func (*LogResponse) GetShardID 

func (m *LogResponse) GetShardID() uint64

func (*LogResponse) Marshal 

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

func (*LogResponse) MarshalTo 

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

func (*LogResponse) MarshalToSizedBuffer 

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

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) Reset 

func (m *LogResponse) Reset()

func (*LogResponse) Size 

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

func (*LogResponse) String 

func (m *LogResponse) String() string

func (*LogResponse) Unmarshal 

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

func (*LogResponse) XXX_DiscardUnknown 

func (m *LogResponse) XXX_DiscardUnknown()

func (*LogResponse) XXX_Marshal 

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

func (*LogResponse) XXX_Merge 

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

func (*LogResponse) XXX_Size 

func (m *LogResponse) XXX_Size() int

func (*LogResponse) XXX_Unmarshal 

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

type LogShardInfo 

type LogShardInfo struct {
	// ShardID is the ID of a Log shard.
	ShardID uint64 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	// Replicas is a map of ReplicaID to LogStore UUID, it describe the member
	// replicas of the shard at the given Epoch.
	Replicas map[uint64]string `` /* 158-byte string literal not displayed */
	// Epoch is the epoch value of the Shard, member replicas of the Shard can
	// change across epochs.
	Epoch uint64 `protobuf:"varint,3,opt,name=Epoch,proto3" json:"Epoch,omitempty"`
	// LeaderID is the ReplicaID of the leader replica at the given term. When
	// LeaderID is 0, it means there is no leader or the leader is unknown.
	LeaderID uint64 `protobuf:"varint,4,opt,name=LeaderID,proto3" json:"LeaderID,omitempty"`
	// Term is the Raft term value.
	Term                 uint64   `protobuf:"varint,5,opt,name=Term,proto3" json:"Term,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogShardInfo contains information a log shard.

func (*LogShardInfo) Descriptor 

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

func (*LogShardInfo) GetEpoch 

func (m *LogShardInfo) GetEpoch() uint64

func (*LogShardInfo) GetLeaderID 

func (m *LogShardInfo) GetLeaderID() uint64

func (*LogShardInfo) GetReplicas 

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

func (*LogShardInfo) GetShardID 

func (m *LogShardInfo) GetShardID() uint64

func (*LogShardInfo) GetTerm 

func (m *LogShardInfo) GetTerm() uint64

func (*LogShardInfo) Marshal 

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

func (*LogShardInfo) MarshalTo 

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

func (*LogShardInfo) MarshalToSizedBuffer 

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

func (*LogShardInfo) ProtoMessage 

func (*LogShardInfo) ProtoMessage()

func (*LogShardInfo) Reset 

func (m *LogShardInfo) Reset()

func (*LogShardInfo) Size 

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

func (*LogShardInfo) String 

func (m *LogShardInfo) String() string

func (*LogShardInfo) Unmarshal 

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

func (*LogShardInfo) XXX_DiscardUnknown 

func (m *LogShardInfo) XXX_DiscardUnknown()

func (*LogShardInfo) XXX_Marshal 

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

func (*LogShardInfo) XXX_Merge 

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

func (*LogShardInfo) XXX_Size 

func (m *LogShardInfo) XXX_Size() int

func (*LogShardInfo) XXX_Unmarshal 

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

type LogState 

type LogState struct {
	// Shards is keyed by ShardID, it contains details aggregated from all Log
	// stores. Each pb.LogShardInfo here contains data aggregated from
	// different replicas and thus reflect a more accurate description on each
	// shard.
	Shards map[uint64]LogShardInfo `` /* 144-byte string literal not displayed */
	// Stores is keyed by log store UUID, it contains details found on each
	// store. Each LogStoreInfo here reflects what was last reported by each Log
	// store.
	Stores               map[string]LogStoreInfo `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func NewLogState 

func NewLogState() LogState

NewLogState creates a new LogState.

func (*LogState) Descriptor 

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

func (*LogState) GetShards 

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

func (*LogState) GetStores 

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

func (*LogState) Marshal 

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

func (*LogState) MarshalTo 

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

func (*LogState) MarshalToSizedBuffer 

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

func (*LogState) ProtoMessage 

func (*LogState) ProtoMessage()

func (*LogState) Reset 

func (m *LogState) Reset()

func (*LogState) Size 

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

func (*LogState) String 

func (m *LogState) String() string

func (*LogState) Unmarshal 

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

func (*LogState) Update 

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

Update applies the incoming heartbeat message to the LogState with the specified tick used as the timestamp.

func (*LogState) XXX_DiscardUnknown 

func (m *LogState) XXX_DiscardUnknown()

func (*LogState) XXX_Marshal 

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

func (*LogState) XXX_Merge 

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

func (*LogState) XXX_Size 

func (m *LogState) XXX_Size() int

func (*LogState) XXX_Unmarshal 

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

type LogStore added in v0.6.0 

type LogStore struct {
	UUID                 string           `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress       string           `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	Tick                 uint64           `protobuf:"varint,3,opt,name=Tick,proto3" json:"Tick,omitempty"`
	State                NodeState        `protobuf:"varint,4,opt,name=State,proto3,enum=logservice.NodeState" json:"State,omitempty"`
	Replicas             []LogReplicaInfo `protobuf:"bytes,5,rep,name=Replicas,proto3" json:"Replicas"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LogStore) Descriptor added in v0.6.0 

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

func (*LogStore) GetReplicas added in v0.6.0 

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

func (*LogStore) GetServiceAddress added in v0.6.0 

func (m *LogStore) GetServiceAddress() string

func (*LogStore) GetState added in v0.6.0 

func (m *LogStore) GetState() NodeState

func (*LogStore) GetTick added in v0.6.0 

func (m *LogStore) GetTick() uint64

func (*LogStore) GetUUID added in v0.6.0 

func (m *LogStore) GetUUID() string

func (*LogStore) Marshal added in v0.6.0 

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

func (*LogStore) MarshalTo added in v0.6.0 

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

func (*LogStore) MarshalToSizedBuffer added in v0.6.0 

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

func (*LogStore) ProtoMessage added in v0.6.0 

func (*LogStore) ProtoMessage()

func (*LogStore) Reset added in v0.6.0 

func (m *LogStore) Reset()

func (*LogStore) Size added in v0.6.0 

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

func (*LogStore) String added in v0.6.0 

func (m *LogStore) String() string

func (*LogStore) Unmarshal added in v0.6.0 

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

func (*LogStore) XXX_DiscardUnknown added in v0.6.0 

func (m *LogStore) XXX_DiscardUnknown()

func (*LogStore) XXX_Marshal added in v0.6.0 

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

func (*LogStore) XXX_Merge added in v0.6.0 

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

func (*LogStore) XXX_Size added in v0.6.0 

func (m *LogStore) XXX_Size() int

func (*LogStore) XXX_Unmarshal added in v0.6.0 

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

type LogStoreHeartbeat 

type LogStoreHeartbeat struct {
	// UUID is the uuid of the Log Store.
	UUID           string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	RaftAddress    string `protobuf:"bytes,2,opt,name=RaftAddress,proto3" json:"RaftAddress,omitempty"`
	ServiceAddress string `protobuf:"bytes,3,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	GossipAddress  string `protobuf:"bytes,4,opt,name=GossipAddress,proto3" json:"GossipAddress,omitempty"`
	// Replicas is a list of LogReplicaInfo instances collected on the specified
	// LogStore. Details in Shards are based on the local knowledge of each
	// replica running on the current LogStore, it may not be accurate or
	// update to date due to various reasons.
	Replicas []LogReplicaInfo `protobuf:"bytes,5,rep,name=Replicas,proto3" json:"Replicas"`
	// TaskServiceCreated task service is created at the current log node
	TaskServiceCreated   bool     `protobuf:"varint,6,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogStoreHeartbeat is the periodic message sent to the HAKeeper by Log Stores.

func (*LogStoreHeartbeat) Descriptor 

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

func (*LogStoreHeartbeat) GetGossipAddress 

func (m *LogStoreHeartbeat) GetGossipAddress() string

func (*LogStoreHeartbeat) GetRaftAddress 

func (m *LogStoreHeartbeat) GetRaftAddress() string

func (*LogStoreHeartbeat) GetReplicas 

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

func (*LogStoreHeartbeat) GetServiceAddress 

func (m *LogStoreHeartbeat) GetServiceAddress() string

func (*LogStoreHeartbeat) GetTaskServiceCreated added in v0.6.0 

func (m *LogStoreHeartbeat) GetTaskServiceCreated() bool

func (*LogStoreHeartbeat) GetUUID 

func (m *LogStoreHeartbeat) GetUUID() string

func (*LogStoreHeartbeat) Marshal 

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

func (*LogStoreHeartbeat) MarshalTo 

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

func (*LogStoreHeartbeat) MarshalToSizedBuffer 

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

func (*LogStoreHeartbeat) ProtoMessage 

func (*LogStoreHeartbeat) ProtoMessage()

func (*LogStoreHeartbeat) Reset 

func (m *LogStoreHeartbeat) Reset()

func (*LogStoreHeartbeat) Size 

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

func (*LogStoreHeartbeat) String 

func (m *LogStoreHeartbeat) String() string

func (*LogStoreHeartbeat) Unmarshal 

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

func (*LogStoreHeartbeat) XXX_DiscardUnknown 

func (m *LogStoreHeartbeat) XXX_DiscardUnknown()

func (*LogStoreHeartbeat) XXX_Marshal 

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

func (*LogStoreHeartbeat) XXX_Merge 

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

func (*LogStoreHeartbeat) XXX_Size 

func (m *LogStoreHeartbeat) XXX_Size() int

func (*LogStoreHeartbeat) XXX_Unmarshal 

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

type LogStoreInfo 

type LogStoreInfo struct {
	Tick                 uint64           `protobuf:"varint,1,opt,name=Tick,proto3" json:"Tick,omitempty"`
	RaftAddress          string           `protobuf:"bytes,2,opt,name=RaftAddress,proto3" json:"RaftAddress,omitempty"`
	ServiceAddress       string           `protobuf:"bytes,3,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	GossipAddress        string           `protobuf:"bytes,4,opt,name=GossipAddress,proto3" json:"GossipAddress,omitempty"`
	Replicas             []LogReplicaInfo `protobuf:"bytes,5,rep,name=Replicas,proto3" json:"Replicas"`
	TaskServiceCreated   bool             `protobuf:"varint,6,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

LogStoreInfo contains information of all replicas found on a Log store.

func (*LogStoreInfo) Descriptor 

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

func (*LogStoreInfo) GetGossipAddress 

func (m *LogStoreInfo) GetGossipAddress() string

func (*LogStoreInfo) GetRaftAddress 

func (m *LogStoreInfo) GetRaftAddress() string

func (*LogStoreInfo) GetReplicas 

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

func (*LogStoreInfo) GetServiceAddress 

func (m *LogStoreInfo) GetServiceAddress() string

func (*LogStoreInfo) GetTaskServiceCreated added in v0.6.0 

func (m *LogStoreInfo) GetTaskServiceCreated() bool

func (*LogStoreInfo) GetTick 

func (m *LogStoreInfo) GetTick() uint64

func (*LogStoreInfo) Marshal 

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

func (*LogStoreInfo) MarshalTo 

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

func (*LogStoreInfo) MarshalToSizedBuffer 

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

func (*LogStoreInfo) ProtoMessage 

func (*LogStoreInfo) ProtoMessage()

func (*LogStoreInfo) Reset 

func (m *LogStoreInfo) Reset()

func (*LogStoreInfo) Size 

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

func (*LogStoreInfo) String 

func (m *LogStoreInfo) String() string

func (*LogStoreInfo) Unmarshal 

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

func (*LogStoreInfo) XXX_DiscardUnknown 

func (m *LogStoreInfo) XXX_DiscardUnknown()

func (*LogStoreInfo) XXX_Marshal 

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

func (*LogStoreInfo) XXX_Merge 

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

func (*LogStoreInfo) XXX_Size 

func (m *LogStoreInfo) XXX_Size() int

func (*LogStoreInfo) XXX_Unmarshal 

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

type MethodType 

type MethodType int32
const (
	TSO_UPDATE           MethodType = 0
	APPEND               MethodType = 1
	READ                 MethodType = 2
	TRUNCATE             MethodType = 3
	GET_TRUNCATE         MethodType = 4
	CONNECT              MethodType = 5
	CONNECT_RO           MethodType = 6
	LOG_HEARTBEAT        MethodType = 7
	CN_HEARTBEAT         MethodType = 8
	TN_HEARTBEAT         MethodType = 9
	CHECK_HAKEEPER       MethodType = 10
	GET_CLUSTER_DETAILS  MethodType = 11
	GET_SHARD_INFO       MethodType = 12
	CN_ALLOCATE_ID       MethodType = 13
	GET_CLUSTER_STATE    MethodType = 14
	UPDATE_CN_LABEL      MethodType = 15
	UPDATE_CN_WORK_STATE MethodType = 16
	PATCH_CN_STORE       MethodType = 17
	DELETE_CN_STORE      MethodType = 18
)

func (MethodType) EnumDescriptor 

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

func (MethodType) String 

func (x MethodType) String() string

type NodeState added in v0.6.0 

type NodeState int32
const (
	NormalState  NodeState = 0
	TimeoutState NodeState = 1
)

func (NodeState) EnumDescriptor added in v0.6.0 

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

func (NodeState) String added in v0.6.0 

func (x NodeState) String() string

type RSMState 

type RSMState struct {
	Tso                  uint64            `protobuf:"varint,1,opt,name=Tso,proto3" json:"Tso,omitempty"`
	Index                uint64            `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
	LeaseHolderID        uint64            `protobuf:"varint,3,opt,name=LeaseHolderID,proto3" json:"LeaseHolderID,omitempty"`
	TruncatedLsn         uint64            `protobuf:"varint,4,opt,name=TruncatedLsn,proto3" json:"TruncatedLsn,omitempty"`
	LeaseHistory         map[uint64]uint64 `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RSMState) Descriptor 

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

func (*RSMState) GetIndex 

func (m *RSMState) GetIndex() uint64

func (*RSMState) GetLeaseHistory 

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

func (*RSMState) GetLeaseHolderID 

func (m *RSMState) GetLeaseHolderID() uint64

func (*RSMState) GetTruncatedLsn 

func (m *RSMState) GetTruncatedLsn() uint64

func (*RSMState) GetTso 

func (m *RSMState) GetTso() uint64

func (*RSMState) Marshal 

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

func (*RSMState) MarshalTo 

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

func (*RSMState) MarshalToSizedBuffer 

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

func (*RSMState) ProtoMessage 

func (*RSMState) ProtoMessage()

func (*RSMState) Reset 

func (m *RSMState) Reset()

func (*RSMState) Size 

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

func (*RSMState) String 

func (m *RSMState) String() string

func (*RSMState) Unmarshal 

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

func (*RSMState) XXX_DiscardUnknown 

func (m *RSMState) XXX_DiscardUnknown()

func (*RSMState) XXX_Marshal 

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

func (*RSMState) XXX_Merge 

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

func (*RSMState) XXX_Size 

func (m *RSMState) XXX_Size() int

func (*RSMState) XXX_Unmarshal 

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

type RecordType 

type RecordType int32
const (
	UserRecord    RecordType = 0
	Internal      RecordType = 1
	LeaseUpdate   RecordType = 2
	LeaseRejected RecordType = 3
)

func (RecordType) EnumDescriptor 

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

func (RecordType) String 

func (x RecordType) String() string

type Replica 

type Replica struct {
	// UUID which store the Replica is located in
	UUID      string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ShardID   uint64 `protobuf:"varint,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	ReplicaID uint64 `protobuf:"varint,3,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	Epoch     uint64 `protobuf:"varint,4,opt,name=Epoch,proto3" json:"Epoch,omitempty"`
	// LogShardID only used for TNShard.
	LogShardID           uint64   `protobuf:"varint,5,opt,name=LogShardID,proto3" json:"LogShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Replica of the shard

func (*Replica) Descriptor 

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

func (*Replica) GetEpoch 

func (m *Replica) GetEpoch() uint64

func (*Replica) GetLogShardID added in v0.6.0 

func (m *Replica) GetLogShardID() uint64

func (*Replica) GetReplicaID 

func (m *Replica) GetReplicaID() uint64

func (*Replica) GetShardID 

func (m *Replica) GetShardID() uint64

func (*Replica) GetUUID 

func (m *Replica) GetUUID() string

func (*Replica) Marshal 

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

func (*Replica) MarshalTo 

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

func (*Replica) MarshalToSizedBuffer 

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

func (*Replica) ProtoMessage 

func (*Replica) ProtoMessage()

func (*Replica) Reset 

func (m *Replica) Reset()

func (*Replica) Size 

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

func (*Replica) String 

func (m *Replica) String() string

func (*Replica) Unmarshal 

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

func (*Replica) XXX_DiscardUnknown 

func (m *Replica) XXX_DiscardUnknown()

func (*Replica) XXX_Marshal 

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

func (*Replica) XXX_Merge 

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

func (*Replica) XXX_Size 

func (m *Replica) XXX_Size() int

func (*Replica) XXX_Unmarshal 

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

type ReplicaInfo added in v0.6.0 

type ReplicaInfo struct {
	UUID                 string   `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress       string   `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReplicaInfo contains details of a replica

func (*ReplicaInfo) Descriptor added in v0.6.0 

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

func (*ReplicaInfo) GetServiceAddress added in v0.6.0 

func (m *ReplicaInfo) GetServiceAddress() string

func (*ReplicaInfo) GetUUID added in v0.6.0 

func (m *ReplicaInfo) GetUUID() string

func (*ReplicaInfo) Marshal added in v0.6.0 

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

func (*ReplicaInfo) MarshalTo added in v0.6.0 

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

func (*ReplicaInfo) MarshalToSizedBuffer added in v0.6.0 

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

func (*ReplicaInfo) ProtoMessage added in v0.6.0 

func (*ReplicaInfo) ProtoMessage()

func (*ReplicaInfo) Reset added in v0.6.0 

func (m *ReplicaInfo) Reset()

func (*ReplicaInfo) Size added in v0.6.0 

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

func (*ReplicaInfo) String added in v0.6.0 

func (m *ReplicaInfo) String() string

func (*ReplicaInfo) Unmarshal added in v0.6.0 

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

func (*ReplicaInfo) XXX_DiscardUnknown added in v0.6.0 

func (m *ReplicaInfo) XXX_DiscardUnknown()

func (*ReplicaInfo) XXX_Marshal added in v0.6.0 

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

func (*ReplicaInfo) XXX_Merge added in v0.6.0 

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

func (*ReplicaInfo) XXX_Size added in v0.6.0 

func (m *ReplicaInfo) XXX_Size() int

func (*ReplicaInfo) XXX_Unmarshal added in v0.6.0 

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

type Request 

type Request struct {
	RequestID            uint64             `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Method               MethodType         `protobuf:"varint,2,opt,name=Method,proto3,enum=logservice.MethodType" json:"Method,omitempty"`
	LogRequest           LogRequest         `protobuf:"bytes,3,opt,name=LogRequest,proto3" json:"LogRequest"`
	LogHeartbeat         *LogStoreHeartbeat `protobuf:"bytes,4,opt,name=LogHeartbeat,proto3" json:"LogHeartbeat,omitempty"`
	CNHeartbeat          *CNStoreHeartbeat  `protobuf:"bytes,5,opt,name=CNHeartbeat,proto3" json:"CNHeartbeat,omitempty"`
	TNHeartbeat          *TNStoreHeartbeat  `protobuf:"bytes,6,opt,name=TNHeartbeat,proto3" json:"TNHeartbeat,omitempty"`
	TsoRequest           *TsoRequest        `protobuf:"bytes,7,opt,name=TsoRequest,proto3" json:"TsoRequest,omitempty"`
	CNAllocateID         *CNAllocateID      `protobuf:"bytes,8,opt,name=CNAllocateID,proto3" json:"CNAllocateID,omitempty"`
	CNStoreLabel         *CNStoreLabel      `protobuf:"bytes,9,opt,name=CNStoreLabel,proto3" json:"CNStoreLabel,omitempty"`
	CNWorkState          *CNWorkState       `protobuf:"bytes,10,opt,name=CNWorkState,proto3" json:"CNWorkState,omitempty"`
	CNStateLabel         *CNStateLabel      `protobuf:"bytes,11,opt,name=CNStateLabel,proto3" json:"CNStateLabel,omitempty"`
	DeleteCNStore        *DeleteCNStore     `protobuf:"bytes,12,opt,name=DeleteCNStore,proto3" json:"DeleteCNStore,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetCNAllocateID added in v0.6.0 

func (m *Request) GetCNAllocateID() *CNAllocateID

func (*Request) GetCNHeartbeat 

func (m *Request) GetCNHeartbeat() *CNStoreHeartbeat

func (*Request) GetCNStateLabel added in v1.0.0 

func (m *Request) GetCNStateLabel() *CNStateLabel

func (*Request) GetCNStoreLabel added in v0.8.0 

func (m *Request) GetCNStoreLabel() *CNStoreLabel

func (*Request) GetCNWorkState added in v1.0.0 

func (m *Request) GetCNWorkState() *CNWorkState

func (*Request) GetDeleteCNStore added in v1.0.0 

func (m *Request) GetDeleteCNStore() *DeleteCNStore

func (*Request) GetLogHeartbeat 

func (m *Request) GetLogHeartbeat() *LogStoreHeartbeat

func (*Request) GetLogRequest 

func (m *Request) GetLogRequest() LogRequest

func (*Request) GetMethod 

func (m *Request) GetMethod() MethodType

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) GetTNHeartbeat added in v1.0.0 

func (m *Request) GetTNHeartbeat() *TNStoreHeartbeat

func (*Request) GetTsoRequest 

func (m *Request) GetTsoRequest() *TsoRequest

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	RequestID            uint64                `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Method               MethodType            `protobuf:"varint,2,opt,name=Method,proto3,enum=logservice.MethodType" json:"Method,omitempty"`
	ErrorCode            uint32                `protobuf:"varint,3,opt,name=ErrorCode,proto3" json:"ErrorCode,omitempty"`
	ErrorMessage         string                `protobuf:"bytes,4,opt,name=ErrorMessage,proto3" json:"ErrorMessage,omitempty"`
	IsHAKeeper           bool                  `protobuf:"varint,5,opt,name=IsHAKeeper,proto3" json:"IsHAKeeper,omitempty"`
	LogResponse          LogResponse           `protobuf:"bytes,6,opt,name=LogResponse,proto3" json:"LogResponse"`
	CommandBatch         *CommandBatch         `protobuf:"bytes,7,opt,name=CommandBatch,proto3" json:"CommandBatch,omitempty"`
	TsoResponse          *TsoResponse          `protobuf:"bytes,8,opt,name=TsoResponse,proto3" json:"TsoResponse,omitempty"`
	ClusterDetails       *ClusterDetails       `protobuf:"bytes,9,opt,name=ClusterDetails,proto3" json:"ClusterDetails,omitempty"`
	ShardInfo            *ShardInfoQueryResult `protobuf:"bytes,10,opt,name=ShardInfo,proto3" json:"ShardInfo,omitempty"`
	AllocateID           *AllocateIDResponse   `protobuf:"bytes,11,opt,name=AllocateID,proto3" json:"AllocateID,omitempty"`
	CheckerState         *CheckerState         `protobuf:"bytes,12,opt,name=CheckerState,proto3" json:"CheckerState,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetAllocateID added in v0.6.0 

func (m *Response) GetAllocateID() *AllocateIDResponse

func (*Response) GetCheckerState added in v0.6.0 

func (m *Response) GetCheckerState() *CheckerState

func (*Response) GetClusterDetails added in v0.5.1 

func (m *Response) GetClusterDetails() *ClusterDetails

func (*Response) GetCommandBatch 

func (m *Response) GetCommandBatch() *CommandBatch

func (*Response) GetErrorCode 

func (m *Response) GetErrorCode() uint32

func (*Response) GetErrorMessage 

func (m *Response) GetErrorMessage() string

func (*Response) GetIsHAKeeper added in v0.5.1 

func (m *Response) GetIsHAKeeper() bool

func (*Response) GetLogResponse 

func (m *Response) GetLogResponse() LogResponse

func (*Response) GetMethod 

func (m *Response) GetMethod() MethodType

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) GetShardInfo added in v0.6.0 

func (m *Response) GetShardInfo() *ShardInfoQueryResult

func (*Response) GetTsoResponse 

func (m *Response) GetTsoResponse() *TsoResponse

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ScheduleCommand 

type ScheduleCommand struct {
	// UUID which store the ScheduleCommand is sent to
	UUID                 string             `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	Bootstrapping        bool               `protobuf:"varint,2,opt,name=Bootstrapping,proto3" json:"Bootstrapping,omitempty"`
	ServiceType          ServiceType        `protobuf:"varint,3,opt,name=ServiceType,proto3,enum=logservice.ServiceType" json:"ServiceType,omitempty"`
	ConfigChange         *ConfigChange      `protobuf:"bytes,4,opt,name=ConfigChange,proto3" json:"ConfigChange,omitempty"`
	ShutdownStore        *ShutdownStore     `protobuf:"bytes,5,opt,name=ShutdownStore,proto3" json:"ShutdownStore,omitempty"`
	CreateTaskService    *CreateTaskService `protobuf:"bytes,6,opt,name=CreateTaskService,proto3" json:"CreateTaskService,omitempty"`
	DeleteCNStore        *DeleteCNStore     `protobuf:"bytes,7,opt,name=DeleteCNStore,proto3" json:"DeleteCNStore,omitempty"`
	JoinGossipCluster    *JoinGossipCluster `protobuf:"bytes,8,opt,name=JoinGossipCluster,proto3" json:"JoinGossipCluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ScheduleCommand contains a shard schedule command.

func (*ScheduleCommand) Descriptor 

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

func (*ScheduleCommand) GetBootstrapping 

func (m *ScheduleCommand) GetBootstrapping() bool

func (*ScheduleCommand) GetConfigChange 

func (m *ScheduleCommand) GetConfigChange() *ConfigChange

func (*ScheduleCommand) GetCreateTaskService added in v0.6.0 

func (m *ScheduleCommand) GetCreateTaskService() *CreateTaskService

func (*ScheduleCommand) GetDeleteCNStore added in v0.7.0 

func (m *ScheduleCommand) GetDeleteCNStore() *DeleteCNStore

func (*ScheduleCommand) GetJoinGossipCluster added in v1.0.0 

func (m *ScheduleCommand) GetJoinGossipCluster() *JoinGossipCluster

func (*ScheduleCommand) GetServiceType 

func (m *ScheduleCommand) GetServiceType() ServiceType

func (*ScheduleCommand) GetShutdownStore 

func (m *ScheduleCommand) GetShutdownStore() *ShutdownStore

func (*ScheduleCommand) GetUUID 

func (m *ScheduleCommand) GetUUID() string

func (*ScheduleCommand) LogString added in v0.5.1 

func (m *ScheduleCommand) LogString() string

LogString returns "ServiceType/ConfigChangeType UUID RepUuid:RepShardID:RepID InitialMembers". Do not add CN's StartTaskRunner info to log string, because there has user and password.

func (*ScheduleCommand) Marshal 

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

func (*ScheduleCommand) MarshalTo 

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

func (*ScheduleCommand) MarshalToSizedBuffer 

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

func (*ScheduleCommand) ProtoMessage 

func (*ScheduleCommand) ProtoMessage()

func (*ScheduleCommand) Reset 

func (m *ScheduleCommand) Reset()

func (*ScheduleCommand) Size 

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

func (*ScheduleCommand) String 

func (m *ScheduleCommand) String() string

func (*ScheduleCommand) Unmarshal 

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

func (*ScheduleCommand) XXX_DiscardUnknown 

func (m *ScheduleCommand) XXX_DiscardUnknown()

func (*ScheduleCommand) XXX_Marshal 

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

func (*ScheduleCommand) XXX_Merge 

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

func (*ScheduleCommand) XXX_Size 

func (m *ScheduleCommand) XXX_Size() int

func (*ScheduleCommand) XXX_Unmarshal 

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

type ServiceType 

type ServiceType int32

ServiceType specifies type of service 

const (
	LogService ServiceType = 0
	TNService  ServiceType = 1
	CNService  ServiceType = 2
)

func (ServiceType) EnumDescriptor 

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

func (ServiceType) String 

func (x ServiceType) String() string

type ShardInfoQueryResult added in v0.6.0 

type ShardInfoQueryResult struct {
	ShardID              uint64                 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Replicas             map[uint64]ReplicaInfo `` /* 148-byte string literal not displayed */
	Epoch                uint64                 `protobuf:"varint,3,opt,name=Epoch,proto3" json:"Epoch,omitempty"`
	LeaderID             uint64                 `protobuf:"varint,4,opt,name=LeaderID,proto3" json:"LeaderID,omitempty"`
	Term                 uint64                 `protobuf:"varint,5,opt,name=Term,proto3" json:"Term,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

ShardInfoQueryResult contains the result of the shard info query.

func (*ShardInfoQueryResult) Descriptor added in v0.6.0 

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

func (*ShardInfoQueryResult) GetEpoch added in v0.6.0 

func (m *ShardInfoQueryResult) GetEpoch() uint64

func (*ShardInfoQueryResult) GetLeaderID added in v0.6.0 

func (m *ShardInfoQueryResult) GetLeaderID() uint64

func (*ShardInfoQueryResult) GetReplicas added in v0.6.0 

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

func (*ShardInfoQueryResult) GetShardID added in v0.6.0 

func (m *ShardInfoQueryResult) GetShardID() uint64

func (*ShardInfoQueryResult) GetTerm added in v0.6.0 

func (m *ShardInfoQueryResult) GetTerm() uint64

func (*ShardInfoQueryResult) Marshal added in v0.6.0 

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

func (*ShardInfoQueryResult) MarshalTo added in v0.6.0 

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

func (*ShardInfoQueryResult) MarshalToSizedBuffer added in v0.6.0 

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

func (*ShardInfoQueryResult) ProtoMessage added in v0.6.0 

func (*ShardInfoQueryResult) ProtoMessage()

func (*ShardInfoQueryResult) Reset added in v0.6.0 

func (m *ShardInfoQueryResult) Reset()

func (*ShardInfoQueryResult) Size added in v0.6.0 

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

func (*ShardInfoQueryResult) String added in v0.6.0 

func (m *ShardInfoQueryResult) String() string

func (*ShardInfoQueryResult) Unmarshal added in v0.6.0 

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

func (*ShardInfoQueryResult) XXX_DiscardUnknown added in v0.6.0 

func (m *ShardInfoQueryResult) XXX_DiscardUnknown()

func (*ShardInfoQueryResult) XXX_Marshal added in v0.6.0 

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

func (*ShardInfoQueryResult) XXX_Merge added in v0.6.0 

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

func (*ShardInfoQueryResult) XXX_Size added in v0.6.0 

func (m *ShardInfoQueryResult) XXX_Size() int

func (*ShardInfoQueryResult) XXX_Unmarshal added in v0.6.0 

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

type ShutdownStore 

type ShutdownStore struct {
	StoreID              string   `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShutdownStore would stop store.

func (*ShutdownStore) Descriptor 

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

func (*ShutdownStore) GetStoreID 

func (m *ShutdownStore) GetStoreID() string

func (*ShutdownStore) Marshal 

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

func (*ShutdownStore) MarshalTo 

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

func (*ShutdownStore) MarshalToSizedBuffer 

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

func (*ShutdownStore) ProtoMessage 

func (*ShutdownStore) ProtoMessage()

func (*ShutdownStore) Reset 

func (m *ShutdownStore) Reset()

func (*ShutdownStore) Size 

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

func (*ShutdownStore) String 

func (m *ShutdownStore) String() string

func (*ShutdownStore) Unmarshal 

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

func (*ShutdownStore) XXX_DiscardUnknown 

func (m *ShutdownStore) XXX_DiscardUnknown()

func (*ShutdownStore) XXX_Marshal 

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

func (*ShutdownStore) XXX_Merge 

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

func (*ShutdownStore) XXX_Size 

func (m *ShutdownStore) XXX_Size() int

func (*ShutdownStore) XXX_Unmarshal 

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

type TNShardInfo added in v1.0.0 

type TNShardInfo struct {
	// ShardID uniquely identifies a TN shard. Each TN shard manages a Primary
	// Key range or hashed Primary Key value range.
	ShardID uint64 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	// ReplicaID uniquely identifies a TN shard instance. After repairing a
	// failed TN shard, a new TN shard instance is created with a new ReplicaID
	// value.
	ReplicaID            uint64   `protobuf:"varint,2,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNShardInfo contains information of a launched TN shard.

func (*TNShardInfo) Descriptor added in v1.0.0 

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

func (*TNShardInfo) GetReplicaID added in v1.0.0 

func (m *TNShardInfo) GetReplicaID() uint64

func (*TNShardInfo) GetShardID added in v1.0.0 

func (m *TNShardInfo) GetShardID() uint64

func (*TNShardInfo) Marshal added in v1.0.0 

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

func (*TNShardInfo) MarshalTo added in v1.0.0 

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

func (*TNShardInfo) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNShardInfo) ProtoMessage added in v1.0.0 

func (*TNShardInfo) ProtoMessage()

func (*TNShardInfo) Reset added in v1.0.0 

func (m *TNShardInfo) Reset()

func (*TNShardInfo) Size added in v1.0.0 

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

func (*TNShardInfo) String added in v1.0.0 

func (m *TNShardInfo) String() string

func (*TNShardInfo) Unmarshal added in v1.0.0 

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

func (*TNShardInfo) XXX_DiscardUnknown added in v1.0.0 

func (m *TNShardInfo) XXX_DiscardUnknown()

func (*TNShardInfo) XXX_Marshal added in v1.0.0 

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

func (*TNShardInfo) XXX_Merge added in v1.0.0 

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

func (*TNShardInfo) XXX_Size added in v1.0.0 

func (m *TNShardInfo) XXX_Size() int

func (*TNShardInfo) XXX_Unmarshal added in v1.0.0 

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

type TNState added in v1.0.0 

type TNState struct {
	// Stores is keyed by TN store UUID.
	Stores               map[string]TNStoreInfo `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

TNState contains all TN details known to the HAKeeper.

func NewTNState added in v1.0.0 

func NewTNState() TNState

NewTNState creates a new DNState.

func (*TNState) Descriptor added in v1.0.0 

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

func (*TNState) GetStores added in v1.0.0 

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

func (*TNState) Marshal added in v1.0.0 

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

func (*TNState) MarshalTo added in v1.0.0 

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

func (*TNState) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNState) ProtoMessage added in v1.0.0 

func (*TNState) ProtoMessage()

func (*TNState) Reset added in v1.0.0 

func (m *TNState) Reset()

func (*TNState) Size added in v1.0.0 

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

func (*TNState) String added in v1.0.0 

func (m *TNState) String() string

func (*TNState) Unmarshal added in v1.0.0 

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

func (*TNState) Update added in v1.0.0 

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

Update applies the incoming DNStoreHeartbeat into HAKeeper. Tick is the current tick of the HAKeeper which is used as the timestamp of the heartbeat.

func (*TNState) XXX_DiscardUnknown added in v1.0.0 

func (m *TNState) XXX_DiscardUnknown()

func (*TNState) XXX_Marshal added in v1.0.0 

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

func (*TNState) XXX_Merge added in v1.0.0 

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

func (*TNState) XXX_Size added in v1.0.0 

func (m *TNState) XXX_Size() int

func (*TNState) XXX_Unmarshal added in v1.0.0 

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

type TNStore added in v1.0.0 

type TNStore struct {
	UUID           string        `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress string        `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	Tick           uint64        `protobuf:"varint,3,opt,name=Tick,proto3" json:"Tick,omitempty"`
	State          NodeState     `protobuf:"varint,4,opt,name=State,proto3,enum=logservice.NodeState" json:"State,omitempty"`
	Shards         []TNShardInfo `protobuf:"bytes,5,rep,name=Shards,proto3" json:"Shards"`
	// Server address for logtail push model
	LogtailServerAddress string `protobuf:"bytes,6,opt,name=LogtailServerAddress,proto3" json:"LogtailServerAddress,omitempty"`
	// LockServiceAddress lock service address for lock table allocator
	LockServiceAddress   string   `protobuf:"bytes,7,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string   `protobuf:"bytes,8,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TNStore) Descriptor added in v1.0.0 

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

func (*TNStore) GetCtlAddress added in v1.0.0 

func (m *TNStore) GetCtlAddress() string

func (*TNStore) GetLockServiceAddress added in v1.0.0 

func (m *TNStore) GetLockServiceAddress() string

func (*TNStore) GetLogtailServerAddress added in v1.0.0 

func (m *TNStore) GetLogtailServerAddress() string

func (*TNStore) GetServiceAddress added in v1.0.0 

func (m *TNStore) GetServiceAddress() string

func (*TNStore) GetShards added in v1.0.0 

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

func (*TNStore) GetState added in v1.0.0 

func (m *TNStore) GetState() NodeState

func (*TNStore) GetTick added in v1.0.0 

func (m *TNStore) GetTick() uint64

func (*TNStore) GetUUID added in v1.0.0 

func (m *TNStore) GetUUID() string

func (*TNStore) Marshal added in v1.0.0 

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

func (*TNStore) MarshalTo added in v1.0.0 

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

func (*TNStore) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNStore) ProtoMessage added in v1.0.0 

func (*TNStore) ProtoMessage()

func (*TNStore) Reset added in v1.0.0 

func (m *TNStore) Reset()

func (*TNStore) Size added in v1.0.0 

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

func (*TNStore) String added in v1.0.0 

func (m *TNStore) String() string

func (*TNStore) Unmarshal added in v1.0.0 

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

func (*TNStore) XXX_DiscardUnknown added in v1.0.0 

func (m *TNStore) XXX_DiscardUnknown()

func (*TNStore) XXX_Marshal added in v1.0.0 

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

func (*TNStore) XXX_Merge added in v1.0.0 

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

func (*TNStore) XXX_Size added in v1.0.0 

func (m *TNStore) XXX_Size() int

func (*TNStore) XXX_Unmarshal added in v1.0.0 

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

type TNStoreHeartbeat added in v1.0.0 

type TNStoreHeartbeat struct {
	// UUID is the uuid of the TN Store.
	UUID           string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	ServiceAddress string `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	// Shards is a list of TNShardInfo instances collected on the specified
	// TN store.
	Shards             []TNShardInfo `protobuf:"bytes,3,rep,name=Shards,proto3" json:"Shards"`
	TaskServiceCreated bool          `protobuf:"varint,4,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	// Server address for logtail push model
	LogtailServerAddress string `protobuf:"bytes,5,opt,name=LogtailServerAddress,proto3" json:"LogtailServerAddress,omitempty"`
	// LockServiceAddress lock service address for lock table allocator
	LockServiceAddress   string   `protobuf:"bytes,6,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string   `protobuf:"bytes,7,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNStoreHeartbeat is the periodic message sent to the HAKeeper by TN stores.

func (*TNStoreHeartbeat) Descriptor added in v1.0.0 

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

func (*TNStoreHeartbeat) GetCtlAddress added in v1.0.0 

func (m *TNStoreHeartbeat) GetCtlAddress() string

func (*TNStoreHeartbeat) GetLockServiceAddress added in v1.0.0 

func (m *TNStoreHeartbeat) GetLockServiceAddress() string

func (*TNStoreHeartbeat) GetLogtailServerAddress added in v1.0.0 

func (m *TNStoreHeartbeat) GetLogtailServerAddress() string

func (*TNStoreHeartbeat) GetServiceAddress added in v1.0.0 

func (m *TNStoreHeartbeat) GetServiceAddress() string

func (*TNStoreHeartbeat) GetShards added in v1.0.0 

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

func (*TNStoreHeartbeat) GetTaskServiceCreated added in v1.0.0 

func (m *TNStoreHeartbeat) GetTaskServiceCreated() bool

func (*TNStoreHeartbeat) GetUUID added in v1.0.0 

func (m *TNStoreHeartbeat) GetUUID() string

func (*TNStoreHeartbeat) Marshal added in v1.0.0 

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

func (*TNStoreHeartbeat) MarshalTo added in v1.0.0 

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

func (*TNStoreHeartbeat) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNStoreHeartbeat) ProtoMessage added in v1.0.0 

func (*TNStoreHeartbeat) ProtoMessage()

func (*TNStoreHeartbeat) Reset added in v1.0.0 

func (m *TNStoreHeartbeat) Reset()

func (*TNStoreHeartbeat) Size added in v1.0.0 

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

func (*TNStoreHeartbeat) String added in v1.0.0 

func (m *TNStoreHeartbeat) String() string

func (*TNStoreHeartbeat) Unmarshal added in v1.0.0 

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

func (*TNStoreHeartbeat) XXX_DiscardUnknown added in v1.0.0 

func (m *TNStoreHeartbeat) XXX_DiscardUnknown()

func (*TNStoreHeartbeat) XXX_Marshal added in v1.0.0 

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

func (*TNStoreHeartbeat) XXX_Merge added in v1.0.0 

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

func (*TNStoreHeartbeat) XXX_Size added in v1.0.0 

func (m *TNStoreHeartbeat) XXX_Size() int

func (*TNStoreHeartbeat) XXX_Unmarshal added in v1.0.0 

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

type TNStoreInfo added in v1.0.0 

type TNStoreInfo struct {
	Tick               uint64        `protobuf:"varint,1,opt,name=Tick,proto3" json:"Tick,omitempty"`
	ServiceAddress     string        `protobuf:"bytes,2,opt,name=ServiceAddress,proto3" json:"ServiceAddress,omitempty"`
	Shards             []TNShardInfo `protobuf:"bytes,3,rep,name=Shards,proto3" json:"Shards"`
	TaskServiceCreated bool          `protobuf:"varint,4,opt,name=TaskServiceCreated,proto3" json:"TaskServiceCreated,omitempty"`
	// Server address for logtail push model
	LogtailServerAddress string `protobuf:"bytes,5,opt,name=LogtailServerAddress,proto3" json:"LogtailServerAddress,omitempty"`
	// LockServiceAddress lock service address for lock table allocator
	LockServiceAddress   string   `protobuf:"bytes,6,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	CtlAddress           string   `protobuf:"bytes,7,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNStoreInfo contains information on a TN store.

func (*TNStoreInfo) Descriptor added in v1.0.0 

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

func (*TNStoreInfo) GetCtlAddress added in v1.0.0 

func (m *TNStoreInfo) GetCtlAddress() string

func (*TNStoreInfo) GetLockServiceAddress added in v1.0.0 

func (m *TNStoreInfo) GetLockServiceAddress() string

func (*TNStoreInfo) GetLogtailServerAddress added in v1.0.0 

func (m *TNStoreInfo) GetLogtailServerAddress() string

func (*TNStoreInfo) GetServiceAddress added in v1.0.0 

func (m *TNStoreInfo) GetServiceAddress() string

func (*TNStoreInfo) GetShards added in v1.0.0 

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

func (*TNStoreInfo) GetTaskServiceCreated added in v1.0.0 

func (m *TNStoreInfo) GetTaskServiceCreated() bool

func (*TNStoreInfo) GetTick added in v1.0.0 

func (m *TNStoreInfo) GetTick() uint64

func (*TNStoreInfo) Marshal added in v1.0.0 

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

func (*TNStoreInfo) MarshalTo added in v1.0.0 

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

func (*TNStoreInfo) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNStoreInfo) ProtoMessage added in v1.0.0 

func (*TNStoreInfo) ProtoMessage()

func (*TNStoreInfo) Reset added in v1.0.0 

func (m *TNStoreInfo) Reset()

func (*TNStoreInfo) Size added in v1.0.0 

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

func (*TNStoreInfo) String added in v1.0.0 

func (m *TNStoreInfo) String() string

func (*TNStoreInfo) Unmarshal added in v1.0.0 

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

func (*TNStoreInfo) XXX_DiscardUnknown added in v1.0.0 

func (m *TNStoreInfo) XXX_DiscardUnknown()

func (*TNStoreInfo) XXX_Marshal added in v1.0.0 

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

func (*TNStoreInfo) XXX_Merge added in v1.0.0 

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

func (*TNStoreInfo) XXX_Size added in v1.0.0 

func (m *TNStoreInfo) XXX_Size() int

func (*TNStoreInfo) XXX_Unmarshal added in v1.0.0 

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

type TaskSchedulerState added in v0.7.0 

type TaskSchedulerState int32

TaskSchedulerState state transition diagram 

TaskSchedulerCreated
         │
         │  setTaskTableUser()
         ▼
TaskSchedulerStarted
        │ ▲
        │ │
        ▼ │
 TaskSchedulerStopped

const (
	TaskSchedulerCreated TaskSchedulerState = 0
	TaskSchedulerRunning TaskSchedulerState = 1
	TaskSchedulerStopped TaskSchedulerState = 2
)

func (TaskSchedulerState) EnumDescriptor added in v0.7.0 

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

func (TaskSchedulerState) String added in v0.7.0 

func (x TaskSchedulerState) String() string

type TaskTableUser added in v0.6.0 

type TaskTableUser struct {
	// Username for task table user
	Username string `protobuf:"bytes,1,opt,name=Username,proto3" json:"Username,omitempty"`
	// Password for task table user
	Password             string   `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskTableUser) Descriptor added in v0.6.0 

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

func (*TaskTableUser) GetPassword added in v0.6.0 

func (m *TaskTableUser) GetPassword() string

func (*TaskTableUser) GetUsername added in v0.6.0 

func (m *TaskTableUser) GetUsername() string

func (*TaskTableUser) Marshal added in v0.6.0 

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

func (*TaskTableUser) MarshalTo added in v0.6.0 

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

func (*TaskTableUser) MarshalToSizedBuffer added in v0.6.0 

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

func (*TaskTableUser) ProtoMessage added in v0.6.0 

func (*TaskTableUser) ProtoMessage()

func (*TaskTableUser) Reset added in v0.6.0 

func (m *TaskTableUser) Reset()

func (*TaskTableUser) Size added in v0.6.0 

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

func (*TaskTableUser) String added in v0.6.0 

func (m *TaskTableUser) String() string

func (*TaskTableUser) Unmarshal added in v0.6.0 

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

func (*TaskTableUser) XXX_DiscardUnknown added in v0.6.0 

func (m *TaskTableUser) XXX_DiscardUnknown()

func (*TaskTableUser) XXX_Marshal added in v0.6.0 

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

func (*TaskTableUser) XXX_Merge added in v0.6.0 

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

func (*TaskTableUser) XXX_Size added in v0.6.0 

func (m *TaskTableUser) XXX_Size() int

func (*TaskTableUser) XXX_Unmarshal added in v0.6.0 

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

type TsoRequest 

type TsoRequest struct {
	Count                uint64   `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TsoRequest) Descriptor 

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

func (*TsoRequest) GetCount 

func (m *TsoRequest) GetCount() uint64

func (*TsoRequest) Marshal 

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

func (*TsoRequest) MarshalTo 

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

func (*TsoRequest) MarshalToSizedBuffer 

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

func (*TsoRequest) ProtoMessage 

func (*TsoRequest) ProtoMessage()

func (*TsoRequest) Reset 

func (m *TsoRequest) Reset()

func (*TsoRequest) Size 

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

func (*TsoRequest) String 

func (m *TsoRequest) String() string

func (*TsoRequest) Unmarshal 

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

func (*TsoRequest) XXX_DiscardUnknown 

func (m *TsoRequest) XXX_DiscardUnknown()

func (*TsoRequest) XXX_Marshal 

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

func (*TsoRequest) XXX_Merge 

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

func (*TsoRequest) XXX_Size 

func (m *TsoRequest) XXX_Size() int

func (*TsoRequest) XXX_Unmarshal 

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

type TsoResponse 

type TsoResponse struct {
	Value                uint64   `protobuf:"varint,1,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TsoResponse) Descriptor 

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

func (*TsoResponse) GetValue 

func (m *TsoResponse) GetValue() uint64

func (*TsoResponse) Marshal 

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

func (*TsoResponse) MarshalTo 

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

func (*TsoResponse) MarshalToSizedBuffer 

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

func (*TsoResponse) ProtoMessage 

func (*TsoResponse) ProtoMessage()

func (*TsoResponse) Reset 

func (m *TsoResponse) Reset()

func (*TsoResponse) Size 

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

func (*TsoResponse) String 

func (m *TsoResponse) String() string

func (*TsoResponse) Unmarshal 

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

func (*TsoResponse) XXX_DiscardUnknown 

func (m *TsoResponse) XXX_DiscardUnknown()

func (*TsoResponse) XXX_Marshal 

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

func (*TsoResponse) XXX_Merge 

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

func (*TsoResponse) XXX_Size 

func (m *TsoResponse) XXX_Size() int

func (*TsoResponse) XXX_Unmarshal 

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

type UpdateType 

type UpdateType int32
const (
	LeaseHolderIDUpdate UpdateType = 0
	TruncateLSNUpdate   UpdateType = 1
	UserEntryUpdate     UpdateType = 2
	TSOUpdate           UpdateType = 3
)

func (UpdateType) EnumDescriptor 

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

func (UpdateType) String 

func (x UpdateType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.