shard

package
v0.0.0-debug-20260702 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthShard        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowShard          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupShard = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CNState_name = map[int32]string{
	0: "Up",
	1: "Pause",
	2: "Down",
}
View Source 
var CNState_value = map[string]int32{
	"Up":    0,
	"Pause": 1,
	"Down":  2,
}
View Source 
var Method_name = map[int32]string{
	0: "Heartbeat",
	1: "CreateShards",
	2: "DeleteShards",
	3: "GetShards",
	4: "ShardRead",
	5: "PauseCN",
	6: "GetCNReplicas",
}
View Source 
var Method_value = map[string]int32{
	"Heartbeat":     0,
	"CreateShards":  1,
	"DeleteShards":  2,
	"GetShards":     3,
	"ShardRead":     4,
	"PauseCN":       5,
	"GetCNReplicas": 6,
}
View Source 
var OpType_name = map[int32]string{
	0: "AddReplica",
	1: "DeleteReplica",
	2: "DeleteAll",
	3: "CreateTable",
}
View Source 
var OpType_value = map[string]int32{
	"AddReplica":    0,
	"DeleteReplica": 1,
	"DeleteAll":     2,
	"CreateTable":   3,
}
View Source 
var Policy_name = map[int32]string{
	0: "None",
	1: "Partition",
	2: "Hash",
}
View Source 
var Policy_value = map[string]int32{
	"None":      0,
	"Partition": 1,
	"Hash":      2,
}
View Source 
var ReplicaState_name = map[int32]string{
	0: "Allocating",
	1: "Allocated",
	2: "Running",
	3: "Moving",
	4: "Tombstone",
}
View Source 
var ReplicaState_value = map[string]int32{
	"Allocating": 0,
	"Allocated":  1,
	"Running":    2,
	"Moving":     3,
	"Tombstone":  4,
}

Functions

This section is empty.

Types

type CNState 

type CNState int32
const (
	CNState_Up    CNState = 0
	CNState_Pause CNState = 1
	CNState_Down  CNState = 2
)

func (CNState) EnumDescriptor 

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

func (CNState) String 

func (x CNState) String() string

type CollectTombstonesParam 

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

func (*CollectTombstonesParam) Descriptor 

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

func (*CollectTombstonesParam) GetCollectPolicy 

func (m *CollectTombstonesParam) GetCollectPolicy() uint64

func (*CollectTombstonesParam) Marshal 

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

func (*CollectTombstonesParam) MarshalTo 

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

func (*CollectTombstonesParam) MarshalToSizedBuffer 

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

func (*CollectTombstonesParam) ProtoMessage 

func (*CollectTombstonesParam) ProtoMessage()

func (*CollectTombstonesParam) ProtoSize 

func (m *CollectTombstonesParam) ProtoSize() (n int)

func (*CollectTombstonesParam) Reset 

func (m *CollectTombstonesParam) Reset()

func (*CollectTombstonesParam) String 

func (m *CollectTombstonesParam) String() string

func (*CollectTombstonesParam) Unmarshal 

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

func (*CollectTombstonesParam) XXX_DiscardUnknown 

func (m *CollectTombstonesParam) XXX_DiscardUnknown()

func (*CollectTombstonesParam) XXX_Marshal 

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

func (*CollectTombstonesParam) XXX_Merge 

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

func (*CollectTombstonesParam) XXX_Size 

func (m *CollectTombstonesParam) XXX_Size() int

func (*CollectTombstonesParam) XXX_Unmarshal 

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

type CreateShardsRequest 

type CreateShardsRequest struct {
	ID                   uint64         `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Metadata             ShardsMetadata `protobuf:"bytes,2,opt,name=Metadata,proto3" json:"Metadata"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateShardsRequest) Descriptor 

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

func (*CreateShardsRequest) GetID 

func (m *CreateShardsRequest) GetID() uint64

func (*CreateShardsRequest) GetMetadata 

func (m *CreateShardsRequest) GetMetadata() ShardsMetadata

func (*CreateShardsRequest) Marshal 

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

func (*CreateShardsRequest) MarshalTo 

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

func (*CreateShardsRequest) MarshalToSizedBuffer 

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

func (*CreateShardsRequest) ProtoMessage 

func (*CreateShardsRequest) ProtoMessage()

func (*CreateShardsRequest) ProtoSize 

func (m *CreateShardsRequest) ProtoSize() (n int)

func (*CreateShardsRequest) Reset 

func (m *CreateShardsRequest) Reset()

func (*CreateShardsRequest) String 

func (m *CreateShardsRequest) String() string

func (*CreateShardsRequest) Unmarshal 

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

func (*CreateShardsRequest) XXX_DiscardUnknown 

func (m *CreateShardsRequest) XXX_DiscardUnknown()

func (*CreateShardsRequest) XXX_Marshal 

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

func (*CreateShardsRequest) XXX_Merge 

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

func (*CreateShardsRequest) XXX_Size 

func (m *CreateShardsRequest) XXX_Size() int

func (*CreateShardsRequest) XXX_Unmarshal 

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

type CreateShardsResponse 

type CreateShardsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardsResponse) Descriptor 

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

func (*CreateShardsResponse) Marshal 

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

func (*CreateShardsResponse) MarshalTo 

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

func (*CreateShardsResponse) MarshalToSizedBuffer 

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

func (*CreateShardsResponse) ProtoMessage 

func (*CreateShardsResponse) ProtoMessage()

func (*CreateShardsResponse) ProtoSize 

func (m *CreateShardsResponse) ProtoSize() (n int)

func (*CreateShardsResponse) Reset 

func (m *CreateShardsResponse) Reset()

func (*CreateShardsResponse) String 

func (m *CreateShardsResponse) String() string

func (*CreateShardsResponse) Unmarshal 

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

func (*CreateShardsResponse) XXX_DiscardUnknown 

func (m *CreateShardsResponse) XXX_DiscardUnknown()

func (*CreateShardsResponse) XXX_Marshal 

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

func (*CreateShardsResponse) XXX_Merge 

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

func (*CreateShardsResponse) XXX_Size 

func (m *CreateShardsResponse) XXX_Size() int

func (*CreateShardsResponse) XXX_Unmarshal 

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

type DeleteShardsRequest 

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

func (*DeleteShardsRequest) Descriptor 

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

func (*DeleteShardsRequest) GetID 

func (m *DeleteShardsRequest) GetID() uint64

func (*DeleteShardsRequest) Marshal 

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

func (*DeleteShardsRequest) MarshalTo 

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

func (*DeleteShardsRequest) MarshalToSizedBuffer 

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

func (*DeleteShardsRequest) ProtoMessage 

func (*DeleteShardsRequest) ProtoMessage()

func (*DeleteShardsRequest) ProtoSize 

func (m *DeleteShardsRequest) ProtoSize() (n int)

func (*DeleteShardsRequest) Reset 

func (m *DeleteShardsRequest) Reset()

func (*DeleteShardsRequest) String 

func (m *DeleteShardsRequest) String() string

func (*DeleteShardsRequest) Unmarshal 

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

func (*DeleteShardsRequest) XXX_DiscardUnknown 

func (m *DeleteShardsRequest) XXX_DiscardUnknown()

func (*DeleteShardsRequest) XXX_Marshal 

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

func (*DeleteShardsRequest) XXX_Merge 

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

func (*DeleteShardsRequest) XXX_Size 

func (m *DeleteShardsRequest) XXX_Size() int

func (*DeleteShardsRequest) XXX_Unmarshal 

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

type DeleteShardsResponse 

type DeleteShardsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteShardsResponse) Descriptor 

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

func (*DeleteShardsResponse) Marshal 

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

func (*DeleteShardsResponse) MarshalTo 

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

func (*DeleteShardsResponse) MarshalToSizedBuffer 

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

func (*DeleteShardsResponse) ProtoMessage 

func (*DeleteShardsResponse) ProtoMessage()

func (*DeleteShardsResponse) ProtoSize 

func (m *DeleteShardsResponse) ProtoSize() (n int)

