metadata

package
v1.0.0-rc1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CNRole_name = map[int32]string{
	0: "TP",
	1: "AP",
}
View Source 
var CNRole_value = map[string]int32{
	"TP": 0,
	"AP": 1,
}
View Source 
var ServiceType_name = map[int32]string{
	0: "CN",
	1: "TN",
	2: "LOG",
	3: "PROXY",
}
View Source 
var ServiceType_value = map[string]int32{
	"CN":    0,
	"TN":    1,
	"LOG":   2,
	"PROXY": 3,
}
View Source 
var WorkState_name = map[int32]string{
	0: "Unknown",
	1: "Working",
	2: "Draining",
	3: "Drained",
}
View Source 
var WorkState_value = map[string]int32{
	"Unknown":  0,
	"Working":  1,
	"Draining": 2,
	"Drained":  3,
}

Functions

func ToTitle added in v1.0.0 

func ToTitle(s string) string

ToTitle converts the state string to title-like string.

func ValidStateString added in v1.0.0 

func ValidStateString(s string) bool

ValidStateString returns true if the state string is valid.

Types

type CNRole added in v0.6.0 

type CNRole int32

CNRole cn node role 

const (
	// TP tp node
	CNRole_TP CNRole = 0
	// AP ap node
	CNRole_AP CNRole = 1
)

func MustParseCNRole added in v0.6.0 

func MustParseCNRole(role string) CNRole

MustParseCNRole parse CN Role from role string

func (CNRole) EnumDescriptor added in v0.6.0 

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

func (CNRole) String added in v0.6.0 

func (x CNRole) String() string

type CNService added in v0.8.0 

