Documentation ¶
Index ¶
- Variables
- type CNRole
- type CNService
- func (m CNService) DebugString() string
- func (*CNService) Descriptor() ([]byte, []int)
- func (m *CNService) GetCtlAddress() string
- func (m *CNService) GetLabels() map[string]LabelList
- func (m *CNService) GetLockServiceAddress() string
- func (m *CNService) GetPipelineServiceAddress() string
- func (m *CNService) GetSQLAddress() string
- func (m *CNService) GetServiceID() string
- func (m *CNService) Marshal() (dAtA []byte, err error)
- func (m *CNService) MarshalTo(dAtA []byte) (int, error)
- func (m *CNService) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CNService) ProtoMessage()
- func (m *CNService) Reset()
- func (m *CNService) Size() (n int)
- func (m *CNService) String() string
- func (m *CNService) Unmarshal(dAtA []byte) error
- func (m *CNService) XXX_DiscardUnknown()
- func (m *CNService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CNService) XXX_Merge(src proto.Message)
- func (m *CNService) XXX_Size() int
- func (m *CNService) XXX_Unmarshal(b []byte) error
- type CNStore
- func (m CNStore) DebugString() string
- func (*CNStore) Descriptor() ([]byte, []int)
- func (m *CNStore) GetRole() CNRole
- func (m *CNStore) GetUUID() string
- func (m *CNStore) Marshal() (dAtA []byte, err error)
- func (m *CNStore) MarshalTo(dAtA []byte) (int, error)
- func (m *CNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CNStore) ProtoMessage()
- func (m *CNStore) Reset()
- func (m *CNStore) Size() (n int)
- func (m *CNStore) String() string
- func (m *CNStore) Unmarshal(dAtA []byte) error
- func (m *CNStore) XXX_DiscardUnknown()
- func (m *CNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CNStore) XXX_Merge(src proto.Message)
- func (m *CNStore) XXX_Size() int
- func (m *CNStore) XXX_Unmarshal(b []byte) error
- type DNService
- func (m DNService) DebugString() string
- func (*DNService) Descriptor() ([]byte, []int)
- func (m *DNService) GetCtlAddress() string
- func (m *DNService) GetLabels() map[string]LabelList
- func (m *DNService) GetLockServiceAddress() string
- func (m *DNService) GetLogTailServiceAddress() string
- func (m *DNService) GetServiceID() string
- func (m *DNService) GetShards() []DNShard
- func (m *DNService) GetTxnServiceAddress() string
- func (m *DNService) Marshal() (dAtA []byte, err error)
- func (m *DNService) MarshalTo(dAtA []byte) (int, error)
- func (m *DNService) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DNService) ProtoMessage()
- func (m *DNService) Reset()
- func (m *DNService) Size() (n int)
- func (m *DNService) String() string
- func (m *DNService) Unmarshal(dAtA []byte) error
- func (m *DNService) XXX_DiscardUnknown()
- func (m *DNService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DNService) XXX_Merge(src proto.Message)
- func (m *DNService) XXX_Size() int
- func (m *DNService) XXX_Unmarshal(b []byte) error
- type DNShard
- func (m DNShard) DebugString() string
- func (*DNShard) Descriptor() ([]byte, []int)
- func (m DNShard) Equal(dn DNShard) bool
- func (m *DNShard) GetAddress() string
- func (m *DNShard) GetReplicaID() uint64
- func (m DNShard) IsEmpty() bool
- func (m *DNShard) Marshal() (dAtA []byte, err error)
- func (m *DNShard) MarshalTo(dAtA []byte) (int, error)
- func (m *DNShard) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DNShard) ProtoMessage()
- func (m *DNShard) Reset()
- func (m *DNShard) Size() (n int)
- func (m *DNShard) String() string
- func (m *DNShard) Unmarshal(dAtA []byte) error
- func (m *DNShard) XXX_DiscardUnknown()
- func (m *DNShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DNShard) XXX_Merge(src proto.Message)
- func (m *DNShard) XXX_Size() int
- func (m *DNShard) XXX_Unmarshal(b []byte) error
- type DNShardRecord
- func (*DNShardRecord) Descriptor() ([]byte, []int)
- func (m *DNShardRecord) GetLogShardID() uint64
- func (m *DNShardRecord) GetShardID() uint64
- func (m *DNShardRecord) Marshal() (dAtA []byte, err error)
- func (m *DNShardRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *DNShardRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DNShardRecord) ProtoMessage()
- func (m *DNShardRecord) Reset()
- func (m *DNShardRecord) Size() (n int)
- func (m *DNShardRecord) String() string
- func (m *DNShardRecord) Unmarshal(dAtA []byte) error
- func (m *DNShardRecord) XXX_DiscardUnknown()
- func (m *DNShardRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DNShardRecord) XXX_Merge(src proto.Message)
- func (m *DNShardRecord) XXX_Size() int
- func (m *DNShardRecord) XXX_Unmarshal(b []byte) error
- type DNStore
- func (m DNStore) DebugString() string
- func (*DNStore) Descriptor() ([]byte, []int)
- func (m *DNStore) GetShards() []DNShard
- func (m *DNStore) GetUUID() string
- func (m *DNStore) Marshal() (dAtA []byte, err error)
- func (m *DNStore) MarshalTo(dAtA []byte) (int, error)
- func (m *DNStore) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DNStore) ProtoMessage()
- func (m *DNStore) Reset()
- func (m *DNStore) Size() (n int)
- func (m *DNStore) String() string
- func (m *DNStore) Unmarshal(dAtA []byte) error
- func (m *DNStore) XXX_DiscardUnknown()
- func (m *DNStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DNStore) XXX_Merge(src proto.Message)
- func (m *DNStore) XXX_Size() int
- func (m *DNStore) XXX_Unmarshal(b []byte) error
- type LabelList
- func (*LabelList) Descriptor() ([]byte, []int)
- func (m *LabelList) GetLabels() []string
- func (m *LabelList) Marshal() (dAtA []byte, err error)
- func (m *LabelList) MarshalTo(dAtA []byte) (int, error)
- func (m *LabelList) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LabelList) ProtoMessage()
- func (m *LabelList) Reset()
- func (m *LabelList) Size() (n int)
- func (m *LabelList) String() string
- func (m *LabelList) Unmarshal(dAtA []byte) error
- func (m *LabelList) XXX_DiscardUnknown()
- func (m *LabelList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LabelList) XXX_Merge(src proto.Message)
- func (m *LabelList) XXX_Size() int
- func (m *LabelList) XXX_Unmarshal(b []byte) error
- type LogShard
- func (*LogShard) Descriptor() ([]byte, []int)
- func (m *LogShard) GetReplicaID() uint64
- func (m *LogShard) Marshal() (dAtA []byte, err error)
- func (m *LogShard) MarshalTo(dAtA []byte) (int, error)
- func (m *LogShard) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogShard) ProtoMessage()
- func (m *LogShard) Reset()
- func (m *LogShard) Size() (n int)
- func (m *LogShard) String() string
- func (m *LogShard) Unmarshal(dAtA []byte) error
- func (m *LogShard) XXX_DiscardUnknown()
- func (m *LogShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogShard) XXX_Merge(src proto.Message)
- func (m *LogShard) XXX_Size() int
- func (m *LogShard) XXX_Unmarshal(b []byte) error
- type LogShardRecord
- func (*LogShardRecord) Descriptor() ([]byte, []int)
- func (m *LogShardRecord) GetNumberOfReplicas() uint64
- func (m *LogShardRecord) GetShardID() uint64
- func (m *LogShardRecord) Marshal() (dAtA []byte, err error)
- func (m *LogShardRecord) MarshalTo(dAtA []byte) (int, error)
- func (m *LogShardRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogShardRecord) ProtoMessage()
- func (m *LogShardRecord) Reset()
- func (m *LogShardRecord) Size() (n int)
- func (m *LogShardRecord) String() string
- func (m *LogShardRecord) Unmarshal(dAtA []byte) error
- func (m *LogShardRecord) XXX_DiscardUnknown()
- func (m *LogShardRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogShardRecord) XXX_Merge(src proto.Message)
- func (m *LogShardRecord) XXX_Size() int
- func (m *LogShardRecord) XXX_Unmarshal(b []byte) error
- type LogStore
- func (*LogStore) Descriptor() ([]byte, []int)
- func (m *LogStore) GetShards() []LogShard
- func (m *LogStore) GetUUID() string
- func (m *LogStore) Marshal() (dAtA []byte, err error)
- func (m *LogStore) MarshalTo(dAtA []byte) (int, error)
- func (m *LogStore) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogStore) ProtoMessage()
- func (m *LogStore) Reset()
- func (m *LogStore) Size() (n int)
- func (m *LogStore) String() string
- func (m *LogStore) Unmarshal(dAtA []byte) error
- func (m *LogStore) XXX_DiscardUnknown()
- func (m *LogStore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogStore) XXX_Merge(src proto.Message)
- func (m *LogStore) XXX_Size() int
- func (m *LogStore) XXX_Unmarshal(b []byte) error
- type ServiceType
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMetadata = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetadata = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group") )
var CNRole_name = map[int32]string{
0: "TP",
1: "AP",
}
var CNRole_value = map[string]int32{
"TP": 0,
"AP": 1,
}
var ServiceType_name = map[int32]string{
0: "CN",
1: "DN",
2: "LOG",
3: "PROXY",
}
var ServiceType_value = map[string]int32{
"CN": 0,
"DN": 1,
"LOG": 2,
"PROXY": 3,
}
Functions ¶
This section is empty.
Types ¶
type CNRole ¶ added in v0.6.0
type CNRole int32
CNRole cn node role
func MustParseCNRole ¶ added in v0.6.0
MustParseCNRole parse CN Role from role string
func (CNRole) EnumDescriptor ¶ added in v0.6.0
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 lables on service Labels map[string]LabelList `` /* 143-byte string literal not displayed */ 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 (*CNService) Descriptor ¶ added in v0.8.0
func (*CNService) GetCtlAddress ¶ added in v0.8.0
func (*CNService) GetLockServiceAddress ¶ added in v0.8.0
func (*CNService) GetPipelineServiceAddress ¶ added in v0.8.0
func (*CNService) GetSQLAddress ¶ added in v0.8.0
func (*CNService) GetServiceID ¶ added in v0.8.0
func (*CNService) MarshalToSizedBuffer ¶ added in v0.8.0
func (*CNService) ProtoMessage ¶ added in v0.8.0
func (*CNService) ProtoMessage()
func (*CNService) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *CNService) XXX_DiscardUnknown()
func (*CNService) XXX_Marshal ¶ added in v0.8.0
func (*CNService) XXX_Unmarshal ¶ added in v0.8.0
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
DebugString returns debug string
func (*CNStore) Descriptor ¶ added in v0.6.0
func (*CNStore) MarshalToSizedBuffer ¶ added in v0.6.0
func (*CNStore) ProtoMessage ¶ added in v0.6.0
func (*CNStore) ProtoMessage()
func (*CNStore) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *CNStore) XXX_DiscardUnknown()
func (*CNStore) XXX_Marshal ¶ added in v0.6.0
func (*CNStore) XXX_Unmarshal ¶ added in v0.6.0
type DNService ¶ added in v0.8.0
type DNService 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 DN shards on service Shards []DNShard `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:"-"` }
DNService dn service metadata
func (DNService) DebugString ¶ added in v0.8.0
func (*DNService) Descriptor ¶ added in v0.8.0
func (*DNService) GetCtlAddress ¶ added in v0.8.0
func (*DNService) GetLockServiceAddress ¶ added in v0.8.0
func (*DNService) GetLogTailServiceAddress ¶ added in v0.8.0
func (*DNService) GetServiceID ¶ added in v0.8.0
func (*DNService) GetTxnServiceAddress ¶ added in v0.8.0
func (*DNService) MarshalToSizedBuffer ¶ added in v0.8.0
func (*DNService) ProtoMessage ¶ added in v0.8.0
func (*DNService) ProtoMessage()
func (*DNService) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *DNService) XXX_DiscardUnknown()
func (*DNService) XXX_Marshal ¶ added in v0.8.0
func (*DNService) XXX_Unmarshal ¶ added in v0.8.0
type DNShard ¶
type DNShard struct { // DNShard extends DNShardRecord DNShardRecord `protobuf:"bytes,1,opt,name=DNShardRecord,proto3,embedded=DNShardRecord" json:"DNShardRecord"` // ReplicaID only one replica for one DN. The ReplicaID is specified at // the time the DN is created. DN restart ReplicaID will not change, when // a DN is migrated to another node, the ReplicaID will be reset. ReplicaID uint64 `protobuf:"varint,2,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"` // Address is DN'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:"-"` }
DNShard
func (*DNShard) Descriptor ¶
func (*DNShard) GetAddress ¶
func (*DNShard) GetReplicaID ¶
func (*DNShard) MarshalToSizedBuffer ¶
func (*DNShard) ProtoMessage ¶
func (*DNShard) ProtoMessage()
func (*DNShard) XXX_DiscardUnknown ¶
func (m *DNShard) XXX_DiscardUnknown()
func (*DNShard) XXX_Marshal ¶
func (*DNShard) XXX_Unmarshal ¶
type DNShardRecord ¶
type DNShardRecord struct { // ShardID the id of the DN shard. ShardID uint64 `protobuf:"varint,1,opt,name=ShardID,proto3" json:"ShardID,omitempty"` // LogShardID a DN 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:"-"` }
DNShardRecord is DN shard metadata describing what is a DN shard. It is internally used by HAKeeper to maintain how many DNs available in the system.
func (*DNShardRecord) Descriptor ¶
func (*DNShardRecord) Descriptor() ([]byte, []int)
func (*DNShardRecord) GetLogShardID ¶
func (m *DNShardRecord) GetLogShardID() uint64
func (*DNShardRecord) GetShardID ¶
func (m *DNShardRecord) GetShardID() uint64
func (*DNShardRecord) Marshal ¶
func (m *DNShardRecord) Marshal() (dAtA []byte, err error)
func (*DNShardRecord) MarshalToSizedBuffer ¶
func (m *DNShardRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DNShardRecord) ProtoMessage ¶
func (*DNShardRecord) ProtoMessage()
func (*DNShardRecord) Reset ¶
func (m *DNShardRecord) Reset()
func (*DNShardRecord) Size ¶
func (m *DNShardRecord) Size() (n int)
func (*DNShardRecord) String ¶
func (m *DNShardRecord) String() string
func (*DNShardRecord) Unmarshal ¶
func (m *DNShardRecord) Unmarshal(dAtA []byte) error
func (*DNShardRecord) XXX_DiscardUnknown ¶
func (m *DNShardRecord) XXX_DiscardUnknown()
func (*DNShardRecord) XXX_Marshal ¶
func (m *DNShardRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DNShardRecord) XXX_Merge ¶
func (m *DNShardRecord) XXX_Merge(src proto.Message)
func (*DNShardRecord) XXX_Size ¶
func (m *DNShardRecord) XXX_Size() int
func (*DNShardRecord) XXX_Unmarshal ¶
func (m *DNShardRecord) XXX_Unmarshal(b []byte) error
type DNStore ¶ added in v0.6.0
type DNStore struct { // UUID DNStore uuid id UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"` // Shards DNShards Shards []DNShard `protobuf:"bytes,2,rep,name=Shards,proto3" json:"Shards"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DNStore DN store metadata
func (DNStore) DebugString ¶ added in v0.6.0
DebugString returns debug string
func (*DNStore) Descriptor ¶ added in v0.6.0
func (*DNStore) MarshalToSizedBuffer ¶ added in v0.6.0
func (*DNStore) ProtoMessage ¶ added in v0.6.0
func (*DNStore) ProtoMessage()
func (*DNStore) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *DNStore) XXX_DiscardUnknown()
func (*DNStore) XXX_Marshal ¶ added in v0.6.0
func (*DNStore) XXX_Unmarshal ¶ added in v0.6.0
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) MarshalToSizedBuffer ¶ added in v0.8.0
func (*LabelList) ProtoMessage ¶ added in v0.8.0
func (*LabelList) ProtoMessage()
func (*LabelList) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *LabelList) XXX_DiscardUnknown()
func (*LabelList) XXX_Marshal ¶ added in v0.8.0
func (*LabelList) XXX_Unmarshal ¶ added in v0.8.0
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) GetReplicaID ¶ added in v0.6.0
func (*LogShard) MarshalToSizedBuffer ¶ added in v0.6.0
func (*LogShard) ProtoMessage ¶ added in v0.6.0
func (*LogShard) ProtoMessage()
func (*LogShard) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *LogShard) XXX_DiscardUnknown()
func (*LogShard) XXX_Marshal ¶ added in v0.6.0
func (*LogShard) XXX_Unmarshal ¶ added in v0.6.0
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) 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) MarshalToSizedBuffer ¶ added in v0.6.0
func (*LogStore) ProtoMessage ¶ added in v0.6.0
func (*LogStore) ProtoMessage()
func (*LogStore) XXX_DiscardUnknown ¶ added in v0.6.0
func (m *LogStore) XXX_DiscardUnknown()
func (*LogStore) XXX_Marshal ¶ added in v0.6.0
func (*LogStore) XXX_Unmarshal ¶ added in v0.6.0
type ServiceType ¶ added in v0.7.0
type ServiceType int32
ServiceType service type
const ( // CN cn service ServiceType_CN ServiceType = 0 // DN dn service ServiceType_DN 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