func (*DeleteShardsResponse) Reset 

func (m *DeleteShardsResponse) Reset()

func (*DeleteShardsResponse) String 

func (m *DeleteShardsResponse) String() string

func (*DeleteShardsResponse) Unmarshal 

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

func (*DeleteShardsResponse) XXX_DiscardUnknown 

func (m *DeleteShardsResponse) XXX_DiscardUnknown()

func (*DeleteShardsResponse) XXX_Marshal 

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

func (*DeleteShardsResponse) XXX_Merge 

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

func (*DeleteShardsResponse) XXX_Size 

func (m *DeleteShardsResponse) XXX_Size() int

func (*DeleteShardsResponse) XXX_Unmarshal 

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

type GetCNReplicasRequest 

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

func (*GetCNReplicasRequest) Descriptor 

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

func (*GetCNReplicasRequest) GetID 

func (m *GetCNReplicasRequest) GetID() string

func (*GetCNReplicasRequest) Marshal 

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

func (*GetCNReplicasRequest) MarshalTo 

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

func (*GetCNReplicasRequest) MarshalToSizedBuffer 

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

func (*GetCNReplicasRequest) ProtoMessage 

func (*GetCNReplicasRequest) ProtoMessage()

func (*GetCNReplicasRequest) ProtoSize 

func (m *GetCNReplicasRequest) ProtoSize() (n int)

func (*GetCNReplicasRequest) Reset 

func (m *GetCNReplicasRequest) Reset()

func (*GetCNReplicasRequest) String 

func (m *GetCNReplicasRequest) String() string

func (*GetCNReplicasRequest) Unmarshal 

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

func (*GetCNReplicasRequest) XXX_DiscardUnknown 

func (m *GetCNReplicasRequest) XXX_DiscardUnknown()

func (*GetCNReplicasRequest) XXX_Marshal 

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

func (*GetCNReplicasRequest) XXX_Merge 

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

func (*GetCNReplicasRequest) XXX_Size 

func (m *GetCNReplicasRequest) XXX_Size() int

func (*GetCNReplicasRequest) XXX_Unmarshal 

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

type GetCNReplicasResponse 

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

func (*GetCNReplicasResponse) Descriptor 

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

func (*GetCNReplicasResponse) GetReplicas 

func (m *GetCNReplicasResponse) GetReplicas() []ShardReplica

func (*GetCNReplicasResponse) Marshal 

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

func (*GetCNReplicasResponse) MarshalTo 

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

func (*GetCNReplicasResponse) MarshalToSizedBuffer 

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

func (*GetCNReplicasResponse) ProtoMessage 

func (*GetCNReplicasResponse) ProtoMessage()

func (*GetCNReplicasResponse) ProtoSize 

func (m *GetCNReplicasResponse) ProtoSize() (n int)

func (*GetCNReplicasResponse) Reset 

func (m *GetCNReplicasResponse) Reset()

func (*GetCNReplicasResponse) String 

func (m *GetCNReplicasResponse) String() string

func (*GetCNReplicasResponse) Unmarshal 

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

func (*GetCNReplicasResponse) XXX_DiscardUnknown 

func (m *GetCNReplicasResponse) XXX_DiscardUnknown()

func (*GetCNReplicasResponse) XXX_Marshal 

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

func (*GetCNReplicasResponse) XXX_Merge 

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

func (*GetCNReplicasResponse) XXX_Size 

func (m *GetCNReplicasResponse) XXX_Size() int

func (*GetCNReplicasResponse) XXX_Unmarshal 

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

type GetColumMetadataScanInfoParam 

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

func (*GetColumMetadataScanInfoParam) Descriptor 

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

func (*GetColumMetadataScanInfoParam) GetColumnName 

func (m *GetColumMetadataScanInfoParam) GetColumnName() string

func (*GetColumMetadataScanInfoParam) Marshal 

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

func (*GetColumMetadataScanInfoParam) MarshalTo 

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

func (*GetColumMetadataScanInfoParam) MarshalToSizedBuffer 

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

func (*GetColumMetadataScanInfoParam) ProtoMessage 

func (*GetColumMetadataScanInfoParam) ProtoMessage()

func (*GetColumMetadataScanInfoParam) ProtoSize 

func (m *GetColumMetadataScanInfoParam) ProtoSize() (n int)

func (*GetColumMetadataScanInfoParam) Reset 

func (m *GetColumMetadataScanInfoParam) Reset()

func (*GetColumMetadataScanInfoParam) String 

func (m *GetColumMetadataScanInfoParam) String() string

func (*GetColumMetadataScanInfoParam) Unmarshal 

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

func (*GetColumMetadataScanInfoParam) XXX_DiscardUnknown 

func (m *GetColumMetadataScanInfoParam) XXX_DiscardUnknown()

func (*GetColumMetadataScanInfoParam) XXX_Marshal 

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

func (*GetColumMetadataScanInfoParam) XXX_Merge 

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

func (*GetColumMetadataScanInfoParam) XXX_Size 

func (m *GetColumMetadataScanInfoParam) XXX_Size() int

func (*GetColumMetadataScanInfoParam) XXX_Unmarshal 

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

type GetShardsRequest 

type GetShardsRequest struct {
	ID                   uint64         `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Metadata             ShardsMetadata `protobuf:"bytes,2,opt,name=Metadata,proto3" json:"Metadata"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetShardsRequest) Descriptor 

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

func (*GetShardsRequest) GetID 

func (m *GetShardsRequest) GetID() uint64

func (*GetShardsRequest) GetMetadata 

func (m *GetShardsRequest) GetMetadata() ShardsMetadata

func (*GetShardsRequest) Marshal 

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

func (*GetShardsRequest) MarshalTo 

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

func (*GetShardsRequest) MarshalToSizedBuffer 

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

func (*GetShardsRequest) ProtoMessage 

func (*GetShardsRequest) ProtoMessage()

func (*GetShardsRequest) ProtoSize 

func (m *GetShardsRequest) ProtoSize() (n int)

func (*GetShardsRequest) Reset 

func (m *GetShardsRequest) Reset()

func (*GetShardsRequest) String 

func (m *GetShardsRequest) String() string

func (*GetShardsRequest) Unmarshal 

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

func (*GetShardsRequest) XXX_DiscardUnknown 

func (m *GetShardsRequest) XXX_DiscardUnknown()

func (*GetShardsRequest) XXX_Marshal 

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

func (*GetShardsRequest) XXX_Merge 

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

func (*GetShardsRequest) XXX_Size 

func (m *GetShardsRequest) XXX_Size() int

func (*GetShardsRequest) XXX_Unmarshal 

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

type GetShardsResponse 

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

func (*GetShardsResponse) Descriptor 

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

func (*GetShardsResponse) GetShards 

func (m *GetShardsResponse) GetShards() []TableShard

func (*GetShardsResponse) Marshal 

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

func (*GetShardsResponse) MarshalTo 

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

func (*GetShardsResponse) MarshalToSizedBuffer 

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

func (*GetShardsResponse) ProtoMessage 

func (*GetShardsResponse) ProtoMessage()

func (*GetShardsResponse) ProtoSize 

func (m *GetShardsResponse) ProtoSize() (n int)

func (*GetShardsResponse) Reset 

func (m *GetShardsResponse) Reset()

func (*GetShardsResponse) String 

func (m *GetShardsResponse) String() string

func (*GetShardsResponse) Unmarshal 

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

func (*GetShardsResponse) XXX_DiscardUnknown 

func (m *GetShardsResponse) XXX_DiscardUnknown()

func (*GetShardsResponse) XXX_Marshal 

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

func (*GetShardsResponse) XXX_Merge 

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

func (*GetShardsResponse) XXX_Size 

func (m *GetShardsResponse) XXX_Size() int

func (*GetShardsResponse) XXX_Unmarshal 

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

type HeartbeatRequest 