type CNService struct {
	// ServiceID service ID
	ServiceID string `protobuf:"bytes,1,opt,name=ServiceID,proto3" json:"ServiceID,omitempty"`
	// LockServiceAddress is used to provide lock service
	LockServiceAddress string `protobuf:"bytes,2,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	// PipelineServiceAddress is used to provide distributed pipeline service
	PipelineServiceAddress string `protobuf:"bytes,3,opt,name=PipelineServiceAddress,proto3" json:"PipelineServiceAddress,omitempty"`
	// SQLAddress is used to provide SQL input.
	SQLAddress string `protobuf:"bytes,4,opt,name=SQLAddress,proto3" json:"SQLAddress,omitempty"`
	// CtlAddress is used to handle ctl request.
	CtlAddress string `protobuf:"bytes,5,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	// Labels are labels on CN service.
	Labels map[string]LabelList `` /* 143-byte string literal not displayed */
	// WorkState is the work state of CN service.
	WorkState WorkState `protobuf:"varint,7,opt,name=WorkState,proto3,enum=metadata.WorkState" json:"WorkState,omitempty"`
	// QueryAddress is the address of queryservice.QueryService.
	QueryAddress         string   `protobuf:"bytes,8,opt,name=QueryAddress,proto3" json:"QueryAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CNService cn service metadata

func (CNService) DebugString added in v0.8.0 

func (m CNService) DebugString() string

func (*CNService) Descriptor added in v0.8.0 

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

func (*CNService) GetCtlAddress added in v0.8.0 

func (m *CNService) GetCtlAddress() string

func (*CNService) GetLabels added in v0.8.0 

func (m *CNService) GetLabels() map[string]LabelList

func (*CNService) GetLockServiceAddress added in v0.8.0 

func (m *CNService) GetLockServiceAddress() string

func (*CNService) GetPipelineServiceAddress added in v0.8.0 

func (m *CNService) GetPipelineServiceAddress() string

func (*CNService) GetQueryAddress added in v1.0.0 

func (m *CNService) GetQueryAddress() string

func (*CNService) GetSQLAddress added in v0.8.0 

func (m *CNService) GetSQLAddress() string

func (*CNService) GetServiceID added in v0.8.0 

func (m *CNService) GetServiceID() string

func (*CNService) GetWorkState added in v1.0.0 

func (m *CNService) GetWorkState() WorkState

func (*CNService) Marshal added in v0.8.0 

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

func (*CNService) MarshalTo added in v0.8.0 

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

func (*CNService) MarshalToSizedBuffer added in v0.8.0 

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

func (*CNService) ProtoMessage added in v0.8.0 

func (*CNService) ProtoMessage()

func (*CNService) Reset added in v0.8.0 

func (m *CNService) Reset()

func (*CNService) Size added in v0.8.0 

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

func (*CNService) String added in v0.8.0 

func (m *CNService) String() string

func (*CNService) Unmarshal added in v0.8.0 

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

func (*CNService) XXX_DiscardUnknown added in v0.8.0 

func (m *CNService) XXX_DiscardUnknown()

func (*CNService) XXX_Marshal added in v0.8.0 

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

func (*CNService) XXX_Merge added in v0.8.0 

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

func (*CNService) XXX_Size added in v0.8.0 

func (m *CNService) XXX_Size() int

func (*CNService) XXX_Unmarshal added in v0.8.0 

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

type CNStore added in v0.6.0 

type CNStore struct {
	// UUID CNStore uuid id
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Role CN role
	Role                 CNRole   `protobuf:"varint,2,opt,name=Role,proto3,enum=metadata.CNRole" json:"Role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CNStore cn store metadata

func (CNStore) DebugString added in v0.6.0 

func (m CNStore) DebugString() string

DebugString returns debug string

func (*CNStore) Descriptor added in v0.6.0 

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

func (*CNStore) GetRole added in v0.6.0 

func (m *CNStore) GetRole() CNRole

func (*CNStore) GetUUID added in v0.6.0 

func (m *CNStore) GetUUID() string

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 LabelList added in v0.8.0 

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

LabelList defines the labels on CN store.

func (*LabelList) Descriptor added in v0.8.0 

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

func (*LabelList) GetLabels added in v0.8.0 

func (m *LabelList) GetLabels() []string

func (*LabelList) Marshal added in v0.8.0 

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

func (*LabelList) MarshalTo added in v0.8.0 

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

func (*LabelList) MarshalToSizedBuffer added in v0.8.0 

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

func (*LabelList) ProtoMessage added in v0.8.0 

func (*LabelList) ProtoMessage()

func (*LabelList) Reset added in v0.8.0 

func (m *LabelList) Reset()

func (*LabelList) Size added in v0.8.0 

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

func (*LabelList) String added in v0.8.0 

func (m *LabelList) String() string

func (*LabelList) Unmarshal added in v0.8.0 

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

func (*LabelList) XXX_DiscardUnknown added in v0.8.0 

func (m *LabelList) XXX_DiscardUnknown()

func (*LabelList) XXX_Marshal added in v0.8.0 

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

func (*LabelList) XXX_Merge added in v0.8.0 

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

func (*LabelList) XXX_Size added in v0.8.0 

func (m *LabelList) XXX_Size() int

func (*LabelList) XXX_Unmarshal added in v0.8.0 

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

type LogShard added in v0.6.0 

type LogShard struct {
	// LogShard extends LogShardRecord
	LogShardRecord `protobuf:"bytes,1,opt,name=LogShardRecord,proto3,embedded=LogShardRecord" json:"LogShardRecord"`
	// ReplicaID is the replica ID of the replica running on the LogStore.
	ReplicaID            uint64   `protobuf:"varint,2,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogShard

func (*LogShard) Descriptor added in v0.6.0 

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

func (*LogShard) GetReplicaID added in v0.6.0 

func (m *LogShard) GetReplicaID() uint64

func (*LogShard) Marshal added in v0.6.0 

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

func (*LogShard) MarshalTo added in v0.6.0 

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

func (*LogShard) MarshalToSizedBuffer added in v0.6.0 

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

func (*LogShard) ProtoMessage added in v0.6.0 

func (*LogShard) ProtoMessage()

func (*LogShard) Reset added in v0.6.0 

func (m *LogShard) Reset()

func (*LogShard) Size added in v0.6.0 

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

func (*LogShard) String added in v0.6.0 

func (m *LogShard) String() string

func (*LogShard) Unmarshal added in v0.6.0 

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

func (*LogShard) XXX_DiscardUnknown added in v0.6.0 

func (m *LogShard) XXX_DiscardUnknown()

func (*LogShard) XXX_Marshal added in v0.6.0 

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

func (*LogShard) XXX_Merge added in v0.6.0 

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

func (*LogShard) XXX_Size added in v0.6.0 

func (m *LogShard) XXX_Size() int

func (*LogShard) XXX_Unmarshal added in v0.6.0 

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

type LogShardRecord 

type LogShardRecord struct {
	// ShardID is the id of the Log Shard.
	ShardID uint64 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	// NumberOfReplicas is the number of replicas in the shard.
	NumberOfReplicas     uint64   `protobuf:"varint,2,opt,name=NumberOfReplicas,proto3" json:"NumberOfReplicas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

LogShardRecord is Log Shard Metadata describing what is a Log shard. It is internally used by the HAKeeper to maintain how many Log shards are available in the system.

func (*LogShardRecord) Descriptor 

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

func (*LogShardRecord) GetNumberOfReplicas 

func (m *LogShardRecord) GetNumberOfReplicas() uint64

func (*LogShardRecord) GetShardID 

func (m *LogShardRecord) GetShardID() uint64

func (*LogShardRecord) Marshal 

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

func (*LogShardRecord) MarshalTo 

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

func (*LogShardRecord) MarshalToSizedBuffer 

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

func (*LogShardRecord) ProtoMessage 

func (*LogShardRecord) ProtoMessage()

func (*LogShardRecord) Reset 

func (m *LogShardRecord) Reset()

func (*LogShardRecord) Size 

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

func (*LogShardRecord) String 

func (m *LogShardRecord) String() string

func (*LogShardRecord) Unmarshal 

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

func (*LogShardRecord) XXX_DiscardUnknown 

func (m *LogShardRecord) XXX_DiscardUnknown()

func (*LogShardRecord) XXX_Marshal 

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

func (*LogShardRecord) XXX_Merge 

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

func (*LogShardRecord) XXX_Size 

func (m *LogShardRecord) XXX_Size() int

func (*LogShardRecord) XXX_Unmarshal 

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

type LogStore added in v0.6.0 

type LogStore struct {
	// UUID is the id of the Log store.
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Shards is for Log shards metadata.
	Shards               []LogShard `protobuf:"bytes,2,rep,name=Shards,proto3" json:"Shards"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

LogStore is for the metadata for Log store.

func (*LogStore) Descriptor added in v0.6.0 

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

func (*LogStore) GetShards added in v0.6.0 

func (m *LogStore) GetShards() []LogShard

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 ServiceType added in v0.7.0 

type ServiceType int32

ServiceType service type 

const (
	// CN cn service
	ServiceType_CN ServiceType = 0
	// TN tn service
	ServiceType_TN ServiceType = 1
	// LOG log service
	ServiceType_LOG ServiceType = 2
	// Proxy proxy service
	ServiceType_PROXY ServiceType = 3
)

func (ServiceType) EnumDescriptor added in v0.7.0 

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

func (ServiceType) String added in v0.7.0 

func (x ServiceType) String() string

type TNService added in v1.0.0 

type TNService struct {
	// ServiceID service ID
	ServiceID string `protobuf:"bytes,1,opt,name=ServiceID,proto3" json:"ServiceID,omitempty"`
	// TxnServiceAddress is used to provide txn service
	TxnServiceAddress string `protobuf:"bytes,2,opt,name=TxnServiceAddress,proto3" json:"TxnServiceAddress,omitempty"`
	// LogTailServiceAddress is used to provide logtail push service
	LogTailServiceAddress string `protobuf:"bytes,3,opt,name=LogTailServiceAddress,proto3" json:"LogTailServiceAddress,omitempty"`
	// LockServiceAddress lock service address for lock table allocator
	LockServiceAddress string `protobuf:"bytes,4,opt,name=LockServiceAddress,proto3" json:"LockServiceAddress,omitempty"`
	// CtlAddress is used to handle ctl request.
	CtlAddress string `protobuf:"bytes,5,opt,name=CtlAddress,proto3" json:"CtlAddress,omitempty"`
	// Shards TN shards on service
	Shards []TNShard `protobuf:"bytes,6,rep,name=Shards,proto3" json:"Shards"`
	// Labels labels on service
	Labels               map[string]LabelList `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

TNService tn service metadata

func (TNService) DebugString added in v1.0.0 

func (m TNService) DebugString() string

func (*TNService) Descriptor added in v1.0.0 

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

func (*TNService) GetCtlAddress added in v1.0.0 

func (m *TNService) GetCtlAddress() string

func (*TNService) GetLabels added in v1.0.0 

func (m *TNService) GetLabels() map[string]LabelList

func (*TNService) GetLockServiceAddress added in v1.0.0 

func (m *TNService) GetLockServiceAddress() string

func (*TNService) GetLogTailServiceAddress added in v1.0.0 

func (m *TNService) GetLogTailServiceAddress() string

func (*TNService) GetServiceID added in v1.0.0 

func (m *TNService) GetServiceID() string

func (*TNService) GetShards added in v1.0.0 

func (m *TNService) GetShards() []TNShard

func (*TNService) GetTxnServiceAddress added in v1.0.0 

func (m *TNService) GetTxnServiceAddress() string

func (*TNService) Marshal added in v1.0.0 

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

func (*TNService) MarshalTo added in v1.0.0 

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

func (*TNService) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNService) ProtoMessage added in v1.0.0 

func (*TNService) ProtoMessage()

func (*TNService) Reset added in v1.0.0 

func (m *TNService) Reset()

func (*TNService) Size added in v1.0.0 

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

func (*TNService) String added in v1.0.0 

func (m *TNService) String() string

func (*TNService) Unmarshal added in v1.0.0 

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

func (*TNService) XXX_DiscardUnknown added in v1.0.0 

func (m *TNService) XXX_DiscardUnknown()

func (*TNService) XXX_Marshal added in v1.0.0 

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

func (*TNService) XXX_Merge added in v1.0.0 

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

func (*TNService) XXX_Size added in v1.0.0 

func (m *TNService) XXX_Size() int

func (*TNService) XXX_Unmarshal added in v1.0.0 

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

type TNShard added in v1.0.0 

type TNShard struct {
	// TNShard extends TNShardRecord
	TNShardRecord `protobuf:"bytes,1,opt,name=TNShardRecord,proto3,embedded=TNShardRecord" json:"TNShardRecord"`
	// ReplicaID only one replica for one TN. The ReplicaID is specified at
	// the time the TN is created. TN restart ReplicaID will not change, when
	// a TN is migrated to another node, the ReplicaID will be reset.
	ReplicaID uint64 `protobuf:"varint,2,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	// Address is TN's external service address.
	Address              string   `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNShard

func (TNShard) DebugString added in v1.0.0 

func (m TNShard) DebugString() string

DebugString returns debug string

func (*TNShard) Descriptor added in v1.0.0 

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

func (TNShard) Equal added in v1.0.0 

func (m TNShard) Equal(tn TNShard) bool

Equal returns true if DNShard is same

func (*TNShard) GetAddress added in v1.0.0 

func (m *TNShard) GetAddress() string

func (*TNShard) GetReplicaID added in v1.0.0 

func (m *TNShard) GetReplicaID() uint64

func (TNShard) IsEmpty added in v1.0.0 

func (m TNShard) IsEmpty() bool

IsEmpty return true if is a empty DNShard

func (*TNShard) Marshal added in v1.0.0 

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

func (*TNShard) MarshalTo added in v1.0.0 

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

func (*TNShard) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNShard) ProtoMessage added in v1.0.0 

func (*TNShard) ProtoMessage()

func (*TNShard) Reset added in v1.0.0 

func (m *TNShard) Reset()

func (*TNShard) Size added in v1.0.0 

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

func (*TNShard) String added in v1.0.0 

func (m *TNShard) String() string

func (*TNShard) Unmarshal added in v1.0.0 

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

func (*TNShard) XXX_DiscardUnknown added in v1.0.0 

func (m *TNShard) XXX_DiscardUnknown()

func (*TNShard) XXX_Marshal added in v1.0.0 

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

func (*TNShard) XXX_Merge added in v1.0.0 

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

func (*TNShard) XXX_Size added in v1.0.0 

func (m *TNShard) XXX_Size() int

func (*TNShard) XXX_Unmarshal added in v1.0.0 

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

type TNShardRecord added in v1.0.0 

type TNShardRecord struct {
	// ShardID the id of the TN shard.
	ShardID uint64 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	// LogShardID a TN corresponds to a unique Shard of LogService.
	LogShardID           uint64   `protobuf:"varint,2,opt,name=LogShardID,proto3" json:"LogShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TNShardRecord is TN shard metadata describing what is a TN shard. It is internally used by HAKeeper to maintain how many TNs available in the system.

func (*TNShardRecord) Descriptor added in v1.0.0 

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

func (*TNShardRecord) GetLogShardID added in v1.0.0 

func (m *TNShardRecord) GetLogShardID() uint64

func (*TNShardRecord) GetShardID added in v1.0.0 

func (m *TNShardRecord) GetShardID() uint64

func (*TNShardRecord) Marshal added in v1.0.0 

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

func (*TNShardRecord) MarshalTo added in v1.0.0 

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

func (*TNShardRecord) MarshalToSizedBuffer added in v1.0.0 

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

func (*TNShardRecord) ProtoMessage added in v1.0.0 

func (*TNShardRecord) ProtoMessage()

func (*TNShardRecord) Reset added in v1.0.0 

func (m *TNShardRecord) Reset()

func (*TNShardRecord) Size added in v1.0.0 

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

func (*TNShardRecord) String added in v1.0.0 

func (m *TNShardRecord) String() string

func (*TNShardRecord) Unmarshal added in v1.0.0 

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

func (*TNShardRecord) XXX_DiscardUnknown added in v1.0.0 

func (m *TNShardRecord) XXX_DiscardUnknown()

func (*TNShardRecord) XXX_Marshal added in v1.0.0 

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

func (*TNShardRecord) XXX_Merge added in v1.0.0 

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

func (*TNShardRecord) XXX_Size added in v1.0.0 

func (m *TNShardRecord) XXX_Size() int

func (*TNShardRecord) XXX_Unmarshal added in v1.0.0 

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

type TNStore added in v1.0.0 

type TNStore struct {
	// UUID TNStore uuid id
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// Shards TNShards
	Shards               []TNShard `protobuf:"bytes,2,rep,name=Shards,proto3" json:"Shards"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

TNStore TN store metadata

func (TNStore) DebugString added in v1.0.0 

func (m TNStore) DebugString() string

DebugString returns debug string

func (*TNStore) Descriptor added in v1.0.0 

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

func (*TNStore) GetShards added in v1.0.0 

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

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 WorkState added in v1.0.0 

type WorkState int32

WorkState is the work state of CN service. 

const (
	WorkState_Unknown  WorkState = 0
	WorkState_Working  WorkState = 1
	WorkState_Draining WorkState = 2
	WorkState_Drained  WorkState = 3
)

func (WorkState) EnumDescriptor added in v1.0.0 

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

func (WorkState) String added in v1.0.0 

func (x WorkState) 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.