type HeartbeatRequest struct {
	CN                   string       `protobuf:"bytes,1,opt,name=CN,proto3" json:"CN,omitempty"`
	Shards               []TableShard `protobuf:"bytes,2,rep,name=Shards,proto3" json:"Shards"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

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

func (*HeartbeatRequest) GetCN 

func (m *HeartbeatRequest) GetCN() string

func (*HeartbeatRequest) GetShards 

func (m *HeartbeatRequest) GetShards() []TableShard

func (*HeartbeatRequest) Marshal 

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

func (*HeartbeatRequest) MarshalTo 

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

func (*HeartbeatRequest) MarshalToSizedBuffer 

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

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoSize 

func (m *HeartbeatRequest) ProtoSize() (n int)

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

func (*HeartbeatRequest) Unmarshal 

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

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

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

func (*HeartbeatRequest) XXX_Merge 

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

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

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

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor 

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

func (*HeartbeatResponse) GetOperators 

func (m *HeartbeatResponse) GetOperators() []Operator

func (*HeartbeatResponse) Marshal 

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

func (*HeartbeatResponse) MarshalTo 

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

func (*HeartbeatResponse) MarshalToSizedBuffer 

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

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoSize 

func (m *HeartbeatResponse) ProtoSize() (n int)

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (m *HeartbeatResponse) String() string

func (*HeartbeatResponse) Unmarshal 

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

func (*HeartbeatResponse) XXX_DiscardUnknown 

func (m *HeartbeatResponse) XXX_DiscardUnknown()

func (*HeartbeatResponse) XXX_Marshal 

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

func (*HeartbeatResponse) XXX_Merge 

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

func (*HeartbeatResponse) XXX_Size 

func (m *HeartbeatResponse) XXX_Size() int

func (*HeartbeatResponse) XXX_Unmarshal 

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

type KeyParam 

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

func (*KeyParam) Descriptor 

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

func (*KeyParam) GetKey 

func (m *KeyParam) GetKey() []byte

func (*KeyParam) Marshal 

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

func (*KeyParam) MarshalTo 

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

func (*KeyParam) MarshalToSizedBuffer 

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

func (*KeyParam) ProtoMessage 

func (*KeyParam) ProtoMessage()

func (*KeyParam) ProtoSize 

func (m *KeyParam) ProtoSize() (n int)

func (*KeyParam) Reset 

func (m *KeyParam) Reset()

func (*KeyParam) String 

func (m *KeyParam) String() string

func (*KeyParam) Unmarshal 

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

func (*KeyParam) XXX_DiscardUnknown 

func (m *KeyParam) XXX_DiscardUnknown()

func (*KeyParam) XXX_Marshal 

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

func (*KeyParam) XXX_Merge 

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

func (*KeyParam) XXX_Size 

func (m *KeyParam) XXX_Size() int

func (*KeyParam) XXX_Unmarshal 

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

type MergeObjectsParam 

type MergeObjectsParam struct {
	Objstats             [][]byte `protobuf:"bytes,1,rep,name=objstats,proto3" json:"objstats,omitempty"`
	TargetObjSize        uint32   `protobuf:"varint,3,opt,name=targetObjSize,proto3" json:"targetObjSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MergeObjectsParam) Descriptor 

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

func (*MergeObjectsParam) GetObjstats 

func (m *MergeObjectsParam) GetObjstats() [][]byte

func (*MergeObjectsParam) GetTargetObjSize 

func (m *MergeObjectsParam) GetTargetObjSize() uint32

func (*MergeObjectsParam) Marshal 

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

func (*MergeObjectsParam) MarshalTo 

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

func (*MergeObjectsParam) MarshalToSizedBuffer 

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

func (*MergeObjectsParam) ProtoMessage 

func (*MergeObjectsParam) ProtoMessage()

func (*MergeObjectsParam) ProtoSize 

func (m *MergeObjectsParam) ProtoSize() (n int)

func (*MergeObjectsParam) Reset 

func (m *MergeObjectsParam) Reset()

func (*MergeObjectsParam) String 

func (m *MergeObjectsParam) String() string

func (*MergeObjectsParam) Unmarshal 

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

func (*MergeObjectsParam) XXX_DiscardUnknown 

func (m *MergeObjectsParam) XXX_DiscardUnknown()

func (*MergeObjectsParam) XXX_Marshal 

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

func (*MergeObjectsParam) XXX_Merge 

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

func (*MergeObjectsParam) XXX_Size 

func (m *MergeObjectsParam) XXX_Size() int

func (*MergeObjectsParam) XXX_Unmarshal 

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

type Method 

type Method int32

Method sharding operations 

const (
	Method_Heartbeat     Method = 0
	Method_CreateShards  Method = 1
	Method_DeleteShards  Method = 2
	Method_GetShards     Method = 3
	Method_ShardRead     Method = 4
	Method_PauseCN       Method = 5
	Method_GetCNReplicas Method = 6
)

func (Method) EnumDescriptor 

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

func (Method) String 

func (x Method) String() string

type OpType 

type OpType int32

OpType operator type. 

const (
	OpType_AddReplica    OpType = 0
	OpType_DeleteReplica OpType = 1
	OpType_DeleteAll     OpType = 2
	OpType_CreateTable   OpType = 3
)

func (OpType) EnumDescriptor 

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

func (OpType) String 

func (x OpType) String() string

type Operator 

type Operator struct {
	Type                 OpType       `protobuf:"varint,1,opt,name=Type,proto3,enum=shard.OpType" json:"Type,omitempty"`
	TableShard           TableShard   `protobuf:"bytes,2,opt,name=TableShard,proto3" json:"TableShard"`
	Replica              ShardReplica `protobuf:"bytes,3,opt,name=Replica,proto3" json:"Replica"`
	TableID              uint64       `protobuf:"varint,4,opt,name=TableID,proto3" json:"TableID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Operator is a description of a command that needs to be sent down to CN for execution. The command needs to be executed within a specified time frame. If the timeout is exceeded, the command is automatically terminated and the ShardBalancer recalculates to use the another CN to execute the command.

func (*Operator) Descriptor 

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

func (*Operator) GetReplica 

func (m *Operator) GetReplica() ShardReplica

func (*Operator) GetTableID 

func (m *Operator) GetTableID() uint64

func (*Operator) GetTableShard 

func (m *Operator) GetTableShard() TableShard

func (*Operator) GetType 

func (m *Operator) GetType() OpType

func (*Operator) Marshal 

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

func (*Operator) MarshalTo 

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

func (*Operator) MarshalToSizedBuffer 

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

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) ProtoSize 

func (m *Operator) ProtoSize() (n int)

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) String 

func (m *Operator) String() string

func (*Operator) Unmarshal 

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

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

type PauseCNRequest 

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

func (*PauseCNRequest) Descriptor 

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

func (*PauseCNRequest) GetID 

func (m *PauseCNRequest) GetID() string

func (*PauseCNRequest) Marshal 

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

func (*PauseCNRequest) MarshalTo 

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

func (*PauseCNRequest) MarshalToSizedBuffer 

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

func (*PauseCNRequest) ProtoMessage 

func (*PauseCNRequest) ProtoMessage()

func (*PauseCNRequest) ProtoSize 

func (m *PauseCNRequest) ProtoSize() (n int)

func (*PauseCNRequest) Reset 

func (m *PauseCNRequest) Reset()

func (*PauseCNRequest) String 

func (m *PauseCNRequest) String() string

func (*PauseCNRequest) Unmarshal 

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

func (*PauseCNRequest) XXX_DiscardUnknown 

func (m *PauseCNRequest) XXX_DiscardUnknown()

func (*PauseCNRequest) XXX_Marshal 

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

func (*PauseCNRequest) XXX_Merge 

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

func (*PauseCNRequest) XXX_Size 

func (m *PauseCNRequest) XXX_Size() int

func (*PauseCNRequest) XXX_Unmarshal 

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

type PauseCNResponse 

type PauseCNResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseCNResponse) Descriptor 

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

func (*PauseCNResponse) Marshal 

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

func (*PauseCNResponse) MarshalTo 

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

func (*PauseCNResponse) MarshalToSizedBuffer 

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

func (*PauseCNResponse) ProtoMessage 

func (*PauseCNResponse) ProtoMessage()

func (*PauseCNResponse) ProtoSize 

func (m *PauseCNResponse) ProtoSize() (n int)

func (*PauseCNResponse) Reset 

func (m *PauseCNResponse) Reset()

func (*PauseCNResponse) String 

func (m *PauseCNResponse) String() string

func (*PauseCNResponse) Unmarshal 

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

func (*PauseCNResponse) XXX_DiscardUnknown 

func (m *PauseCNResponse) XXX_DiscardUnknown()

func (*PauseCNResponse) XXX_Marshal 

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

func (*PauseCNResponse) XXX_Merge 

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

func (*PauseCNResponse) XXX_Size 

func (m *PauseCNResponse) XXX_Size() int

func (*PauseCNResponse) XXX_Unmarshal 

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

type Policy 

type Policy int32

Policy shard policy for a table. 

const (
	// None no sharding for the current table.
	Policy_None Policy = 0
	// Partition the user-defined way of sharding data for a partitioned table.
	//
	// The number of Shards is determined when the table is created. It does not
	// change with the number of CN nodes in the MO cluster.
	//
	// The number of shards is only changed when the user changes the table definition
	// by using alter table.
	//
	// len(Shards) == len(Partitions).
	Policy_Partition Policy = 1
	// Hash auto-sharding data in a way that is based on primary key hash.
	//
	// In this mode, the number of shards of the table changes with the number of
	// nodes of CN in the mo cluster. len(shards) >= len(CN nodes).
	Policy_Hash Policy = 2
)

func (Policy) EnumDescriptor 

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

func (Policy) String 

func (x Policy) String() string

type PrimaryKeysMayBeModifiedParam 

type PrimaryKeysMayBeModifiedParam struct {
	From                 []byte   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To                   []byte   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	KeyVector            []byte   `protobuf:"bytes,3,opt,name=keyVector,proto3" json:"keyVector,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrimaryKeysMayBeModifiedParam) Descriptor 

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

func (*PrimaryKeysMayBeModifiedParam) GetFrom 

func (m *PrimaryKeysMayBeModifiedParam) GetFrom() []byte

func (*PrimaryKeysMayBeModifiedParam) GetKeyVector 

func (m *PrimaryKeysMayBeModifiedParam) GetKeyVector() []byte

func (*PrimaryKeysMayBeModifiedParam) GetTo 

func (m *PrimaryKeysMayBeModifiedParam) GetTo() []byte

func (*PrimaryKeysMayBeModifiedParam) Marshal 

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

func (*PrimaryKeysMayBeModifiedParam) MarshalTo 

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

func (*PrimaryKeysMayBeModifiedParam) MarshalToSizedBuffer 

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

func (*PrimaryKeysMayBeModifiedParam) ProtoMessage 

func (*PrimaryKeysMayBeModifiedParam) ProtoMessage()

func (*PrimaryKeysMayBeModifiedParam) ProtoSize 

func (m *PrimaryKeysMayBeModifiedParam) ProtoSize() (n int)

func (*PrimaryKeysMayBeModifiedParam) Reset 

func (m *PrimaryKeysMayBeModifiedParam) Reset()

func (*PrimaryKeysMayBeModifiedParam) String 

func (m *PrimaryKeysMayBeModifiedParam) String() string

func (*PrimaryKeysMayBeModifiedParam) Unmarshal 

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

func (*PrimaryKeysMayBeModifiedParam) XXX_DiscardUnknown 

func (m *PrimaryKeysMayBeModifiedParam) XXX_DiscardUnknown()

func (*PrimaryKeysMayBeModifiedParam) XXX_Marshal 

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

func (*PrimaryKeysMayBeModifiedParam) XXX_Merge 

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

func (*PrimaryKeysMayBeModifiedParam) XXX_Size 

func (m *PrimaryKeysMayBeModifiedParam) XXX_Size() int

func (*PrimaryKeysMayBeModifiedParam) XXX_Unmarshal 

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

type RangesParam 

type RangesParam struct {
	Exprs                []*plan.Expr `protobuf:"bytes,1,rep,name=Exprs,proto3" json:"Exprs,omitempty"`
	PreAllocSize         uint32       `protobuf:"varint,2,opt,name=preAllocSize,proto3" json:"preAllocSize,omitempty"`
	DataCollectPolicy    uint32       `protobuf:"varint,3,opt,name=dataCollectPolicy,proto3" json:"dataCollectPolicy,omitempty"`
	TxnOffset            uint32       `protobuf:"varint,4,opt,name=txnOffset,proto3" json:"txnOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RangesParam) Descriptor 

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

func (*RangesParam) GetDataCollectPolicy 

func (m *RangesParam) GetDataCollectPolicy() uint32

func (*RangesParam) GetExprs 

func (m *RangesParam) GetExprs() []*plan.Expr

func (*RangesParam) GetPreAllocSize 

func (m *RangesParam) GetPreAllocSize() uint32

func (*RangesParam) GetTxnOffset 

func (m *RangesParam) GetTxnOffset() uint32

func (*RangesParam) Marshal 

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

func (*RangesParam) MarshalTo 

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

func (*RangesParam) MarshalToSizedBuffer 

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

func (*RangesParam) ProtoMessage 

func (*RangesParam) ProtoMessage()

func (*RangesParam) ProtoSize 

func (m *RangesParam) ProtoSize() (n int)

func (*RangesParam) Reset 

func (m *RangesParam) Reset()

func (*RangesParam) String 

func (m *RangesParam) String() string

func (*RangesParam) Unmarshal 

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

func (*RangesParam) XXX_DiscardUnknown 

func (m *RangesParam) XXX_DiscardUnknown()

func (*RangesParam) XXX_Marshal 

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

func (*RangesParam) XXX_Merge 

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

func (*RangesParam) XXX_Size 

func (m *RangesParam) XXX_Size() int

func (*RangesParam) XXX_Unmarshal 

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

type ReadCloseParam 

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

func (*ReadCloseParam) Descriptor 

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

func (*ReadCloseParam) GetUuid 

func (m *ReadCloseParam) GetUuid() []byte

func (*ReadCloseParam) Marshal 

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

func (*ReadCloseParam) MarshalTo 

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

func (*ReadCloseParam) MarshalToSizedBuffer 

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

func (*ReadCloseParam) ProtoMessage 

func (*ReadCloseParam) ProtoMessage()

func (*ReadCloseParam) ProtoSize 

func (m *ReadCloseParam) ProtoSize() (n int)

func (*ReadCloseParam) Reset 

func (m *ReadCloseParam) Reset()

func (*ReadCloseParam) String 

func (m *ReadCloseParam) String() string

func (*ReadCloseParam) Unmarshal 

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

func (*ReadCloseParam) XXX_DiscardUnknown 

func (m *ReadCloseParam) XXX_DiscardUnknown()

func (*ReadCloseParam) XXX_Marshal 

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

func (*ReadCloseParam) XXX_Merge 

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

func (*ReadCloseParam) XXX_Size 

func (m *ReadCloseParam) XXX_Size() int

func (*ReadCloseParam) XXX_Unmarshal 

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

type ReadNextParam 

type ReadNextParam struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Columns              []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadNextParam) Descriptor 

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

func (*ReadNextParam) GetColumns 

func (m *ReadNextParam) GetColumns() []string

func (*ReadNextParam) GetUuid 

func (m *ReadNextParam) GetUuid() []byte

func (*ReadNextParam) Marshal 

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

func (*ReadNextParam) MarshalTo 

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

func (*ReadNextParam) MarshalToSizedBuffer 

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

func (*ReadNextParam) ProtoMessage 

func (*ReadNextParam) ProtoMessage()

func (*ReadNextParam) ProtoSize 

func (m *ReadNextParam) ProtoSize() (n int)

func (*ReadNextParam) Reset 

func (m *ReadNextParam) Reset()

func (*ReadNextParam) String 

func (m *ReadNextParam) String() string

func (*ReadNextParam) Unmarshal 

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

func (*ReadNextParam) XXX_DiscardUnknown 

func (m *ReadNextParam) XXX_DiscardUnknown()

func (*ReadNextParam) XXX_Marshal 

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

func (*ReadNextParam) XXX_Merge 

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

func (*ReadNextParam) XXX_Size 

func (m *ReadNextParam) XXX_Size() int

func (*ReadNextParam) XXX_Unmarshal 

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

type ReadNextResult 

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

func (*ReadNextResult) Descriptor 

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

func (*ReadNextResult) GetResult 

func (m *ReadNextResult) GetResult() []byte

func (*ReadNextResult) Marshal 

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

func (*ReadNextResult) MarshalTo 

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

func (*ReadNextResult) MarshalToSizedBuffer 

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

func (*ReadNextResult) ProtoMessage 

func (*ReadNextResult) ProtoMessage()

func (*ReadNextResult) ProtoSize 

func (m *ReadNextResult) ProtoSize() (n int)

func (*ReadNextResult) Reset 

func (m *ReadNextResult) Reset()

func (*ReadNextResult) String 

func (m *ReadNextResult) String() string

func (*ReadNextResult) Unmarshal 

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

func (*ReadNextResult) XXX_DiscardUnknown 

func (m *ReadNextResult) XXX_DiscardUnknown()

func (*ReadNextResult) XXX_Marshal 

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

func (*ReadNextResult) XXX_Merge 

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

func (*ReadNextResult) XXX_Size 

func (m *ReadNextResult) XXX_Size() int

func (*ReadNextResult) XXX_Unmarshal 

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

type ReadParam 

type ReadParam struct {
	Process                       pipeline.ProcessInfo          `protobuf:"bytes,1,opt,name=Process,proto3" json:"Process"`
	TxnTable                      TxnTable                      `protobuf:"bytes,2,opt,name=TxnTable,proto3" json:"TxnTable"`
	StatsParam                    StatsParam                    `protobuf:"bytes,3,opt,name=StatsParam,proto3" json:"StatsParam"`
	SizeParam                     SizeParam                     `protobuf:"bytes,4,opt,name=SizeParam,proto3" json:"SizeParam"`
	RangesParam                   RangesParam                   `protobuf:"bytes,5,opt,name=RangesParam,proto3" json:"RangesParam"`
	GetColumMetadataScanInfoParam GetColumMetadataScanInfoParam `protobuf:"bytes,6,opt,name=GetColumMetadataScanInfoParam,proto3" json:"GetColumMetadataScanInfoParam"`
	MergeObjectsParam             MergeObjectsParam             `protobuf:"bytes,7,opt,name=MergeObjectsParam,proto3" json:"MergeObjectsParam"`
	KeyParam                      KeyParam                      `protobuf:"bytes,8,opt,name=KeyParam,proto3" json:"KeyParam"`
	ReaderBuildParam              ReaderBuildParam              `protobuf:"bytes,9,opt,name=ReaderBuildParam,proto3" json:"ReaderBuildParam"`
	PrimaryKeysMayBeModifiedParam PrimaryKeysMayBeModifiedParam `protobuf:"bytes,10,opt,name=PrimaryKeysMayBeModifiedParam,proto3" json:"PrimaryKeysMayBeModifiedParam"`
	ReadNextParam                 ReadNextParam                 `protobuf:"bytes,11,opt,name=ReadNextParam,proto3" json:"ReadNextParam"`
	ReadCloseParam                ReadCloseParam                `protobuf:"bytes,12,opt,name=ReadCloseParam,proto3" json:"ReadCloseParam"`
	CollectTombstonesParam        CollectTombstonesParam        `protobuf:"bytes,13,opt,name=CollectTombstonesParam,proto3" json:"CollectTombstonesParam"`
	XXX_NoUnkeyedLiteral          struct{}                      `json:"-"`
	XXX_unrecognized              []byte                        `json:"-"`
	XXX_sizecache                 int32                         `json:"-"`
}

func (*ReadParam) Descriptor 

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

func (*ReadParam) GetCollectTombstonesParam 

func (m *ReadParam) GetCollectTombstonesParam() CollectTombstonesParam

func (*ReadParam) GetGetColumMetadataScanInfoParam 

func (m *ReadParam) GetGetColumMetadataScanInfoParam() GetColumMetadataScanInfoParam

func (*ReadParam) GetKeyParam 

func (m *ReadParam) GetKeyParam() KeyParam

func (*ReadParam) GetMergeObjectsParam 

func (m *ReadParam) GetMergeObjectsParam() MergeObjectsParam

func (*ReadParam) GetPrimaryKeysMayBeModifiedParam 

func (m *ReadParam) GetPrimaryKeysMayBeModifiedParam() PrimaryKeysMayBeModifiedParam

func (*ReadParam) GetProcess 

func (m *ReadParam) GetProcess() pipeline.ProcessInfo

func (*ReadParam) GetRangesParam 

func (m *ReadParam) GetRangesParam() RangesParam

func (*ReadParam) GetReadCloseParam 

func (m *ReadParam) GetReadCloseParam() ReadCloseParam

func (*ReadParam) GetReadNextParam 

func (m *ReadParam) GetReadNextParam() ReadNextParam

func (*ReadParam) GetReaderBuildParam 

func (m *ReadParam) GetReaderBuildParam() ReaderBuildParam

func (*ReadParam) GetSizeParam 

func (m *ReadParam) GetSizeParam() SizeParam

func (*ReadParam) GetStatsParam 

func (m *ReadParam) GetStatsParam() StatsParam

func (*ReadParam) GetTxnTable 

func (m *ReadParam) GetTxnTable() TxnTable

func (*ReadParam) Marshal 

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

func (*ReadParam) MarshalTo 

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

func (*ReadParam) MarshalToSizedBuffer 

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

func (*ReadParam) ProtoMessage 

func (*ReadParam) ProtoMessage()

func (*ReadParam) ProtoSize 

func (m *ReadParam) ProtoSize() (n int)

func (*ReadParam) Reset 

func (m *ReadParam) Reset()

func (*ReadParam) String 

func (m *ReadParam) String() string

func (*ReadParam) Unmarshal 

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

func (*ReadParam) XXX_DiscardUnknown 

func (m *ReadParam) XXX_DiscardUnknown()

func (*ReadParam) XXX_Marshal 

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

func (*ReadParam) XXX_Merge 

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

func (*ReadParam) XXX_Size 

func (m *ReadParam) XXX_Size() int

func (*ReadParam) XXX_Unmarshal 

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

type ReaderBuildParam 

type ReaderBuildParam struct {
	RelData              []byte     `protobuf:"bytes,1,opt,name=relData,proto3" json:"relData,omitempty"`
	Expr                 *plan.Expr `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	TombstoneApplyPolicy int32      `protobuf:"varint,3,opt,name=tombstoneApplyPolicy,proto3" json:"tombstoneApplyPolicy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ReaderBuildParam) Descriptor 

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

func (*ReaderBuildParam) GetExpr 

func (m *ReaderBuildParam) GetExpr() *plan.Expr

func (*ReaderBuildParam) GetRelData 

func (m *ReaderBuildParam) GetRelData() []byte

func (*ReaderBuildParam) GetTombstoneApplyPolicy 

func (m *ReaderBuildParam) GetTombstoneApplyPolicy() int32

func (*ReaderBuildParam) Marshal 

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

func (*ReaderBuildParam) MarshalTo 

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

func (*ReaderBuildParam) MarshalToSizedBuffer 

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

func (*ReaderBuildParam) ProtoMessage 

func (*ReaderBuildParam) ProtoMessage()

func (*ReaderBuildParam) ProtoSize 

func (m *ReaderBuildParam) ProtoSize() (n int)

func (*ReaderBuildParam) Reset 

func (m *ReaderBuildParam) Reset()

func (*ReaderBuildParam) String 

func (m *ReaderBuildParam) String() string

func (*ReaderBuildParam) Unmarshal 

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

func (*ReaderBuildParam) XXX_DiscardUnknown 

func (m *ReaderBuildParam) XXX_DiscardUnknown()

func (*ReaderBuildParam) XXX_Marshal 

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

func (*ReaderBuildParam) XXX_Merge 

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

func (*ReaderBuildParam) XXX_Size 

func (m *ReaderBuildParam) XXX_Size() int

func (*ReaderBuildParam) XXX_Unmarshal 

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

type ReaderBuildResult 

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

func (*ReaderBuildResult) Descriptor 

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

func (*ReaderBuildResult) GetUuid 

func (m *ReaderBuildResult) GetUuid() []byte

func (*ReaderBuildResult) Marshal 

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

func (*ReaderBuildResult) MarshalTo 

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

func (*ReaderBuildResult) MarshalToSizedBuffer 

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

func (*ReaderBuildResult) ProtoMessage 

func (*ReaderBuildResult) ProtoMessage()

func (*ReaderBuildResult) ProtoSize 

func (m *ReaderBuildResult) ProtoSize() (n int)

func (*ReaderBuildResult) Reset 

func (m *ReaderBuildResult) Reset()

func (*ReaderBuildResult) String 

func (m *ReaderBuildResult) String() string

func (*ReaderBuildResult) Unmarshal 

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

func (*ReaderBuildResult) XXX_DiscardUnknown 

func (m *ReaderBuildResult) XXX_DiscardUnknown()

func (*ReaderBuildResult) XXX_Marshal 

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

func (*ReaderBuildResult) XXX_Merge 

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

func (*ReaderBuildResult) XXX_Size 

func (m *ReaderBuildResult) XXX_Size() int

func (*ReaderBuildResult) XXX_Unmarshal 

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

type ReplicaState 

type ReplicaState int32
const (
	ReplicaState_Allocating ReplicaState = 0
	ReplicaState_Allocated  ReplicaState = 1
	ReplicaState_Running    ReplicaState = 2
	ReplicaState_Moving     ReplicaState = 3
	ReplicaState_Tombstone  ReplicaState = 4
)

func (ReplicaState) EnumDescriptor 

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

func (ReplicaState) String 

func (x ReplicaState) String() string

type Request 

type Request struct {
	RequestID            uint64               `protobuf:"varint,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	RPCMethod            Method               `protobuf:"varint,2,opt,name=RPCMethod,proto3,enum=shard.Method" json:"RPCMethod,omitempty"`
	CreateShards         CreateShardsRequest  `protobuf:"bytes,3,opt,name=CreateShards,proto3" json:"CreateShards"`
	DeleteShards         DeleteShardsRequest  `protobuf:"bytes,4,opt,name=DeleteShards,proto3" json:"DeleteShards"`
	Heartbeat            HeartbeatRequest     `protobuf:"bytes,5,opt,name=Heartbeat,proto3" json:"Heartbeat"`
	GetShards            GetShardsRequest     `protobuf:"bytes,6,opt,name=GetShards,proto3" json:"GetShards"`
	ShardRead            ShardReadRequest     `protobuf:"bytes,7,opt,name=ShardRead,proto3" json:"ShardRead"`
	PauseCN              PauseCNRequest       `protobuf:"bytes,8,opt,name=PauseCN,proto3" json:"PauseCN"`
	GetCNReplicas        GetCNReplicasRequest `protobuf:"bytes,9,opt,name=GetCNReplicas,proto3" json:"GetCNReplicas"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Request) DebugString 

func (m *Request) DebugString() string

DebugString returns the debug string

func (*Request) Descriptor 

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

func (*Request) GetCreateShards 

func (m *Request) GetCreateShards() CreateShardsRequest

func (*Request) GetDeleteShards 

func (m *Request) GetDeleteShards() DeleteShardsRequest

func (*Request) GetGetCNReplicas 

func (m *Request) GetGetCNReplicas() GetCNReplicasRequest

func (*Request) GetGetShards 

func (m *Request) GetGetShards() GetShardsRequest

func (*Request) GetHeartbeat 

func (m *Request) GetHeartbeat() HeartbeatRequest

func (*Request) GetID 

func (m *Request) GetID() uint64

GetID implement morpc Message

func (*Request) GetPauseCN 

func (m *Request) GetPauseCN() PauseCNRequest

func (*Request) GetRPCMethod 

func (m *Request) GetRPCMethod() Method

func (*Request) GetRequestID 

func (m *Request) GetRequestID() uint64

func (*Request) GetShardRead 

func (m *Request) GetShardRead() ShardReadRequest

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) Method 

func (m *Request) Method() uint32

Method implement morpc Message

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoSize 

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

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) SetID 

func (m *Request) SetID(id uint64)

SetID implement morpc Message

func (*Request) SetMethod 

func (m *Request) SetMethod(v uint32)

SetMethod implement morpc Message

func (*Request) String 

func (m *Request) String() string

func (Request) TypeName 

func (m Request) TypeName() string

func (*Request) Unmarshal 

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

func (Request) UnwrapError 

func (m Request) UnwrapError() error

UnwrapError unwrap the moerr from the error bytes

func (*Request) WrapError 

func (m *Request) WrapError(err error)

WrapError wrapper error to TxnError

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"`
	RPCMethod Method `protobuf:"varint,2,opt,name=RPCMethod,proto3,enum=shard.Method" json:"RPCMethod,omitempty"`
	// Error we use this field to send moerr from service to another cn. Set with
	// moerr.MarshalBinary, and use moerr.UnmarshalBinary to restore moerr.
	Error                []byte                `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	CreateShards         CreateShardsResponse  `protobuf:"bytes,4,opt,name=CreateShards,proto3" json:"CreateShards"`
	DeleteShards         DeleteShardsResponse  `protobuf:"bytes,5,opt,name=DeleteShards,proto3" json:"DeleteShards"`
	Heartbeat            HeartbeatResponse     `protobuf:"bytes,6,opt,name=Heartbeat,proto3" json:"Heartbeat"`
	GetShards            GetShardsResponse     `protobuf:"bytes,7,opt,name=GetShards,proto3" json:"GetShards"`
	ShardRead            ShardReadResponse     `protobuf:"bytes,8,opt,name=ShardRead,proto3" json:"ShardRead"`
	PauseCN              PauseCNResponse       `protobuf:"bytes,9,opt,name=PauseCN,proto3" json:"PauseCN"`
	GetCNReplicas        GetCNReplicasResponse `protobuf:"bytes,10,opt,name=GetCNReplicas,proto3" json:"GetCNReplicas"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Response) DebugString 

func (m *Response) DebugString() string

DebugString returns the debug string

func (*Response) Descriptor 

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

func (*Response) GetCreateShards 

func (m *Response) GetCreateShards() CreateShardsResponse

func (*Response) GetDeleteShards 

func (m *Response) GetDeleteShards() DeleteShardsResponse

func (*Response) GetError 

func (m *Response) GetError() []byte

func (*Response) GetGetCNReplicas 

func (m *Response) GetGetCNReplicas() GetCNReplicasResponse

func (*Response) GetGetShards 

func (m *Response) GetGetShards() GetShardsResponse

func (*Response) GetHeartbeat 

func (m *Response) GetHeartbeat() HeartbeatResponse

func (*Response) GetID 

func (m *Response) GetID() uint64

GetID implement morpc Message

func (*Response) GetPauseCN 

func (m *Response) GetPauseCN() PauseCNResponse

func (*Response) GetRPCMethod 

func (m *Response) GetRPCMethod() Method

func (*Response) GetRequestID 

func (m *Response) GetRequestID() uint64

func (*Response) GetShardRead 

func (m *Response) GetShardRead() ShardReadResponse

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) Method 

func (m *Response) Method() uint32

Method implement morpc Message

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoSize 

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

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) SetID 

func (m *Response) SetID(id uint64)

SetID implement morpc Message

func (*Response) SetMethod 

func (m *Response) SetMethod(v uint32)

SetMethod implement morpc Message

func (*Response) String 

func (m *Response) String() string

func (Response) TypeName 

func (m Response) TypeName() string

func (*Response) Unmarshal 

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

func (Response) UnwrapError 

func (m Response) UnwrapError() error

UnwrapError unwrap the moerr from the error bytes

func (*Response) WrapError 

func (m *Response) WrapError(err error)

WrapError wrapper error to TxnError

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 ShardReadRequest 

type ShardReadRequest struct {
	Shard                TableShard          `protobuf:"bytes,1,opt,name=Shard,proto3" json:"Shard"`
	CN                   string              `protobuf:"bytes,2,opt,name=CN,proto3" json:"CN,omitempty"`
	Method               uint32              `protobuf:"varint,3,opt,name=Method,proto3" json:"Method,omitempty"`
	Param                ReadParam           `protobuf:"bytes,4,opt,name=Param,proto3" json:"Param"`
	ReadAt               timestamp.Timestamp `protobuf:"bytes,5,opt,name=ReadAt,proto3" json:"ReadAt"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ShardReadRequest) Descriptor 

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

func (*ShardReadRequest) GetCN 

func (m *ShardReadRequest) GetCN() string

func (*ShardReadRequest) GetMethod 

func (m *ShardReadRequest) GetMethod() uint32

func (*ShardReadRequest) GetParam 

func (m *ShardReadRequest) GetParam() ReadParam

func (*ShardReadRequest) GetReadAt 

func (m *ShardReadRequest) GetReadAt() timestamp.Timestamp

func (*ShardReadRequest) GetShard 

func (m *ShardReadRequest) GetShard() TableShard

func (*ShardReadRequest) Marshal 

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

func (*ShardReadRequest) MarshalTo 

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

func (*ShardReadRequest) MarshalToSizedBuffer 

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

func (*ShardReadRequest) ProtoMessage 

func (*ShardReadRequest) ProtoMessage()

func (*ShardReadRequest) ProtoSize 

func (m *ShardReadRequest) ProtoSize() (n int)

func (*ShardReadRequest) Reset 

func (m *ShardReadRequest) Reset()

func (*ShardReadRequest) String 

func (m *ShardReadRequest) String() string

func (*ShardReadRequest) Unmarshal 

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

func (*ShardReadRequest) XXX_DiscardUnknown 

func (m *ShardReadRequest) XXX_DiscardUnknown()

func (*ShardReadRequest) XXX_Marshal 

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

func (*ShardReadRequest) XXX_Merge 

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

func (*ShardReadRequest) XXX_Size 

func (m *ShardReadRequest) XXX_Size() int

func (*ShardReadRequest) XXX_Unmarshal 

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

type ShardReadResponse 

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

func (*ShardReadResponse) Descriptor 

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

func (*ShardReadResponse) GetPayload 

func (m *ShardReadResponse) GetPayload() []byte

func (*ShardReadResponse) Marshal 

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

func (*ShardReadResponse) MarshalTo 

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

func (*ShardReadResponse) MarshalToSizedBuffer 

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

func (*ShardReadResponse) ProtoMessage 

func (*ShardReadResponse) ProtoMessage()

func (*ShardReadResponse) ProtoSize 

func (m *ShardReadResponse) ProtoSize() (n int)

func (*ShardReadResponse) Reset 

func (m *ShardReadResponse) Reset()

func (*ShardReadResponse) String 

func (m *ShardReadResponse) String() string

func (*ShardReadResponse) Unmarshal 

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

func (*ShardReadResponse) XXX_DiscardUnknown 

func (m *ShardReadResponse) XXX_DiscardUnknown()

func (*ShardReadResponse) XXX_Marshal 

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

func (*ShardReadResponse) XXX_Merge 

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

func (*ShardReadResponse) XXX_Size 

func (m *ShardReadResponse) XXX_Size() int

func (*ShardReadResponse) XXX_Unmarshal 

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

type ShardReplica 

type ShardReplica struct {
	ReplicaID uint64       `protobuf:"varint,1,opt,name=ReplicaID,proto3" json:"ReplicaID,omitempty"`
	State     ReplicaState `protobuf:"varint,2,opt,name=State,proto3,enum=shard.ReplicaState" json:"State,omitempty"`
	CN        string       `protobuf:"bytes,3,opt,name=CN,proto3" json:"CN,omitempty"`
	// Version increment when the cn changed
	Version              uint64   `protobuf:"varint,4,opt,name=Version,proto3" json:"Version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardReplica a tableShard will have multiple replicas, the data of these replicas is exactly the same, each replica is a ShardReplica. ShardReplica can run on any available CN node.

The binding relationship between CN and ShardReplica changes dynamically during the runtime, and presumably if the corresponding CN goes offline, or if a new CN comes online and causes an imbalance between ShardReplica and CN, then the binding relationship will be readjusted.

The number of replicas is used to extend the read performance.

func (*ShardReplica) Descriptor 

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

func (*ShardReplica) GetCN 

func (m *ShardReplica) GetCN() string

func (*ShardReplica) GetReplicaID 

func (m *ShardReplica) GetReplicaID() uint64

func (*ShardReplica) GetState 

func (m *ShardReplica) GetState() ReplicaState

func (*ShardReplica) GetVersion 

func (m *ShardReplica) GetVersion() uint64

func (*ShardReplica) Marshal 

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

func (*ShardReplica) MarshalTo 

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

func (*ShardReplica) MarshalToSizedBuffer 

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

func (*ShardReplica) ProtoMessage 

func (*ShardReplica) ProtoMessage()

func (*ShardReplica) ProtoSize 

func (m *ShardReplica) ProtoSize() (n int)

func (*ShardReplica) Reset 

func (m *ShardReplica) Reset()

func (ShardReplica) Same 

func (m ShardReplica) Same(
	m2 ShardReplica,
) bool

func (*ShardReplica) String 

func (m *ShardReplica) String() string

func (*ShardReplica) Unmarshal 

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

func (*ShardReplica) XXX_DiscardUnknown 

func (m *ShardReplica) XXX_DiscardUnknown()

func (*ShardReplica) XXX_Marshal 

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

func (*ShardReplica) XXX_Merge 

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

func (*ShardReplica) XXX_Size 

func (m *ShardReplica) XXX_Size() int

func (*ShardReplica) XXX_Unmarshal 

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

type ShardsMetadata 

type ShardsMetadata struct {
	Policy               Policy   `protobuf:"varint,1,opt,name=Policy,proto3,enum=shard.Policy" json:"Policy,omitempty"`
	ShardsCount          uint32   `protobuf:"varint,2,opt,name=ShardsCount,proto3" json:"ShardsCount,omitempty"`
	Version              uint32   `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	AccountID            uint64   `protobuf:"varint,4,opt,name=AccountID,proto3" json:"AccountID,omitempty"`
	MaxReplicaCount      uint32   `protobuf:"varint,5,opt,name=MaxReplicaCount,proto3" json:"MaxReplicaCount,omitempty"`
	ShardIDs             []uint64 `protobuf:"varint,6,rep,packed,name=ShardIDs,proto3" json:"ShardIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ShardsMetadata table shards metadata. When a Table is created, metadata for the corresponding shards is created and serialized and stored in MO_TABLES.

func (*ShardsMetadata) Descriptor 

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

func (*ShardsMetadata) GetAccountID 

func (m *ShardsMetadata) GetAccountID() uint64

func (*ShardsMetadata) GetMaxReplicaCount 

func (m *ShardsMetadata) GetMaxReplicaCount() uint32

func (*ShardsMetadata) GetPolicy 

func (m *ShardsMetadata) GetPolicy() Policy

func (*ShardsMetadata) GetShardIDs 

func (m *ShardsMetadata) GetShardIDs() []uint64

func (*ShardsMetadata) GetShardsCount 

func (m *ShardsMetadata) GetShardsCount() uint32

func (*ShardsMetadata) GetVersion 

func (m *ShardsMetadata) GetVersion() uint32

func (ShardsMetadata) IsEmpty 

func (m ShardsMetadata) IsEmpty() bool

func (*ShardsMetadata) Marshal 

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

func (*ShardsMetadata) MarshalTo 

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

func (*ShardsMetadata) MarshalToSizedBuffer 

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

func (*ShardsMetadata) ProtoMessage 

func (*ShardsMetadata) ProtoMessage()

func (*ShardsMetadata) ProtoSize 

func (m *ShardsMetadata) ProtoSize() (n int)

func (*ShardsMetadata) Reset 

func (m *ShardsMetadata) Reset()

func (*ShardsMetadata) String 

func (m *ShardsMetadata) String() string

func (*ShardsMetadata) Unmarshal 

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

func (*ShardsMetadata) XXX_DiscardUnknown 

func (m *ShardsMetadata) XXX_DiscardUnknown()

func (*ShardsMetadata) XXX_Marshal 

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

func (*ShardsMetadata) XXX_Merge 

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

func (*ShardsMetadata) XXX_Size 

func (m *ShardsMetadata) XXX_Size() int

func (*ShardsMetadata) XXX_Unmarshal 

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

type SizeParam 

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

func (*SizeParam) Descriptor 

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

func (*SizeParam) GetColumnName 

func (m *SizeParam) GetColumnName() string

func (*SizeParam) Marshal 

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

func (*SizeParam) MarshalTo 

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

func (*SizeParam) MarshalToSizedBuffer 

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

func (*SizeParam) ProtoMessage 

func (*SizeParam) ProtoMessage()

func (*SizeParam) ProtoSize 

func (m *SizeParam) ProtoSize() (n int)

func (*SizeParam) Reset 

func (m *SizeParam) Reset()

func (*SizeParam) String 

func (m *SizeParam) String() string

func (*SizeParam) Unmarshal 

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

func (*SizeParam) XXX_DiscardUnknown 

func (m *SizeParam) XXX_DiscardUnknown()

func (*SizeParam) XXX_Marshal 

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

func (*SizeParam) XXX_Merge 

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

func (*SizeParam) XXX_Size 

func (m *SizeParam) XXX_Size() int

func (*SizeParam) XXX_Unmarshal 

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

type StatsParam 

type StatsParam struct {
	Sync                 bool     `protobuf:"varint,1,opt,name=sync,proto3" json:"sync,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsParam) Descriptor 

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

func (*StatsParam) GetSync 

func (m *StatsParam) GetSync() bool

func (*StatsParam) Marshal 

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

func (*StatsParam) MarshalTo 

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

func (*StatsParam) MarshalToSizedBuffer 

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

func (*StatsParam) ProtoMessage 

func (*StatsParam) ProtoMessage()

func (*StatsParam) ProtoSize 

func (m *StatsParam) ProtoSize() (n int)

func (*StatsParam) Reset 

func (m *StatsParam) Reset()

func (*StatsParam) String 

func (m *StatsParam) String() string

func (*StatsParam) Unmarshal 

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

func (*StatsParam) XXX_DiscardUnknown 

func (m *StatsParam) XXX_DiscardUnknown()

func (*StatsParam) XXX_Marshal 

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

func (*StatsParam) XXX_Merge 

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

func (*StatsParam) XXX_Size 

func (m *StatsParam) XXX_Size() int

func (*StatsParam) XXX_Unmarshal 

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

type TableShard 

type TableShard struct {
	TableID uint64 `protobuf:"varint,1,opt,name=TableID,proto3" json:"TableID,omitempty"`
	ShardID uint64 `protobuf:"varint,2,opt,name=ShardID,proto3" json:"ShardID,omitempty"`
	Policy  Policy `protobuf:"varint,3,opt,name=Policy,proto3,enum=shard.Policy" json:"Policy,omitempty"`
	// Version increment when shards count changed
	Version              uint32         `protobuf:"varint,4,opt,name=Version,proto3" json:"Version,omitempty"`
	Replicas             []ShardReplica `protobuf:"bytes,5,rep,name=Replicas,proto3" json:"Replicas"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

TableShard when ShardsMetadata are created, the Shards corresponding to a table are determined, and each Shard is assigned a corresponding CN node to handle requests for that Shard.

When the Table's shards count changed, the corresponding Version field increments itself. This makes it easy to found expired information.

func (TableShard) Clone 

func (m TableShard) Clone() TableShard

func (*TableShard) Descriptor 

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

func (*TableShard) GetPolicy 

func (m *TableShard) GetPolicy() Policy

func (TableShard) GetRealTableID 

func (m TableShard) GetRealTableID() uint64

func (TableShard) GetReplica 

func (m TableShard) GetReplica(
	target ShardReplica,
) int

func (*TableShard) GetReplicas 

func (m *TableShard) GetReplicas() []ShardReplica

func (*TableShard) GetShardID 

func (m *TableShard) GetShardID() uint64

func (*TableShard) GetTableID 

func (m *TableShard) GetTableID() uint64

func (*TableShard) GetVersion 

func (m *TableShard) GetVersion() uint32

func (TableShard) HasReplicaWithState 

func (m TableShard) HasReplicaWithState(
	state ReplicaState,
) bool

func (*TableShard) Marshal 

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

func (*TableShard) MarshalTo 

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

func (*TableShard) MarshalToSizedBuffer 

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

func (*TableShard) ProtoMessage 

func (*TableShard) ProtoMessage()

func (*TableShard) ProtoSize 

func (m *TableShard) ProtoSize() (n int)

func (*TableShard) Reset 

func (m *TableShard) Reset()

func (TableShard) Same 

func (m TableShard) Same(
	m2 TableShard,
) bool

func (*TableShard) String 

func (m *TableShard) String() string

func (*TableShard) Unmarshal 

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

func (*TableShard) XXX_DiscardUnknown 

func (m *TableShard) XXX_DiscardUnknown()

func (*TableShard) XXX_Marshal 

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

func (*TableShard) XXX_Merge 

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

func (*TableShard) XXX_Size 

func (m *TableShard) XXX_Size() int

func (*TableShard) XXX_Unmarshal 

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

type TxnTable 

type TxnTable struct {
	AccountID            uint64   `protobuf:"varint,1,opt,name=AccountID,proto3" json:"AccountID,omitempty"`
	DatabaseID           uint64   `protobuf:"varint,2,opt,name=DatabaseID,proto3" json:"DatabaseID,omitempty"`
	DatabaseName         string   `protobuf:"bytes,3,opt,name=DatabaseName,proto3" json:"DatabaseName,omitempty"`
	TableName            string   `protobuf:"bytes,4,opt,name=TableName,proto3" json:"TableName,omitempty"`
	CreatedInTxn         bool     `protobuf:"varint,5,opt,name=CreatedInTxn,proto3" json:"CreatedInTxn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TxnTable) Descriptor 

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

func (*TxnTable) GetAccountID 

func (m *TxnTable) GetAccountID() uint64

func (*TxnTable) GetCreatedInTxn 

func (m *TxnTable) GetCreatedInTxn() bool

func (*TxnTable) GetDatabaseID 

func (m *TxnTable) GetDatabaseID() uint64

func (*TxnTable) GetDatabaseName 

func (m *TxnTable) GetDatabaseName() string

func (*TxnTable) GetTableName 

func (m *TxnTable) GetTableName() string

func (*TxnTable) Marshal 

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

func (*TxnTable) MarshalTo 

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

func (*TxnTable) MarshalToSizedBuffer 

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

func (*TxnTable) ProtoMessage 

func (*TxnTable) ProtoMessage()

func (*TxnTable) ProtoSize 

func (m *TxnTable) ProtoSize() (n int)

func (*TxnTable) Reset 

func (m *TxnTable) Reset()

func (*TxnTable) String 

func (m *TxnTable) String() string

func (*TxnTable) Unmarshal 

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

func (*TxnTable) XXX_DiscardUnknown 

func (m *TxnTable) XXX_DiscardUnknown()

func (*TxnTable) XXX_Marshal 

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

func (*TxnTable) XXX_Merge 

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

func (*TxnTable) XXX_Size 

func (m *TxnTable) XXX_Size() int

func (*TxnTable) XXX_Unmarshal 

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

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.