meta

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Role_name = map[int32]string{
		0: "DATANODE",
		1: "FRONTEND",
		2: "FLOWNODE",
	}
	Role_value = map[string]int32{
		"DATANODE": 0,
		"FRONTEND": 1,
		"FLOWNODE": 2,
	}
)

Enum value maps for Role.

View Source 
var (
	DdlTaskType_name = map[int32]string{
		0: "Create",
		1: "Drop",
	}
	DdlTaskType_value = map[string]int32{
		"Create": 0,
		"Drop":   1,
	}
)

Enum value maps for DdlTaskType.

View Source 
var (
	RegionRole_name = map[int32]string{
		0: "Leader",
		1: "Follower",
		2: "DowngradingLeader",
	}
	RegionRole_value = map[string]int32{
		"Leader":            0,
		"Follower":          1,
		"DowngradingLeader": 2,
	}
)

Enum value maps for RegionRole.

View Source 
var (
	ProcedureStatus_name = map[int32]string{
		0: "Running",
		1: "Done",
		2: "Retrying",
		3: "Failed",
		4: "PrepareRollback",
		5: "RollingBack",
	}
	ProcedureStatus_value = map[string]int32{
		"Running":         0,
		"Done":            1,
		"Retrying":        2,
		"Failed":          3,
		"PrepareRollback": 4,
		"RollingBack":     5,
	}
)

Enum value maps for ProcedureStatus.

View Source 
var Cluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.Cluster",
	HandlerType: (*ClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BatchGet",
			Handler:    _Cluster_BatchGet_Handler,
		},
		{
			MethodName: "Range",
			Handler:    _Cluster_Range_Handler,
		},
		{
			MethodName: "MetasrvPeers",
			Handler:    _Cluster_MetasrvPeers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/cluster.proto",
}

Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DdlTask_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.DdlTask",
	HandlerType: (*DdlTaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubmitDdlTask",
			Handler:    _DdlTask_SubmitDdlTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/ddl.proto",
}

DdlTask_ServiceDesc is the grpc.ServiceDesc for DdlTask service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_greptime_v1_meta_cluster_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_common_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_ddl_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_heartbeat_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_lock_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_procedure_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_region_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_route_proto protoreflect.FileDescriptor
View Source 
var File_greptime_v1_meta_store_proto protoreflect.FileDescriptor
View Source 
var Heartbeat_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.Heartbeat",
	HandlerType: (*HeartbeatServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AskLeader",
			Handler:    _Heartbeat_AskLeader_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Heartbeat",
			Handler:       _Heartbeat_Heartbeat_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "greptime/v1/meta/heartbeat.proto",
}

Heartbeat_ServiceDesc is the grpc.ServiceDesc for Heartbeat service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Lock_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.Lock",
	HandlerType: (*LockServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Lock",
			Handler:    _Lock_Lock_Handler,
		},
		{
			MethodName: "Unlock",
			Handler:    _Lock_Unlock_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/lock.proto",
}

Lock_ServiceDesc is the grpc.ServiceDesc for Lock service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ProcedureService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.ProcedureService",
	HandlerType: (*ProcedureServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "query",
			Handler:    _ProcedureService_Query_Handler,
		},
		{
			MethodName: "ddl",
			Handler:    _ProcedureService_Ddl_Handler,
		},
		{
			MethodName: "migrate",
			Handler:    _ProcedureService_Migrate_Handler,
		},
		{
			MethodName: "details",
			Handler:    _ProcedureService_Details_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/procedure.proto",
}

ProcedureService_ServiceDesc is the grpc.ServiceDesc for ProcedureService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Router_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.Router",
	HandlerType: (*RouterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Route",
			Handler:    _Router_Route_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/route.proto",
}

Router_ServiceDesc is the grpc.ServiceDesc for Router service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Store_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "greptime.v1.meta.Store",
	HandlerType: (*StoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Range",
			Handler:    _Store_Range_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Store_Put_Handler,
		},
		{
			MethodName: "BatchGet",
			Handler:    _Store_BatchGet_Handler,
		},
		{
			MethodName: "BatchPut",
			Handler:    _Store_BatchPut_Handler,
		},
		{
			MethodName: "BatchDelete",
			Handler:    _Store_BatchDelete_Handler,
		},
		{
			MethodName: "CompareAndPut",
			Handler:    _Store_CompareAndPut_Handler,
		},
		{
			MethodName: "DeleteRange",
			Handler:    _Store_DeleteRange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "greptime/v1/meta/store.proto",
}

Store_ServiceDesc is the grpc.ServiceDesc for Store service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterClusterServer 

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

func RegisterDdlTaskServer 

func RegisterDdlTaskServer(s grpc.ServiceRegistrar, srv DdlTaskServer)

func RegisterHeartbeatServer 

func RegisterHeartbeatServer(s grpc.ServiceRegistrar, srv HeartbeatServer)

func RegisterLockServer 

func RegisterLockServer(s grpc.ServiceRegistrar, srv LockServer)

func RegisterProcedureServiceServer added in v0.7.0 

func RegisterProcedureServiceServer(s grpc.ServiceRegistrar, srv ProcedureServiceServer)

func RegisterRouterServer 

func RegisterRouterServer(s grpc.ServiceRegistrar, srv RouterServer)

func RegisterStoreServer 

func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)

Types

type AlterTableTask 

type AlterTableTask struct {
	AlterTable *v1.AlterExpr `protobuf:"bytes,1,opt,name=alter_table,json=alterTable,proto3" json:"alter_table,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterTableTask) Descriptor deprecated 

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

Deprecated: Use AlterTableTask.ProtoReflect.Descriptor instead.

func (*AlterTableTask) GetAlterTable 

func (x *AlterTableTask) GetAlterTable() *v1.AlterExpr

func (*AlterTableTask) ProtoMessage 

func (*AlterTableTask) ProtoMessage()

func (*AlterTableTask) ProtoReflect 

func (x *AlterTableTask) ProtoReflect() protoreflect.Message

func (*AlterTableTask) Reset 

func (x *AlterTableTask) Reset()

func (*AlterTableTask) String 

func (x *AlterTableTask) String() string

type AlterTableTasks added in v0.4.3 

type AlterTableTasks struct {
	Tasks []*AlterTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterTableTasks) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use AlterTableTasks.ProtoReflect.Descriptor instead.

func (*AlterTableTasks) GetTasks added in v0.4.3 

func (x *AlterTableTasks) GetTasks() []*AlterTableTask

func (*AlterTableTasks) ProtoMessage added in v0.4.3 

func (*AlterTableTasks) ProtoMessage()

func (*AlterTableTasks) ProtoReflect added in v0.4.3 

func (x *AlterTableTasks) ProtoReflect() protoreflect.Message

func (*AlterTableTasks) Reset added in v0.4.3 

func (x *AlterTableTasks) Reset()

func (*AlterTableTasks) String added in v0.4.3 

func (x *AlterTableTasks) String() string

type AskLeaderRequest 

type AskLeaderRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*AskLeaderRequest) Descriptor deprecated 

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

Deprecated: Use AskLeaderRequest.ProtoReflect.Descriptor instead.

func (*AskLeaderRequest) GetHeader 

func (x *AskLeaderRequest) GetHeader() *RequestHeader

func (*AskLeaderRequest) ProtoMessage 

func (*AskLeaderRequest) ProtoMessage()

func (*AskLeaderRequest) ProtoReflect 

func (x *AskLeaderRequest) ProtoReflect() protoreflect.Message

func (*AskLeaderRequest) Reset 

func (x *AskLeaderRequest) Reset()

func (*AskLeaderRequest) String 

func (x *AskLeaderRequest) String() string

type AskLeaderResponse 

type AskLeaderResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Leader *Peer           `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*AskLeaderResponse) Descriptor deprecated 

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

Deprecated: Use AskLeaderResponse.ProtoReflect.Descriptor instead.

func (*AskLeaderResponse) GetHeader 

func (x *AskLeaderResponse) GetHeader() *ResponseHeader

func (*AskLeaderResponse) GetLeader 

func (x *AskLeaderResponse) GetLeader() *Peer

func (*AskLeaderResponse) ProtoMessage 

func (*AskLeaderResponse) ProtoMessage()

func (*AskLeaderResponse) ProtoReflect 

func (x *AskLeaderResponse) ProtoReflect() protoreflect.Message

func (*AskLeaderResponse) Reset 

func (x *AskLeaderResponse) Reset()

func (*AskLeaderResponse) String 

func (x *AskLeaderResponse) String() string

type BatchDeleteRequest 

type BatchDeleteRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keys   [][]byte       `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the batch delete response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchDeleteRequest) Descriptor deprecated 

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

Deprecated: Use BatchDeleteRequest.ProtoReflect.Descriptor instead.

func (*BatchDeleteRequest) GetHeader 

func (x *BatchDeleteRequest) GetHeader() *RequestHeader

func (*BatchDeleteRequest) GetKeys 

func (x *BatchDeleteRequest) GetKeys() [][]byte

func (*BatchDeleteRequest) GetPrevKv 

func (x *BatchDeleteRequest) GetPrevKv() bool

func (*BatchDeleteRequest) ProtoMessage 

func (*BatchDeleteRequest) ProtoMessage()

func (*BatchDeleteRequest) ProtoReflect 

func (x *BatchDeleteRequest) ProtoReflect() protoreflect.Message

func (*BatchDeleteRequest) Reset 

func (x *BatchDeleteRequest) Reset()

func (*BatchDeleteRequest) String 

func (x *BatchDeleteRequest) String() string

type BatchDeleteResponse 

type BatchDeleteResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchDeleteResponse) Descriptor deprecated 

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

Deprecated: Use BatchDeleteResponse.ProtoReflect.Descriptor instead.

func (*BatchDeleteResponse) GetHeader 

func (x *BatchDeleteResponse) GetHeader() *ResponseHeader

func (*BatchDeleteResponse) GetPrevKvs 

func (x *BatchDeleteResponse) GetPrevKvs() []*KeyValue

func (*BatchDeleteResponse) ProtoMessage 

func (*BatchDeleteResponse) ProtoMessage()

func (*BatchDeleteResponse) ProtoReflect 

func (x *BatchDeleteResponse) ProtoReflect() protoreflect.Message

func (*BatchDeleteResponse) Reset 

func (x *BatchDeleteResponse) Reset()

func (*BatchDeleteResponse) String 

func (x *BatchDeleteResponse) String() string

type BatchGetRequest 

type BatchGetRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Keys   [][]byte       `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetRequest) Descriptor deprecated 

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

Deprecated: Use BatchGetRequest.ProtoReflect.Descriptor instead.

func (*BatchGetRequest) GetHeader 

func (x *BatchGetRequest) GetHeader() *RequestHeader

func (*BatchGetRequest) GetKeys 

func (x *BatchGetRequest) GetKeys() [][]byte

func (*BatchGetRequest) ProtoMessage 

func (*BatchGetRequest) ProtoMessage()

func (*BatchGetRequest) ProtoReflect 

func (x *BatchGetRequest) ProtoReflect() protoreflect.Message

func (*BatchGetRequest) Reset 

func (x *BatchGetRequest) Reset()

func (*BatchGetRequest) String 

func (x *BatchGetRequest) String() string

type BatchGetResponse 

type BatchGetResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Kvs    []*KeyValue     `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetResponse) Descriptor deprecated 

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

Deprecated: Use BatchGetResponse.ProtoReflect.Descriptor instead.

func (*BatchGetResponse) GetHeader 

func (x *BatchGetResponse) GetHeader() *ResponseHeader

func (*BatchGetResponse) GetKvs 

func (x *BatchGetResponse) GetKvs() []*KeyValue

func (*BatchGetResponse) ProtoMessage 

func (*BatchGetResponse) ProtoMessage()

func (*BatchGetResponse) ProtoReflect 

func (x *BatchGetResponse) ProtoReflect() protoreflect.Message

func (*BatchGetResponse) Reset 

func (x *BatchGetResponse) Reset()

func (*BatchGetResponse) String 

func (x *BatchGetResponse) String() string

type BatchPutRequest 

type BatchPutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Kvs    []*KeyValue    `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before changing it.
	// The previous key-value pairs will be returned in the batch put response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchPutRequest) Descriptor deprecated 

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

Deprecated: Use BatchPutRequest.ProtoReflect.Descriptor instead.

func (*BatchPutRequest) GetHeader 

func (x *BatchPutRequest) GetHeader() *RequestHeader

func (*BatchPutRequest) GetKvs 

func (x *BatchPutRequest) GetKvs() []*KeyValue

func (*BatchPutRequest) GetPrevKv 

func (x *BatchPutRequest) GetPrevKv() bool

func (*BatchPutRequest) ProtoMessage 

func (*BatchPutRequest) ProtoMessage()

func (*BatchPutRequest) ProtoReflect 

func (x *BatchPutRequest) ProtoReflect() protoreflect.Message

func (*BatchPutRequest) Reset 

func (x *BatchPutRequest) Reset()

func (*BatchPutRequest) String 

func (x *BatchPutRequest) String() string

type BatchPutResponse 

type BatchPutResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchPutResponse) Descriptor deprecated 

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

Deprecated: Use BatchPutResponse.ProtoReflect.Descriptor instead.

func (*BatchPutResponse) GetHeader 

func (x *BatchPutResponse) GetHeader() *ResponseHeader

func (*BatchPutResponse) GetPrevKvs 

func (x *BatchPutResponse) GetPrevKvs() []*KeyValue

func (*BatchPutResponse) ProtoMessage 

func (*BatchPutResponse) ProtoMessage()

func (*BatchPutResponse) ProtoReflect 

func (x *BatchPutResponse) ProtoReflect() protoreflect.Message

func (*BatchPutResponse) Reset 

func (x *BatchPutResponse) Reset()

func (*BatchPutResponse) String 

func (x *BatchPutResponse) String() string

type ClusterClient 

type ClusterClient interface {
	// Batch get kvs by input keys from leader's in_memory kv store.
	BatchGet(ctx context.Context, in *BatchGetRequest, opts ...grpc.CallOption) (*BatchGetResponse, error)
	// Range get the kvs from leader's in_memory kv store.
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	// Returns all the peers of metasrv.
	MetasrvPeers(ctx context.Context, in *MetasrvPeersRequest, opts ...grpc.CallOption) (*MetasrvPeersResponse, error)
}

ClusterClient is the client API for Cluster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer 

type ClusterServer interface {
	// Batch get kvs by input keys from leader's in_memory kv store.
	BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)
	// Range get the kvs from leader's in_memory kv store.
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	// Returns all the peers of metasrv.
	MetasrvPeers(context.Context, *MetasrvPeersRequest) (*MetasrvPeersResponse, error)
	// contains filtered or unexported methods
}

ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility

type CompareAndPutRequest 

type CompareAndPutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// expect is the previous value, in bytes
	Expect []byte `protobuf:"bytes,3,opt,name=expect,proto3" json:"expect,omitempty"`
	// value is the value, in bytes, to associate with the key in the
	// key-value store.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*CompareAndPutRequest) Descriptor deprecated 

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

Deprecated: Use CompareAndPutRequest.ProtoReflect.Descriptor instead.

func (*CompareAndPutRequest) GetExpect 

func (x *CompareAndPutRequest) GetExpect() []byte

func (*CompareAndPutRequest) GetHeader 

func (x *CompareAndPutRequest) GetHeader() *RequestHeader

func (*CompareAndPutRequest) GetKey 

func (x *CompareAndPutRequest) GetKey() []byte

func (*CompareAndPutRequest) GetValue 

func (x *CompareAndPutRequest) GetValue() []byte

func (*CompareAndPutRequest) ProtoMessage 

func (*CompareAndPutRequest) ProtoMessage()

func (*CompareAndPutRequest) ProtoReflect 

func (x *CompareAndPutRequest) ProtoReflect() protoreflect.Message

func (*CompareAndPutRequest) Reset 

func (x *CompareAndPutRequest) Reset()

func (*CompareAndPutRequest) String 

func (x *CompareAndPutRequest) String() string

type CompareAndPutResponse 

type CompareAndPutResponse struct {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Success bool            `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	PrevKv  *KeyValue       `protobuf:"bytes,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*CompareAndPutResponse) Descriptor deprecated 

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

Deprecated: Use CompareAndPutResponse.ProtoReflect.Descriptor instead.

func (*CompareAndPutResponse) GetHeader 

func (x *CompareAndPutResponse) GetHeader() *ResponseHeader

func (*CompareAndPutResponse) GetPrevKv 

func (x *CompareAndPutResponse) GetPrevKv() *KeyValue

func (*CompareAndPutResponse) GetSuccess 

func (x *CompareAndPutResponse) GetSuccess() bool

func (*CompareAndPutResponse) ProtoMessage 

func (*CompareAndPutResponse) ProtoMessage()

func (*CompareAndPutResponse) ProtoReflect 

func (x *CompareAndPutResponse) ProtoReflect() protoreflect.Message

func (*CompareAndPutResponse) Reset 

func (x *CompareAndPutResponse) Reset()

func (*CompareAndPutResponse) String 

func (x *CompareAndPutResponse) String() string

type CreateDatabaseTask added in v0.7.0 

type CreateDatabaseTask struct {
	CreateDatabase *v1.CreateDatabaseExpr `protobuf:"bytes,1,opt,name=create_database,json=createDatabase,proto3" json:"create_database,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseTask) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use CreateDatabaseTask.ProtoReflect.Descriptor instead.

func (*CreateDatabaseTask) GetCreateDatabase added in v0.7.0 

func (x *CreateDatabaseTask) GetCreateDatabase() *v1.CreateDatabaseExpr

func (*CreateDatabaseTask) ProtoMessage added in v0.7.0 

func (*CreateDatabaseTask) ProtoMessage()

func (*CreateDatabaseTask) ProtoReflect added in v0.7.0 

func (x *CreateDatabaseTask) ProtoReflect() protoreflect.Message

func (*CreateDatabaseTask) Reset added in v0.7.0 

func (x *CreateDatabaseTask) Reset()

func (*CreateDatabaseTask) String added in v0.7.0 

func (x *CreateDatabaseTask) String() string

type CreateFlowTask added in v0.7.0 

type CreateFlowTask struct {
	CreateFlow *v1.CreateFlowExpr `protobuf:"bytes,1,opt,name=create_flow,json=createFlow,proto3" json:"create_flow,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFlowTask) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use CreateFlowTask.ProtoReflect.Descriptor instead.

func (*CreateFlowTask) GetCreateFlow added in v0.9.0 

func (x *CreateFlowTask) GetCreateFlow() *v1.CreateFlowExpr

func (*CreateFlowTask) ProtoMessage added in v0.7.0 

func (*CreateFlowTask) ProtoMessage()

func (*CreateFlowTask) ProtoReflect added in v0.7.0 

func (x *CreateFlowTask) ProtoReflect() protoreflect.Message

func (*CreateFlowTask) Reset added in v0.7.0 

func (x *CreateFlowTask) Reset()

func (*CreateFlowTask) String added in v0.7.0 

func (x *CreateFlowTask) String() string

type CreateTableTask 

type CreateTableTask struct {
	CreateTable *v1.CreateTableExpr `protobuf:"bytes,1,opt,name=create_table,json=createTable,proto3" json:"create_table,omitempty"`
	Partitions  []*Partition        `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	TableInfo   []byte              `protobuf:"bytes,3,opt,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableTask) Descriptor deprecated 

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

Deprecated: Use CreateTableTask.ProtoReflect.Descriptor instead.

func (*CreateTableTask) GetCreateTable 

func (x *CreateTableTask) GetCreateTable() *v1.CreateTableExpr

func (*CreateTableTask) GetPartitions 

func (x *CreateTableTask) GetPartitions() []*Partition

func (*CreateTableTask) GetTableInfo 

func (x *CreateTableTask) GetTableInfo() []byte

func (*CreateTableTask) ProtoMessage 

func (*CreateTableTask) ProtoMessage()

func (*CreateTableTask) ProtoReflect 

func (x *CreateTableTask) ProtoReflect() protoreflect.Message

func (*CreateTableTask) Reset 

func (x *CreateTableTask) Reset()

func (*CreateTableTask) String 

func (x *CreateTableTask) String() string

type CreateTableTasks added in v0.4.3 

type CreateTableTasks struct {
	Tasks []*CreateTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableTasks) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use CreateTableTasks.ProtoReflect.Descriptor instead.

func (*CreateTableTasks) GetTasks added in v0.4.3 

func (x *CreateTableTasks) GetTasks() []*CreateTableTask

func (*CreateTableTasks) ProtoMessage added in v0.4.3 

func (*CreateTableTasks) ProtoMessage()

func (*CreateTableTasks) ProtoReflect added in v0.4.3 

func (x *CreateTableTasks) ProtoReflect() protoreflect.Message

func (*CreateTableTasks) Reset added in v0.4.3 

func (x *CreateTableTasks) Reset()

func (*CreateTableTasks) String added in v0.4.3 

func (x *CreateTableTasks) String() string

type CreateViewTask added in v0.9.0 

type CreateViewTask struct {
	CreateView *v1.CreateViewExpr `protobuf:"bytes,1,opt,name=create_view,json=createView,proto3" json:"create_view,omitempty"`
	ViewInfo   []byte             `protobuf:"bytes,2,opt,name=view_info,json=viewInfo,proto3" json:"view_info,omitempty"`
	// contains filtered or unexported fields
}

Create a view task

func (*CreateViewTask) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use CreateViewTask.ProtoReflect.Descriptor instead.

func (*CreateViewTask) GetCreateView added in v0.9.0 

func (x *CreateViewTask) GetCreateView() *v1.CreateViewExpr

func (*CreateViewTask) GetViewInfo added in v0.9.0 

func (x *CreateViewTask) GetViewInfo() []byte

func (*CreateViewTask) ProtoMessage added in v0.9.0 

func (*CreateViewTask) ProtoMessage()

func (*CreateViewTask) ProtoReflect added in v0.9.0 

func (x *CreateViewTask) ProtoReflect() protoreflect.Message

func (*CreateViewTask) Reset added in v0.9.0 

func (x *CreateViewTask) Reset()

func (*CreateViewTask) String added in v0.9.0 

func (x *CreateViewTask) String() string

type DdlTaskClient 

type DdlTaskClient interface {
	// Submits a DDL task to meta.
	SubmitDdlTask(ctx context.Context, in *SubmitDdlTaskRequest, opts ...grpc.CallOption) (*SubmitDdlTaskResponse, error)
}

DdlTaskClient is the client API for DdlTask service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDdlTaskClient 

func NewDdlTaskClient(cc grpc.ClientConnInterface) DdlTaskClient

type DdlTaskRequest added in v0.7.0 

type DdlTaskRequest struct {
	Header       *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	QueryContext *v1.QueryContext `protobuf:"bytes,64,opt,name=query_context,json=queryContext,proto3" json:"query_context,omitempty"`
	// Types that are assignable to Task:
	//
	//	*DdlTaskRequest_CreateTableTask
	//	*DdlTaskRequest_DropTableTask
	//	*DdlTaskRequest_AlterTableTask
	//	*DdlTaskRequest_TruncateTableTask
	//	*DdlTaskRequest_CreateTableTasks
	//	*DdlTaskRequest_DropTableTasks
	//	*DdlTaskRequest_AlterTableTasks
	//	*DdlTaskRequest_DropDatabaseTask
	//	*DdlTaskRequest_CreateDatabaseTask
	//	*DdlTaskRequest_CreateFlowTask
	//	*DdlTaskRequest_DropFlowTask
	//	*DdlTaskRequest_CreateViewTask
	//	*DdlTaskRequest_DropViewTask
	Task isDdlTaskRequest_Task `protobuf_oneof:"task"`
	// contains filtered or unexported fields
}

func (*DdlTaskRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DdlTaskRequest.ProtoReflect.Descriptor instead.

func (*DdlTaskRequest) GetAlterTableTask added in v0.7.0 

func (x *DdlTaskRequest) GetAlterTableTask() *AlterTableTask

func (*DdlTaskRequest) GetAlterTableTasks added in v0.7.0 

func (x *DdlTaskRequest) GetAlterTableTasks() *AlterTableTasks

func (*DdlTaskRequest) GetCreateDatabaseTask added in v0.7.0 

func (x *DdlTaskRequest) GetCreateDatabaseTask() *CreateDatabaseTask

func (*DdlTaskRequest) GetCreateFlowTask added in v0.7.0 

func (x *DdlTaskRequest) GetCreateFlowTask() *CreateFlowTask

func (*DdlTaskRequest) GetCreateTableTask added in v0.7.0 

func (x *DdlTaskRequest) GetCreateTableTask() *CreateTableTask

func (*DdlTaskRequest) GetCreateTableTasks added in v0.7.0 

func (x *DdlTaskRequest) GetCreateTableTasks() *CreateTableTasks

func (*DdlTaskRequest) GetCreateViewTask added in v0.9.0 

func (x *DdlTaskRequest) GetCreateViewTask() *CreateViewTask

func (*DdlTaskRequest) GetDropDatabaseTask added in v0.7.0 

func (x *DdlTaskRequest) GetDropDatabaseTask() *DropDatabaseTask

func (*DdlTaskRequest) GetDropFlowTask added in v0.7.0 

func (x *DdlTaskRequest) GetDropFlowTask() *DropFlowTask

func (*DdlTaskRequest) GetDropTableTask added in v0.7.0 

func (x *DdlTaskRequest) GetDropTableTask() *DropTableTask

func (*DdlTaskRequest) GetDropTableTasks added in v0.7.0 

func (x *DdlTaskRequest) GetDropTableTasks() *DropTableTasks

func (*DdlTaskRequest) GetDropViewTask added in v0.9.0 

func (x *DdlTaskRequest) GetDropViewTask() *DropViewTask

func (*DdlTaskRequest) GetHeader added in v0.7.0 

func (x *DdlTaskRequest) GetHeader() *RequestHeader

func (*DdlTaskRequest) GetQueryContext added in v0.9.0 

func (x *DdlTaskRequest) GetQueryContext() *v1.QueryContext

func (*DdlTaskRequest) GetTask added in v0.7.0 

func (m *DdlTaskRequest) GetTask() isDdlTaskRequest_Task

func (*DdlTaskRequest) GetTruncateTableTask added in v0.7.0 

func (x *DdlTaskRequest) GetTruncateTableTask() *TruncateTableTask

func (*DdlTaskRequest) ProtoMessage added in v0.7.0 

func (*DdlTaskRequest) ProtoMessage()

func (*DdlTaskRequest) ProtoReflect added in v0.7.0 

func (x *DdlTaskRequest) ProtoReflect() protoreflect.Message

func (*DdlTaskRequest) Reset added in v0.7.0 

func (x *DdlTaskRequest) Reset()

func (*DdlTaskRequest) String added in v0.7.0 

func (x *DdlTaskRequest) String() string

type DdlTaskRequest_AlterTableTask added in v0.7.0 

type DdlTaskRequest_AlterTableTask struct {
	AlterTableTask *AlterTableTask `protobuf:"bytes,4,opt,name=alter_table_task,json=alterTableTask,proto3,oneof"`
}

type DdlTaskRequest_AlterTableTasks added in v0.7.0 

type DdlTaskRequest_AlterTableTasks struct {
	AlterTableTasks *AlterTableTasks `protobuf:"bytes,8,opt,name=alter_table_tasks,json=alterTableTasks,proto3,oneof"`
}

type DdlTaskRequest_CreateDatabaseTask added in v0.7.0 

type DdlTaskRequest_CreateDatabaseTask struct {
	CreateDatabaseTask *CreateDatabaseTask `protobuf:"bytes,10,opt,name=create_database_task,json=createDatabaseTask,proto3,oneof"`
}

type DdlTaskRequest_CreateFlowTask added in v0.7.0 

type DdlTaskRequest_CreateFlowTask struct {
	CreateFlowTask *CreateFlowTask `protobuf:"bytes,11,opt,name=create_flow_task,json=createFlowTask,proto3,oneof"`
}

type DdlTaskRequest_CreateTableTask added in v0.7.0 

type DdlTaskRequest_CreateTableTask struct {
	CreateTableTask *CreateTableTask `protobuf:"bytes,2,opt,name=create_table_task,json=createTableTask,proto3,oneof"`
}

type DdlTaskRequest_CreateTableTasks added in v0.7.0 

type DdlTaskRequest_CreateTableTasks struct {
	CreateTableTasks *CreateTableTasks `protobuf:"bytes,6,opt,name=create_table_tasks,json=createTableTasks,proto3,oneof"`
}

type DdlTaskRequest_CreateViewTask added in v0.9.0 

type DdlTaskRequest_CreateViewTask struct {
	CreateViewTask *CreateViewTask `protobuf:"bytes,13,opt,name=create_view_task,json=createViewTask,proto3,oneof"`
}

type DdlTaskRequest_DropDatabaseTask added in v0.7.0 

type DdlTaskRequest_DropDatabaseTask struct {
	DropDatabaseTask *DropDatabaseTask `protobuf:"bytes,9,opt,name=drop_database_task,json=dropDatabaseTask,proto3,oneof"`
}

type DdlTaskRequest_DropFlowTask added in v0.7.0 

type DdlTaskRequest_DropFlowTask struct {
	DropFlowTask *DropFlowTask `protobuf:"bytes,12,opt,name=drop_flow_task,json=dropFlowTask,proto3,oneof"`
}

type DdlTaskRequest_DropTableTask added in v0.7.0 

type DdlTaskRequest_DropTableTask struct {
	DropTableTask *DropTableTask `protobuf:"bytes,3,opt,name=drop_table_task,json=dropTableTask,proto3,oneof"`
}

type DdlTaskRequest_DropTableTasks added in v0.7.0 

type DdlTaskRequest_DropTableTasks struct {
	DropTableTasks *DropTableTasks `protobuf:"bytes,7,opt,name=drop_table_tasks,json=dropTableTasks,proto3,oneof"`
}

type DdlTaskRequest_DropViewTask added in v0.9.0 

type DdlTaskRequest_DropViewTask struct {
	DropViewTask *DropViewTask `protobuf:"bytes,14,opt,name=drop_view_task,json=dropViewTask,proto3,oneof"`
}

type DdlTaskRequest_TruncateTableTask added in v0.7.0 

type DdlTaskRequest_TruncateTableTask struct {
	TruncateTableTask *TruncateTableTask `protobuf:"bytes,5,opt,name=truncate_table_task,json=truncateTableTask,proto3,oneof"`
}

type DdlTaskResponse added in v0.7.0 

type DdlTaskResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId    `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// Returns if the tables created.
	TableIds []*v1.TableId `protobuf:"bytes,5,rep,name=table_ids,json=tableIds,proto3" json:"table_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DdlTaskResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DdlTaskResponse.ProtoReflect.Descriptor instead.

func (*DdlTaskResponse) GetHeader added in v0.7.0 

func (x *DdlTaskResponse) GetHeader() *ResponseHeader

func (*DdlTaskResponse) GetPid added in v0.7.0 

func (x *DdlTaskResponse) GetPid() *ProcedureId

func (*DdlTaskResponse) GetTableIds added in v0.7.0 

func (x *DdlTaskResponse) GetTableIds() []*v1.TableId

func (*DdlTaskResponse) ProtoMessage added in v0.7.0 

func (*DdlTaskResponse) ProtoMessage()

func (*DdlTaskResponse) ProtoReflect added in v0.7.0 

func (x *DdlTaskResponse) ProtoReflect() protoreflect.Message

func (*DdlTaskResponse) Reset added in v0.7.0 

func (x *DdlTaskResponse) Reset()

func (*DdlTaskResponse) String added in v0.7.0 

func (x *DdlTaskResponse) String() string

type DdlTaskServer 

type DdlTaskServer interface {
	// Submits a DDL task to meta.
	SubmitDdlTask(context.Context, *SubmitDdlTaskRequest) (*SubmitDdlTaskResponse, error)
	// contains filtered or unexported methods
}

DdlTaskServer is the server API for DdlTask service. All implementations must embed UnimplementedDdlTaskServer for forward compatibility

type DdlTaskType 

type DdlTaskType int32
const (
	DdlTaskType_Create DdlTaskType = 0
	DdlTaskType_Drop   DdlTaskType = 1
)

func (DdlTaskType) Descriptor 

func (DdlTaskType) Descriptor() protoreflect.EnumDescriptor

func (DdlTaskType) Enum 

func (x DdlTaskType) Enum() *DdlTaskType

func (DdlTaskType) EnumDescriptor deprecated 

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

Deprecated: Use DdlTaskType.Descriptor instead.

func (DdlTaskType) Number 

func (x DdlTaskType) Number() protoreflect.EnumNumber

func (DdlTaskType) String 

func (x DdlTaskType) String() string

func (DdlTaskType) Type 

func (DdlTaskType) Type() protoreflect.EnumType

type DeleteRangeRequest 

type DeleteRangeRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the first key to delete in the range.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the key following the last key to delete for the range
	// [key, range_end).
	// If range_end is not given, the range is defined to contain only the key
	// argument.
	// If range_end is one bit larger than the given key, then the range is all
	// the keys with the prefix (the given key).
	// If range_end is '\0', the range is all keys greater than or equal to the
	// key argument.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// If prev_kv is set, gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRangeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRangeRequest.ProtoReflect.Descriptor instead.

func (*DeleteRangeRequest) GetHeader 

func (x *DeleteRangeRequest) GetHeader() *RequestHeader

func (*DeleteRangeRequest) GetKey 

func (x *DeleteRangeRequest) GetKey() []byte

func (*DeleteRangeRequest) GetPrevKv 

func (x *DeleteRangeRequest) GetPrevKv() bool

func (*DeleteRangeRequest) GetRangeEnd 

func (x *DeleteRangeRequest) GetRangeEnd() []byte

func (*DeleteRangeRequest) ProtoMessage 

func (*DeleteRangeRequest) ProtoMessage()

func (*DeleteRangeRequest) ProtoReflect 

func (x *DeleteRangeRequest) ProtoReflect() protoreflect.Message

func (*DeleteRangeRequest) Reset 

func (x *DeleteRangeRequest) Reset()

func (*DeleteRangeRequest) String 

func (x *DeleteRangeRequest) String() string

type DeleteRangeResponse 

type DeleteRangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// If prev_kv is set in the request, the previous key-value pairs will be
	// returned.
	PrevKvs []*KeyValue `protobuf:"bytes,3,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRangeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRangeResponse.ProtoReflect.Descriptor instead.

func (*DeleteRangeResponse) GetDeleted 

func (x *DeleteRangeResponse) GetDeleted() int64

func (*DeleteRangeResponse) GetHeader 

func (x *DeleteRangeResponse) GetHeader() *ResponseHeader

func (*DeleteRangeResponse) GetPrevKvs 

func (x *DeleteRangeResponse) GetPrevKvs() []*KeyValue

func (*DeleteRangeResponse) ProtoMessage 

func (*DeleteRangeResponse) ProtoMessage()

func (*DeleteRangeResponse) ProtoReflect 

func (x *DeleteRangeResponse) ProtoReflect() protoreflect.Message

func (*DeleteRangeResponse) Reset 

func (x *DeleteRangeResponse) Reset()

func (*DeleteRangeResponse) String 

func (x *DeleteRangeResponse) String() string

type DropDatabaseTask added in v0.7.0 

type DropDatabaseTask struct {
	DropDatabase *v1.DropDatabaseExpr `protobuf:"bytes,1,opt,name=drop_database,json=dropDatabase,proto3" json:"drop_database,omitempty"`
	// contains filtered or unexported fields
}

func (*DropDatabaseTask) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DropDatabaseTask.ProtoReflect.Descriptor instead.

func (*DropDatabaseTask) GetDropDatabase added in v0.7.0 

func (x *DropDatabaseTask) GetDropDatabase() *v1.DropDatabaseExpr

func (*DropDatabaseTask) ProtoMessage added in v0.7.0 

func (*DropDatabaseTask) ProtoMessage()

func (*DropDatabaseTask) ProtoReflect added in v0.7.0 

func (x *DropDatabaseTask) ProtoReflect() protoreflect.Message

func (*DropDatabaseTask) Reset added in v0.7.0 

func (x *DropDatabaseTask) Reset()

func (*DropDatabaseTask) String added in v0.7.0 

func (x *DropDatabaseTask) String() string

type DropFlowTask added in v0.7.0 

type DropFlowTask struct {
	DropFlow *v1.DropFlowExpr `protobuf:"bytes,1,opt,name=drop_flow,json=dropFlow,proto3" json:"drop_flow,omitempty"`
	// contains filtered or unexported fields
}

func (*DropFlowTask) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use DropFlowTask.ProtoReflect.Descriptor instead.

func (*DropFlowTask) GetDropFlow added in v0.9.0 

func (x *DropFlowTask) GetDropFlow() *v1.DropFlowExpr

func (*DropFlowTask) ProtoMessage added in v0.7.0 

func (*DropFlowTask) ProtoMessage()

func (*DropFlowTask) ProtoReflect added in v0.7.0 

func (x *DropFlowTask) ProtoReflect() protoreflect.Message

func (*DropFlowTask) Reset added in v0.7.0 

func (x *DropFlowTask) Reset()

func (*DropFlowTask) String added in v0.7.0 

func (x *DropFlowTask) String() string

type DropTableTask 

type DropTableTask struct {
	DropTable *v1.DropTableExpr `protobuf:"bytes,1,opt,name=drop_table,json=dropTable,proto3" json:"drop_table,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableTask) Descriptor deprecated 

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

Deprecated: Use DropTableTask.ProtoReflect.Descriptor instead.

func (*DropTableTask) GetDropTable 

func (x *DropTableTask) GetDropTable() *v1.DropTableExpr

func (*DropTableTask) ProtoMessage 

func (*DropTableTask) ProtoMessage()

func (*DropTableTask) ProtoReflect 

func (x *DropTableTask) ProtoReflect() protoreflect.Message

func (*DropTableTask) Reset 

func (x *DropTableTask) Reset()

func (*DropTableTask) String 

func (x *DropTableTask) String() string

type DropTableTasks added in v0.4.3 

type DropTableTasks struct {
	Tasks []*DropTableTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableTasks) Descriptor deprecated added in v0.4.3 

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

Deprecated: Use DropTableTasks.ProtoReflect.Descriptor instead.

func (*DropTableTasks) GetTasks added in v0.4.3 

func (x *DropTableTasks) GetTasks() []*DropTableTask

func (*DropTableTasks) ProtoMessage added in v0.4.3 

func (*DropTableTasks) ProtoMessage()

func (*DropTableTasks) ProtoReflect added in v0.4.3 

func (x *DropTableTasks) ProtoReflect() protoreflect.Message

func (*DropTableTasks) Reset added in v0.4.3 

func (x *DropTableTasks) Reset()

func (*DropTableTasks) String added in v0.4.3 

func (x *DropTableTasks) String() string

type DropViewTask added in v0.9.0 

type DropViewTask struct {
	DropView *v1.DropViewExpr `protobuf:"bytes,1,opt,name=drop_view,json=dropView,proto3" json:"drop_view,omitempty"`
	// contains filtered or unexported fields
}

Drop a view task

func (*DropViewTask) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DropViewTask.ProtoReflect.Descriptor instead.

func (*DropViewTask) GetDropView added in v0.9.0 

func (x *DropViewTask) GetDropView() *v1.DropViewExpr

func (*DropViewTask) ProtoMessage added in v0.9.0 

func (*DropViewTask) ProtoMessage()

func (*DropViewTask) ProtoReflect added in v0.9.0 

func (x *DropViewTask) ProtoReflect() protoreflect.Message

func (*DropViewTask) Reset added in v0.9.0 

func (x *DropViewTask) Reset()

func (*DropViewTask) String added in v0.9.0 

func (x *DropViewTask) String() string

type Error 

type Error struct {
	Code   int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() int32

func (*Error) GetErrMsg 

func (x *Error) GetErrMsg() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FlowStat added in v0.9.0 

type FlowStat struct {

	// Each flow's in mem state's size in bytes
	// due to protobuf's key can't be a message, so we use uint32 as the key which
	// is [`FlowId`]'s inner field `id`
	FlowStatSize map[uint32]uint64 `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FlowStat) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use FlowStat.ProtoReflect.Descriptor instead.

func (*FlowStat) GetFlowStatSize added in v0.9.0 

func (x *FlowStat) GetFlowStatSize() map[uint32]uint64

func (*FlowStat) ProtoMessage added in v0.9.0 

func (*FlowStat) ProtoMessage()

func (*FlowStat) ProtoReflect added in v0.9.0 

func (x *FlowStat) ProtoReflect() protoreflect.Message

func (*FlowStat) Reset added in v0.9.0 

func (x *FlowStat) Reset()

func (*FlowStat) String added in v0.9.0 

func (x *FlowStat) String() string

type GrantedRegion added in v0.4.1 

type GrantedRegion struct {
	RegionId uint64     `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Role     RegionRole `protobuf:"varint,2,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantedRegion) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use GrantedRegion.ProtoReflect.Descriptor instead.

func (*GrantedRegion) GetRegionId added in v0.4.1 

func (x *GrantedRegion) GetRegionId() uint64

func (*GrantedRegion) GetRole added in v0.4.1 

func (x *GrantedRegion) GetRole() RegionRole

func (*GrantedRegion) ProtoMessage added in v0.4.1 

func (*GrantedRegion) ProtoMessage()

func (*GrantedRegion) ProtoReflect added in v0.4.1 

func (x *GrantedRegion) ProtoReflect() protoreflect.Message

func (*GrantedRegion) Reset added in v0.4.1 

func (x *GrantedRegion) Reset()

func (*GrantedRegion) String added in v0.4.1 

func (x *GrantedRegion) String() string

type HeartbeatClient 

type HeartbeatClient interface {
	// Heartbeat, there may be many contents of the heartbeat, such as:
	//  1. Metadata to be registered to meta server and discoverable by other
	//     nodes.
	//  2. Some performance metrics, such as Load, CPU usage, etc.
	//  3. The number of computing tasks being executed.
	Heartbeat(ctx context.Context, opts ...grpc.CallOption) (Heartbeat_HeartbeatClient, error)
	// Ask leader's endpoint.
	AskLeader(ctx context.Context, in *AskLeaderRequest, opts ...grpc.CallOption) (*AskLeaderResponse, error)
}

HeartbeatClient is the client API for Heartbeat service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHeartbeatClient 

func NewHeartbeatClient(cc grpc.ClientConnInterface) HeartbeatClient

type HeartbeatRequest 

type HeartbeatRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Self peer
	Peer *Peer `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	// Actually reported time interval
	ReportInterval *TimeInterval `protobuf:"bytes,3,opt,name=report_interval,json=reportInterval,proto3" json:"report_interval,omitempty"`
	// Region stats on this node
	RegionStats []*RegionStat `protobuf:"bytes,4,rep,name=region_stats,json=regionStats,proto3" json:"region_stats,omitempty"`
	// Mailbox send message to Metasrv
	MailboxMessage *MailboxMessage `protobuf:"bytes,5,opt,name=mailbox_message,json=mailboxMessage,proto3" json:"mailbox_message,omitempty"`
	// The duration since the heartbeat task's epoch in milliseconds.
	DurationSinceEpoch uint64 `protobuf:"varint,6,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"`
	// The node's epoch
	NodeEpoch uint64    `protobuf:"varint,7,opt,name=node_epoch,json=nodeEpoch,proto3" json:"node_epoch,omitempty"`
	Info      *NodeInfo `protobuf:"bytes,8,opt,name=info,proto3" json:"info,omitempty"`
	FlowStat  *FlowStat `protobuf:"bytes,9,opt,name=flow_stat,json=flowStat,proto3" json:"flow_stat,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetDurationSinceEpoch 

func (x *HeartbeatRequest) GetDurationSinceEpoch() uint64

func (*HeartbeatRequest) GetFlowStat added in v0.9.0 

func (x *HeartbeatRequest) GetFlowStat() *FlowStat

func (*HeartbeatRequest) GetHeader 

func (x *HeartbeatRequest) GetHeader() *RequestHeader

func (*HeartbeatRequest) GetInfo added in v0.9.0 

func (x *HeartbeatRequest) GetInfo() *NodeInfo

func (*HeartbeatRequest) GetMailboxMessage 

func (x *HeartbeatRequest) GetMailboxMessage() *MailboxMessage

func (*HeartbeatRequest) GetNodeEpoch 

func (x *HeartbeatRequest) GetNodeEpoch() uint64

func (*HeartbeatRequest) GetPeer 

func (x *HeartbeatRequest) GetPeer() *Peer

func (*HeartbeatRequest) GetRegionStats 

func (x *HeartbeatRequest) GetRegionStats() []*RegionStat

func (*HeartbeatRequest) GetReportInterval 

func (x *HeartbeatRequest) GetReportInterval() *TimeInterval

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	Header         *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	MailboxMessage *MailboxMessage `protobuf:"bytes,2,opt,name=mailbox_message,json=mailboxMessage,proto3" json:"mailbox_message,omitempty"`
	RegionLease    *RegionLease    `protobuf:"bytes,3,opt,name=region_lease,json=regionLease,proto3" json:"region_lease,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetHeader 

func (x *HeartbeatResponse) GetHeader() *ResponseHeader

func (*HeartbeatResponse) GetMailboxMessage 

func (x *HeartbeatResponse) GetMailboxMessage() *MailboxMessage

func (*HeartbeatResponse) GetRegionLease added in v0.4.0 

func (x *HeartbeatResponse) GetRegionLease() *RegionLease

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type HeartbeatServer 

type HeartbeatServer interface {
	// Heartbeat, there may be many contents of the heartbeat, such as:
	//  1. Metadata to be registered to meta server and discoverable by other
	//     nodes.
	//  2. Some performance metrics, such as Load, CPU usage, etc.
	//  3. The number of computing tasks being executed.
	Heartbeat(Heartbeat_HeartbeatServer) error
	// Ask leader's endpoint.
	AskLeader(context.Context, *AskLeaderRequest) (*AskLeaderResponse, error)
	// contains filtered or unexported methods
}

HeartbeatServer is the server API for Heartbeat service. All implementations must embed UnimplementedHeartbeatServer for forward compatibility

type Heartbeat_HeartbeatClient 

type Heartbeat_HeartbeatClient interface {
	Send(*HeartbeatRequest) error
	Recv() (*HeartbeatResponse, error)
	grpc.ClientStream
}

type Heartbeat_HeartbeatServer 

type Heartbeat_HeartbeatServer interface {
	Send(*HeartbeatResponse) error
	Recv() (*HeartbeatRequest, error)
	grpc.ServerStream
}

type KeyValue 

type KeyValue struct {

	// key is the key in bytes. An empty key is not allowed.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value held by the key, in bytes.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() []byte

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() []byte

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect 

func (x *KeyValue) ProtoReflect() protoreflect.Message

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type LockClient 

type LockClient interface {
	// Lock acquires a distributed shared lock on a given named lock. On success,
	// it will return a unique key that exists so long as the lock is held by the
	// caller.
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	// Unlock takes a key returned by Lock and releases the hold on lock.
	Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
}

LockClient is the client API for Lock service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLockClient 

func NewLockClient(cc grpc.ClientConnInterface) LockClient

type LockRequest 

type LockRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Name is the identifier for the distributed shared lock to be acquired.
	Name []byte `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// If the expiration time is exceeded and currently holds the lock, the lock
	// is automatically released.
	ExpireSecs int64 `protobuf:"varint,3,opt,name=expire_secs,json=expireSecs,proto3" json:"expire_secs,omitempty"`
	// contains filtered or unexported fields
}

func (*LockRequest) Descriptor deprecated 

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

Deprecated: Use LockRequest.ProtoReflect.Descriptor instead.

func (*LockRequest) GetExpireSecs 

func (x *LockRequest) GetExpireSecs() int64

func (*LockRequest) GetHeader 

func (x *LockRequest) GetHeader() *RequestHeader

func (*LockRequest) GetName 

func (x *LockRequest) GetName() []byte

func (*LockRequest) ProtoMessage 

func (*LockRequest) ProtoMessage()

func (*LockRequest) ProtoReflect 

func (x *LockRequest) ProtoReflect() protoreflect.Message

func (*LockRequest) Reset 

func (x *LockRequest) Reset()

func (*LockRequest) String 

func (x *LockRequest) String() string

type LockResponse 

type LockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Key will exist as long as lock is held by the caller.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LockResponse) Descriptor deprecated 

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

Deprecated: Use LockResponse.ProtoReflect.Descriptor instead.

func (*LockResponse) GetHeader 

func (x *LockResponse) GetHeader() *ResponseHeader

func (*LockResponse) GetKey 

func (x *LockResponse) GetKey() []byte

func (*LockResponse) ProtoMessage 

func (*LockResponse) ProtoMessage()

func (*LockResponse) ProtoReflect 

func (x *LockResponse) ProtoReflect() protoreflect.Message

func (*LockResponse) Reset 

func (x *LockResponse) Reset()

func (*LockResponse) String 

func (x *LockResponse) String() string

type LockServer 

type LockServer interface {
	// Lock acquires a distributed shared lock on a given named lock. On success,
	// it will return a unique key that exists so long as the lock is held by the
	// caller.
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	// Unlock takes a key returned by Lock and releases the hold on lock.
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	// contains filtered or unexported methods
}

LockServer is the server API for Lock service. All implementations must embed UnimplementedLockServer for forward compatibility

type MailboxMessage 

type MailboxMessage struct {

	// The id is used to associate request and response.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The following information plays a bigger role in making messages traceable
	// and facilitating debugging.
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	From    string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	To      string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"`
	// The unix timestamp in milliseconds.
	TimestampMillis int64 `protobuf:"varint,5,opt,name=timestamp_millis,json=timestampMillis,proto3" json:"timestamp_millis,omitempty"`
	// The message body.
	//
	// Types that are assignable to Payload:
	//
	//	*MailboxMessage_Json
	Payload isMailboxMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*MailboxMessage) Descriptor deprecated 

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

Deprecated: Use MailboxMessage.ProtoReflect.Descriptor instead.

func (*MailboxMessage) GetFrom 

func (x *MailboxMessage) GetFrom() string

func (*MailboxMessage) GetId 

func (x *MailboxMessage) GetId() uint64

func (*MailboxMessage) GetJson 

func (x *MailboxMessage) GetJson() string

func (*MailboxMessage) GetPayload 

func (m *MailboxMessage) GetPayload() isMailboxMessage_Payload

func (*MailboxMessage) GetSubject 

func (x *MailboxMessage) GetSubject() string

func (*MailboxMessage) GetTimestampMillis 

func (x *MailboxMessage) GetTimestampMillis() int64

func (*MailboxMessage) GetTo 

func (x *MailboxMessage) GetTo() string

func (*MailboxMessage) ProtoMessage 

func (*MailboxMessage) ProtoMessage()

func (*MailboxMessage) ProtoReflect 

func (x *MailboxMessage) ProtoReflect() protoreflect.Message

func (*MailboxMessage) Reset 

func (x *MailboxMessage) Reset()

func (*MailboxMessage) String 

func (x *MailboxMessage) String() string

type MailboxMessage_Json 

type MailboxMessage_Json struct {
	Json string `protobuf:"bytes,6,opt,name=json,proto3,oneof"`
}

type MetasrvNodeInfo added in v0.9.0 

type MetasrvNodeInfo struct {
	Peer      *Peer  `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	GitCommit string `protobuf:"bytes,3,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	// The node start timestamp in milliseconds.
	StartTimeMs uint64 `protobuf:"varint,4,opt,name=start_time_ms,json=startTimeMs,proto3" json:"start_time_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*MetasrvNodeInfo) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use MetasrvNodeInfo.ProtoReflect.Descriptor instead.

func (*MetasrvNodeInfo) GetGitCommit added in v0.9.0 

func (x *MetasrvNodeInfo) GetGitCommit() string

func (*MetasrvNodeInfo) GetPeer added in v0.9.0 

func (x *MetasrvNodeInfo) GetPeer() *Peer

func (*MetasrvNodeInfo) GetStartTimeMs added in v0.9.0 

func (x *MetasrvNodeInfo) GetStartTimeMs() uint64

func (*MetasrvNodeInfo) GetVersion added in v0.9.0 

func (x *MetasrvNodeInfo) GetVersion() string

func (*MetasrvNodeInfo) ProtoMessage added in v0.9.0 

func (*MetasrvNodeInfo) ProtoMessage()

func (*MetasrvNodeInfo) ProtoReflect added in v0.9.0 

func (x *MetasrvNodeInfo) ProtoReflect() protoreflect.Message

func (*MetasrvNodeInfo) Reset added in v0.9.0 

func (x *MetasrvNodeInfo) Reset()

func (*MetasrvNodeInfo) String added in v0.9.0 

func (x *MetasrvNodeInfo) String() string

type MetasrvPeersRequest added in v0.7.0 

type MetasrvPeersRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*MetasrvPeersRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use MetasrvPeersRequest.ProtoReflect.Descriptor instead.

func (*MetasrvPeersRequest) GetHeader added in v0.7.0 

func (x *MetasrvPeersRequest) GetHeader() *RequestHeader

func (*MetasrvPeersRequest) ProtoMessage added in v0.7.0 

func (*MetasrvPeersRequest) ProtoMessage()

func (*MetasrvPeersRequest) ProtoReflect added in v0.7.0 

func (x *MetasrvPeersRequest) ProtoReflect() protoreflect.Message

func (*MetasrvPeersRequest) Reset added in v0.7.0 

func (x *MetasrvPeersRequest) Reset()

func (*MetasrvPeersRequest) String added in v0.7.0 

func (x *MetasrvPeersRequest) String() string

type MetasrvPeersResponse added in v0.7.0 

type MetasrvPeersResponse struct {
	Header    *ResponseHeader    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Leader    *MetasrvNodeInfo   `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	Followers []*MetasrvNodeInfo `protobuf:"bytes,3,rep,name=followers,proto3" json:"followers,omitempty"`
	// contains filtered or unexported fields
}

func (*MetasrvPeersResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use MetasrvPeersResponse.ProtoReflect.Descriptor instead.

func (*MetasrvPeersResponse) GetFollowers added in v0.7.0 

func (x *MetasrvPeersResponse) GetFollowers() []*MetasrvNodeInfo

func (*MetasrvPeersResponse) GetHeader added in v0.7.0 

func (x *MetasrvPeersResponse) GetHeader() *ResponseHeader

func (*MetasrvPeersResponse) GetLeader added in v0.7.0 

func (x *MetasrvPeersResponse) GetLeader() *MetasrvNodeInfo

func (*MetasrvPeersResponse) ProtoMessage added in v0.7.0 

func (*MetasrvPeersResponse) ProtoMessage()

func (*MetasrvPeersResponse) ProtoReflect added in v0.7.0 

func (x *MetasrvPeersResponse) ProtoReflect() protoreflect.Message

func (*MetasrvPeersResponse) Reset added in v0.7.0 

func (x *MetasrvPeersResponse) Reset()

func (*MetasrvPeersResponse) String added in v0.7.0 

func (x *MetasrvPeersResponse) String() string

type MigrateRegionRequest added in v0.7.0 

type MigrateRegionRequest struct {
	Header      *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RegionId    uint64         `protobuf:"varint,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	FromPeer    uint64         `protobuf:"varint,4,opt,name=from_peer,json=fromPeer,proto3" json:"from_peer,omitempty"`
	ToPeer      uint64         `protobuf:"varint,5,opt,name=to_peer,json=toPeer,proto3" json:"to_peer,omitempty"`
	TimeoutSecs uint32         `protobuf:"varint,6,opt,name=timeout_secs,json=timeoutSecs,proto3" json:"timeout_secs,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrateRegionRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use MigrateRegionRequest.ProtoReflect.Descriptor instead.

func (*MigrateRegionRequest) GetFromPeer added in v0.7.0 

func (x *MigrateRegionRequest) GetFromPeer() uint64

func (*MigrateRegionRequest) GetHeader added in v0.7.0 

func (x *MigrateRegionRequest) GetHeader() *RequestHeader

func (*MigrateRegionRequest) GetRegionId added in v0.7.0 

func (x *MigrateRegionRequest) GetRegionId() uint64

func (*MigrateRegionRequest) GetTimeoutSecs added in v0.9.0 

func (x *MigrateRegionRequest) GetTimeoutSecs() uint32

func (*MigrateRegionRequest) GetToPeer added in v0.7.0 

func (x *MigrateRegionRequest) GetToPeer() uint64

func (*MigrateRegionRequest) ProtoMessage added in v0.7.0 

func (*MigrateRegionRequest) ProtoMessage()

func (*MigrateRegionRequest) ProtoReflect added in v0.7.0 

func (x *MigrateRegionRequest) ProtoReflect() protoreflect.Message

func (*MigrateRegionRequest) Reset added in v0.7.0 

func (x *MigrateRegionRequest) Reset()

func (*MigrateRegionRequest) String added in v0.7.0 

func (x *MigrateRegionRequest) String() string

type MigrateRegionResponse added in v0.7.0 

type MigrateRegionResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId    `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrateRegionResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use MigrateRegionResponse.ProtoReflect.Descriptor instead.

func (*MigrateRegionResponse) GetHeader added in v0.7.0 

func (x *MigrateRegionResponse) GetHeader() *ResponseHeader

func (*MigrateRegionResponse) GetPid added in v0.7.0 

func (x *MigrateRegionResponse) GetPid() *ProcedureId

func (*MigrateRegionResponse) ProtoMessage added in v0.7.0 

func (*MigrateRegionResponse) ProtoMessage()

func (*MigrateRegionResponse) ProtoReflect added in v0.7.0 

func (x *MigrateRegionResponse) ProtoReflect() protoreflect.Message

func (*MigrateRegionResponse) Reset added in v0.7.0 

func (x *MigrateRegionResponse) Reset()

func (*MigrateRegionResponse) String added in v0.7.0 

func (x *MigrateRegionResponse) String() string

type NodeInfo added in v0.9.0 

type NodeInfo struct {

	// The node build version
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The node build git commit hash
	GitCommit string `protobuf:"bytes,2,opt,name=git_commit,json=gitCommit,proto3" json:"git_commit,omitempty"`
	// The node start timestamp
	StartTimeMs uint64 `protobuf:"varint,3,opt,name=start_time_ms,json=startTimeMs,proto3" json:"start_time_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetGitCommit added in v0.9.0 

func (x *NodeInfo) GetGitCommit() string

func (*NodeInfo) GetStartTimeMs added in v0.9.0 

func (x *NodeInfo) GetStartTimeMs() uint64

func (*NodeInfo) GetVersion added in v0.9.0 

func (x *NodeInfo) GetVersion() string

func (*NodeInfo) ProtoMessage added in v0.9.0 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect added in v0.9.0 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset added in v0.9.0 

func (x *NodeInfo) Reset()

func (*NodeInfo) String added in v0.9.0 

func (x *NodeInfo) String() string

type Partition 

type Partition struct {
	ColumnList [][]byte `protobuf:"bytes,1,rep,name=column_list,json=columnList,proto3" json:"column_list,omitempty"`
	ValueList  [][]byte `protobuf:"bytes,2,rep,name=value_list,json=valueList,proto3" json:"value_list,omitempty"`
	// contains filtered or unexported fields
}

PARTITION `region_name` VALUES LESS THAN (value_list)

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetColumnList 

func (x *Partition) GetColumnList() [][]byte

func (*Partition) GetValueList 

func (x *Partition) GetValueList() [][]byte

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

func (x *Partition) ProtoReflect() protoreflect.Message

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type Peer 

type Peer struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Peer) Descriptor deprecated 

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

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetAddr 

func (x *Peer) GetAddr() string

func (*Peer) GetId 

func (x *Peer) GetId() uint64

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

func (x *Peer) ProtoReflect() protoreflect.Message

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

type ProcedureDetailRequest added in v0.9.0 

type ProcedureDetailRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcedureDetailRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ProcedureDetailRequest.ProtoReflect.Descriptor instead.

func (*ProcedureDetailRequest) GetHeader added in v0.9.0 

func (x *ProcedureDetailRequest) GetHeader() *RequestHeader

func (*ProcedureDetailRequest) ProtoMessage added in v0.9.0 

func (*ProcedureDetailRequest) ProtoMessage()

func (*ProcedureDetailRequest) ProtoReflect added in v0.9.0 

func (x *ProcedureDetailRequest) ProtoReflect() protoreflect.Message

func (*ProcedureDetailRequest) Reset added in v0.9.0 

func (x *ProcedureDetailRequest) Reset()

func (*ProcedureDetailRequest) String added in v0.9.0 

func (x *ProcedureDetailRequest) String() string

type ProcedureDetailResponse added in v0.9.0 

type ProcedureDetailResponse struct {
	Header     *ResponseHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Procedures []*ProcedureMeta `protobuf:"bytes,2,rep,name=procedures,proto3" json:"procedures,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcedureDetailResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ProcedureDetailResponse.ProtoReflect.Descriptor instead.

func (*ProcedureDetailResponse) GetHeader added in v0.9.0 

func (x *ProcedureDetailResponse) GetHeader() *ResponseHeader

func (*ProcedureDetailResponse) GetProcedures added in v0.9.0 

func (x *ProcedureDetailResponse) GetProcedures() []*ProcedureMeta

func (*ProcedureDetailResponse) ProtoMessage added in v0.9.0 

func (*ProcedureDetailResponse) ProtoMessage()

func (*ProcedureDetailResponse) ProtoReflect added in v0.9.0 

func (x *ProcedureDetailResponse) ProtoReflect() protoreflect.Message

func (*ProcedureDetailResponse) Reset added in v0.9.0 

func (x *ProcedureDetailResponse) Reset()

func (*ProcedureDetailResponse) String added in v0.9.0 

func (x *ProcedureDetailResponse) String() string

type ProcedureId added in v0.7.0 

type ProcedureId struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Procedure identifier

func (*ProcedureId) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ProcedureId.ProtoReflect.Descriptor instead.

func (*ProcedureId) GetKey added in v0.7.0 

func (x *ProcedureId) GetKey() []byte

func (*ProcedureId) ProtoMessage added in v0.7.0 

func (*ProcedureId) ProtoMessage()

func (*ProcedureId) ProtoReflect added in v0.7.0 

func (x *ProcedureId) ProtoReflect() protoreflect.Message

func (*ProcedureId) Reset added in v0.7.0 

func (x *ProcedureId) Reset()

func (*ProcedureId) String added in v0.7.0 

func (x *ProcedureId) String() string

type ProcedureMeta added in v0.9.0 

type ProcedureMeta struct {
	Id          *ProcedureId    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TypeName    string          `protobuf:"bytes,2,opt,name=type_name,json=typeName,proto3" json:"type_name,omitempty"`
	Status      ProcedureStatus `protobuf:"varint,3,opt,name=status,proto3,enum=greptime.v1.meta.ProcedureStatus" json:"status,omitempty"`
	StartTimeMs int64           `protobuf:"varint,4,opt,name=start_time_ms,json=startTimeMs,proto3" json:"start_time_ms,omitempty"`
	EndTimeMs   int64           `protobuf:"varint,5,opt,name=end_time_ms,json=endTimeMs,proto3" json:"end_time_ms,omitempty"`
	LockKeys    []string        `protobuf:"bytes,6,rep,name=lock_keys,json=lockKeys,proto3" json:"lock_keys,omitempty"`
	Error       string          `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcedureMeta) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ProcedureMeta.ProtoReflect.Descriptor instead.

func (*ProcedureMeta) GetEndTimeMs added in v0.9.0 

func (x *ProcedureMeta) GetEndTimeMs() int64

func (*ProcedureMeta) GetError added in v0.9.0 

func (x *ProcedureMeta) GetError() string

func (*ProcedureMeta) GetId added in v0.9.0 

func (x *ProcedureMeta) GetId() *ProcedureId

func (*ProcedureMeta) GetLockKeys added in v0.9.0 

func (x *ProcedureMeta) GetLockKeys() []string

func (*ProcedureMeta) GetStartTimeMs added in v0.9.0 

func (x *ProcedureMeta) GetStartTimeMs() int64

func (*ProcedureMeta) GetStatus added in v0.9.0 

func (x *ProcedureMeta) GetStatus() ProcedureStatus

func (*ProcedureMeta) GetTypeName added in v0.9.0 

func (x *ProcedureMeta) GetTypeName() string

func (*ProcedureMeta) ProtoMessage added in v0.9.0 

func (*ProcedureMeta) ProtoMessage()

func (*ProcedureMeta) ProtoReflect added in v0.9.0 

func (x *ProcedureMeta) ProtoReflect() protoreflect.Message

func (*ProcedureMeta) Reset added in v0.9.0 

func (x *ProcedureMeta) Reset()

func (*ProcedureMeta) String added in v0.9.0 

func (x *ProcedureMeta) String() string

type ProcedureServiceClient added in v0.7.0 

type ProcedureServiceClient interface {
	// Query a submitted procedure state
	Query(ctx context.Context, in *QueryProcedureRequest, opts ...grpc.CallOption) (*ProcedureStateResponse, error)
	// Submits a DDL task
	Ddl(ctx context.Context, in *DdlTaskRequest, opts ...grpc.CallOption) (*DdlTaskResponse, error)
	// Submits a region migration task
	Migrate(ctx context.Context, in *MigrateRegionRequest, opts ...grpc.CallOption) (*MigrateRegionResponse, error)
	// Query all submitted procedures details
	Details(ctx context.Context, in *ProcedureDetailRequest, opts ...grpc.CallOption) (*ProcedureDetailResponse, error)
}

ProcedureServiceClient is the client API for ProcedureService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProcedureServiceClient added in v0.7.0 

func NewProcedureServiceClient(cc grpc.ClientConnInterface) ProcedureServiceClient

type ProcedureServiceServer added in v0.7.0 

type ProcedureServiceServer interface {
	// Query a submitted procedure state
	Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)
	// Submits a DDL task
	Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)
	// Submits a region migration task
	Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)
	// Query all submitted procedures details
	Details(context.Context, *ProcedureDetailRequest) (*ProcedureDetailResponse, error)
	// contains filtered or unexported methods
}

ProcedureServiceServer is the server API for ProcedureService service. All implementations must embed UnimplementedProcedureServiceServer for forward compatibility

type ProcedureStateResponse added in v0.7.0 

type ProcedureStateResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Status ProcedureStatus `protobuf:"varint,2,opt,name=status,proto3,enum=greptime.v1.meta.ProcedureStatus" json:"status,omitempty"`
	Error  string          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcedureStateResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ProcedureStateResponse.ProtoReflect.Descriptor instead.

func (*ProcedureStateResponse) GetError added in v0.7.0 

func (x *ProcedureStateResponse) GetError() string

func (*ProcedureStateResponse) GetHeader added in v0.7.0 

func (x *ProcedureStateResponse) GetHeader() *ResponseHeader

func (*ProcedureStateResponse) GetStatus added in v0.7.0 

func (x *ProcedureStateResponse) GetStatus() ProcedureStatus

func (*ProcedureStateResponse) ProtoMessage added in v0.7.0 

func (*ProcedureStateResponse) ProtoMessage()

func (*ProcedureStateResponse) ProtoReflect added in v0.7.0 

func (x *ProcedureStateResponse) ProtoReflect() protoreflect.Message

func (*ProcedureStateResponse) Reset added in v0.7.0 

func (x *ProcedureStateResponse) Reset()

func (*ProcedureStateResponse) String added in v0.7.0 

func (x *ProcedureStateResponse) String() string

type ProcedureStatus added in v0.7.0 

type ProcedureStatus int32
const (
	ProcedureStatus_Running         ProcedureStatus = 0
	ProcedureStatus_Done            ProcedureStatus = 1
	ProcedureStatus_Retrying        ProcedureStatus = 2
	ProcedureStatus_Failed          ProcedureStatus = 3
	ProcedureStatus_PrepareRollback ProcedureStatus = 4
	ProcedureStatus_RollingBack     ProcedureStatus = 5
)

func (ProcedureStatus) Descriptor added in v0.7.0 

func (ProcedureStatus) Descriptor() protoreflect.EnumDescriptor

func (ProcedureStatus) Enum added in v0.7.0 

func (x ProcedureStatus) Enum() *ProcedureStatus

func (ProcedureStatus) EnumDescriptor deprecated added in v0.7.0 

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

Deprecated: Use ProcedureStatus.Descriptor instead.

func (ProcedureStatus) Number added in v0.7.0 

func (x ProcedureStatus) Number() protoreflect.EnumNumber

func (ProcedureStatus) String added in v0.7.0 

func (x ProcedureStatus) String() string

func (ProcedureStatus) Type added in v0.7.0 

func (ProcedureStatus) Type() protoreflect.EnumType

type PutRequest 

type PutRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the key, in bytes, to put into the key-value store.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the
	// key-value store.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// If prev_kv is set, gets the previous key-value pair before changing it.
	// The previous key-value pair will be returned in the put response.
	PrevKv bool `protobuf:"varint,4,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetHeader 

func (x *PutRequest) GetHeader() *RequestHeader

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetPrevKv 

func (x *PutRequest) GetPrevKv() bool

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// If prev_kv is set in the request, the previous key-value pair will be
	// returned.
	PrevKv *KeyValue `protobuf:"bytes,2,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// contains filtered or unexported fields
}

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) GetHeader 

func (x *PutResponse) GetHeader() *ResponseHeader

func (*PutResponse) GetPrevKv 

func (x *PutResponse) GetPrevKv() *KeyValue

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

func (x *PutResponse) ProtoReflect() protoreflect.Message

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type QueryProcedureRequest added in v0.7.0 

type QueryProcedureRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Pid    *ProcedureId   `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryProcedureRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use QueryProcedureRequest.ProtoReflect.Descriptor instead.

func (*QueryProcedureRequest) GetHeader added in v0.7.0 

func (x *QueryProcedureRequest) GetHeader() *RequestHeader

func (*QueryProcedureRequest) GetPid added in v0.7.0 

func (x *QueryProcedureRequest) GetPid() *ProcedureId

func (*QueryProcedureRequest) ProtoMessage added in v0.7.0 

func (*QueryProcedureRequest) ProtoMessage()

func (*QueryProcedureRequest) ProtoReflect added in v0.7.0 

func (x *QueryProcedureRequest) ProtoReflect() protoreflect.Message

func (*QueryProcedureRequest) Reset added in v0.7.0 

func (x *QueryProcedureRequest) Reset()

func (*QueryProcedureRequest) String added in v0.7.0 

func (x *QueryProcedureRequest) String() string

type RangeRequest 

type RangeRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the first key for the range, If range_end is not given, the
	// request only looks up key.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// range_end is the upper bound on the requested range [key, range_end).
	// If range_end is '\0', the range is all keys >= key.
	// If range_end is key plus one (e.g., "aa"+1 == "ab", "a\xff"+1 == "b"),
	// then the range request gets all keys prefixed with key.
	// If both key and range_end are '\0', then the range request returns all
	// keys.
	RangeEnd []byte `protobuf:"bytes,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// limit is a limit on the number of keys returned for the request. When
	// limit is set to 0, it is treated as no limit.
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// keys_only when set returns only the keys and not the values.
	KeysOnly bool `protobuf:"varint,5,opt,name=keys_only,json=keysOnly,proto3" json:"keys_only,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeRequest) Descriptor deprecated 

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

Deprecated: Use RangeRequest.ProtoReflect.Descriptor instead.

func (*RangeRequest) GetHeader 

func (x *RangeRequest) GetHeader() *RequestHeader

func (*RangeRequest) GetKey 

func (x *RangeRequest) GetKey() []byte

func (*RangeRequest) GetKeysOnly 

func (x *RangeRequest) GetKeysOnly() bool

func (*RangeRequest) GetLimit 

func (x *RangeRequest) GetLimit() int64

func (*RangeRequest) GetRangeEnd 

func (x *RangeRequest) GetRangeEnd() []byte

func (*RangeRequest) ProtoMessage 

func (*RangeRequest) ProtoMessage()

func (*RangeRequest) ProtoReflect 

func (x *RangeRequest) ProtoReflect() protoreflect.Message

func (*RangeRequest) Reset 

func (x *RangeRequest) Reset()

func (*RangeRequest) String 

func (x *RangeRequest) String() string

type RangeResponse 

type RangeResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// kvs is the list of key-value pairs matched by the range request.
	Kvs []*KeyValue `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// more indicates if there are more keys to return in the requested range.
	More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeResponse) Descriptor deprecated 

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

Deprecated: Use RangeResponse.ProtoReflect.Descriptor instead.

func (*RangeResponse) GetHeader 

func (x *RangeResponse) GetHeader() *ResponseHeader

func (*RangeResponse) GetKvs 

func (x *RangeResponse) GetKvs() []*KeyValue

func (*RangeResponse) GetMore 

func (x *RangeResponse) GetMore() bool

func (*RangeResponse) ProtoMessage 

func (*RangeResponse) ProtoMessage()

func (*RangeResponse) ProtoReflect 

func (x *RangeResponse) ProtoReflect() protoreflect.Message

func (*RangeResponse) Reset 

func (x *RangeResponse) Reset()

func (*RangeResponse) String 

func (x *RangeResponse) String() string

type Region 

type Region struct {

	// TODO(LFC): Maybe use message RegionNumber?
	Id        uint64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Partition *Partition        `protobuf:"bytes,3,opt,name=partition,proto3" json:"partition,omitempty"`
	Attrs     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Region) Descriptor deprecated 

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

Deprecated: Use Region.ProtoReflect.Descriptor instead.

func (*Region) GetAttrs 

func (x *Region) GetAttrs() map[string]string

func (*Region) GetId 

func (x *Region) GetId() uint64

func (*Region) GetName 

func (x *Region) GetName() string

func (*Region) GetPartition 

func (x *Region) GetPartition() *Partition

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) ProtoReflect 

func (x *Region) ProtoReflect() protoreflect.Message

func (*Region) Reset 

func (x *Region) Reset()

func (*Region) String 

func (x *Region) String() string

type RegionLease 

type RegionLease struct {
	Regions            []*GrantedRegion `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	DurationSinceEpoch uint64           `protobuf:"varint,2,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"`
	LeaseSeconds       uint64           `protobuf:"varint,3,opt,name=lease_seconds,json=leaseSeconds,proto3" json:"lease_seconds,omitempty"`
	CloseableRegionIds []uint64         `protobuf:"varint,4,rep,packed,name=closeable_region_ids,json=closeableRegionIds,proto3" json:"closeable_region_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RegionLease) Descriptor deprecated 

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

Deprecated: Use RegionLease.ProtoReflect.Descriptor instead.

func (*RegionLease) GetCloseableRegionIds added in v0.4.1 

func (x *RegionLease) GetCloseableRegionIds() []uint64

func (*RegionLease) GetDurationSinceEpoch 

func (x *RegionLease) GetDurationSinceEpoch() uint64

func (*RegionLease) GetLeaseSeconds 

func (x *RegionLease) GetLeaseSeconds() uint64

func (*RegionLease) GetRegions 

func (x *RegionLease) GetRegions() []*GrantedRegion

func (*RegionLease) ProtoMessage 

func (*RegionLease) ProtoMessage()

func (*RegionLease) ProtoReflect 

func (x *RegionLease) ProtoReflect() protoreflect.Message

func (*RegionLease) Reset 

func (x *RegionLease) Reset()

func (*RegionLease) String 

func (x *RegionLease) String() string

type RegionRole added in v0.4.1 

type RegionRole int32
const (
	// Writable region(mito2), Readonly region(file).
	RegionRole_Leader RegionRole = 0
	// Readonly region.
	RegionRole_Follower RegionRole = 1
	// A downgrading region, which is in the process of downgrading from Leader to
	// Follower.
	//
	// This role is used to prevent the region from being written during the
	// downgrade process.
	RegionRole_DowngradingLeader RegionRole = 2
)

func (RegionRole) Descriptor added in v0.4.1 

func (RegionRole) Descriptor() protoreflect.EnumDescriptor

func (RegionRole) Enum added in v0.4.1 

func (x RegionRole) Enum() *RegionRole

func (RegionRole) EnumDescriptor deprecated added in v0.4.1 

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

Deprecated: Use RegionRole.Descriptor instead.

func (RegionRole) Number added in v0.4.1 

func (x RegionRole) Number() protoreflect.EnumNumber

func (RegionRole) String added in v0.4.1 

func (x RegionRole) String() string

func (RegionRole) Type added in v0.4.1 

func (RegionRole) Type() protoreflect.EnumType

type RegionRoute 

type RegionRoute struct {
	Region *Region `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// single leader node for write task
	LeaderPeerIndex uint64 `protobuf:"varint,2,opt,name=leader_peer_index,json=leaderPeerIndex,proto3" json:"leader_peer_index,omitempty"`
	// multiple follower nodes for read task
	FollowerPeerIndexes []uint64 `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegionRoute) Descriptor deprecated 

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

Deprecated: Use RegionRoute.ProtoReflect.Descriptor instead.

func (*RegionRoute) GetFollowerPeerIndexes 

func (x *RegionRoute) GetFollowerPeerIndexes() []uint64

func (*RegionRoute) GetLeaderPeerIndex 

func (x *RegionRoute) GetLeaderPeerIndex() uint64

func (*RegionRoute) GetRegion 

func (x *RegionRoute) GetRegion() *Region

func (*RegionRoute) ProtoMessage 

func (*RegionRoute) ProtoMessage()

func (*RegionRoute) ProtoReflect 

func (x *RegionRoute) ProtoReflect() protoreflect.Message

func (*RegionRoute) Reset 

func (x *RegionRoute) Reset()

func (*RegionRoute) String 

func (x *RegionRoute) String() string

type RegionStat 

type RegionStat struct {
	RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// The read capacity units during this period
	Rcus int64 `protobuf:"varint,2,opt,name=rcus,proto3" json:"rcus,omitempty"`
	// The write capacity units during this period
	Wcus int64 `protobuf:"varint,3,opt,name=wcus,proto3" json:"wcus,omitempty"`
	// Approximate bytes of this region
	ApproximateBytes int64 `protobuf:"varint,4,opt,name=approximate_bytes,json=approximateBytes,proto3" json:"approximate_bytes,omitempty"`
	// Engine name
	Engine string `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"`
	// Region role
	Role       RegionRole        `protobuf:"varint,7,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"`
	Extensions map[string][]byte `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RegionStat) Descriptor deprecated 

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

Deprecated: Use RegionStat.ProtoReflect.Descriptor instead.

func (*RegionStat) GetApproximateBytes 

func (x *RegionStat) GetApproximateBytes() int64

func (*RegionStat) GetEngine added in v0.4.0 

func (x *RegionStat) GetEngine() string

func (*RegionStat) GetExtensions added in v0.9.0 

func (x *RegionStat) GetExtensions() map[string][]byte

func (*RegionStat) GetRcus 

func (x *RegionStat) GetRcus() int64

func (*RegionStat) GetRegionId 

func (x *RegionStat) GetRegionId() uint64

func (*RegionStat) GetRole added in v0.4.1 

func (x *RegionStat) GetRole() RegionRole

func (*RegionStat) GetWcus 

func (x *RegionStat) GetWcus() int64

func (*RegionStat) ProtoMessage 

func (*RegionStat) ProtoMessage()

func (*RegionStat) ProtoReflect 

func (x *RegionStat) ProtoReflect() protoreflect.Message

func (*RegionStat) Reset 

func (x *RegionStat) Reset()

func (*RegionStat) String 

func (x *RegionStat) String() string

type RequestHeader 

type RequestHeader struct {
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// cluster_id is the ID of the cluster which be sent to.
	ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// member_id is the ID of the sender server.
	MemberId uint64 `protobuf:"varint,3,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Role     Role   `protobuf:"varint,4,opt,name=role,proto3,enum=greptime.v1.meta.Role" json:"role,omitempty"`
	// Encoded trace_id & span_id, follow the w3c Trace Context
	// https://www.w3.org/TR/trace-context/#header-name
	TracingContext map[string]string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RequestHeader) Descriptor deprecated 

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetClusterId 

func (x *RequestHeader) GetClusterId() uint64

func (*RequestHeader) GetMemberId 

func (x *RequestHeader) GetMemberId() uint64

func (*RequestHeader) GetProtocolVersion 

func (x *RequestHeader) GetProtocolVersion() uint64

func (*RequestHeader) GetRole 

func (x *RequestHeader) GetRole() Role

func (*RequestHeader) GetTracingContext added in v0.4.1 

func (x *RequestHeader) GetTracingContext() map[string]string

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect 

func (x *RequestHeader) ProtoReflect() protoreflect.Message

func (*RequestHeader) Reset 

func (x *RequestHeader) Reset()

func (*RequestHeader) String 

func (x *RequestHeader) String() string

type ResponseHeader 

type ResponseHeader struct {
	ProtocolVersion uint64 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// cluster_id is the ID of the cluster which sent the response.
	ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error     *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetClusterId 

func (x *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError 

func (x *ResponseHeader) GetError() *Error

func (*ResponseHeader) GetProtocolVersion 

func (x *ResponseHeader) GetProtocolVersion() uint64

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

func (x *ResponseHeader) ProtoReflect() protoreflect.Message

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (x *ResponseHeader) String() string

type Role 

type Role int32
const (
	Role_DATANODE Role = 0
	Role_FRONTEND Role = 1
	Role_FLOWNODE Role = 2
)

func (Role) Descriptor 

func (Role) Descriptor() protoreflect.EnumDescriptor

func (Role) Enum 

func (x Role) Enum() *Role

func (Role) EnumDescriptor deprecated 

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

Deprecated: Use Role.Descriptor instead.

func (Role) Number 

func (x Role) Number() protoreflect.EnumNumber

func (Role) String 

func (x Role) String() string

func (Role) Type 

func (Role) Type() protoreflect.EnumType

type RouterClient 

type RouterClient interface {
	// Fetch routing information for tables. The smallest unit is the complete
	// routing information(all regions) of a table.
	//
	// “`text
	// table_1
	//
	//	table_name
	//	table_schema
	//	regions
	//	  region_1
	//	    leader_peer
	//	    follower_peer_1, follower_peer_2
	//	  region_2
	//	    leader_peer
	//	    follower_peer_1, follower_peer_2, follower_peer_3
	//	  region_xxx
	//
	// table_2
	//
	//	...
	//
	// “`
	Route(ctx context.Context, in *RouteRequest, opts ...grpc.CallOption) (*RouteResponse, error)
}

RouterClient is the client API for Router service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRouterClient 

func NewRouterClient(cc grpc.ClientConnInterface) RouterClient

type RouterServer 

type RouterServer interface {
	// Fetch routing information for tables. The smallest unit is the complete
	// routing information(all regions) of a table.
	//
	// “`text
	// table_1
	//
	//	table_name
	//	table_schema
	//	regions
	//	  region_1
	//	    leader_peer
	//	    follower_peer_1, follower_peer_2
	//	  region_2
	//	    leader_peer
	//	    follower_peer_1, follower_peer_2, follower_peer_3
	//	  region_xxx
	//
	// table_2
	//
	//	...
	//
	// “`
	Route(context.Context, *RouteRequest) (*RouteResponse, error)
	// contains filtered or unexported methods
}

RouterServer is the server API for Router service. All implementations must embed UnimplementedRouterServer for forward compatibility

type StoreClient 

type StoreClient interface {
	// Range gets the keys in the range from the key-value store.
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	// Put puts the given key into the key-value store.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// BatchGet atomically get values by the given keys from the key-value store.
	BatchGet(ctx context.Context, in *BatchGetRequest, opts ...grpc.CallOption) (*BatchGetResponse, error)
	// BatchPut atomically puts the given keys into the key-value store.
	BatchPut(ctx context.Context, in *BatchPutRequest, opts ...grpc.CallOption) (*BatchPutResponse, error)
	// BatchDelete atomically deletes the given keys and its associating values
	// from the key-value store.
	BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)
	// CompareAndPut atomically puts the value to the given updated
	// value if the current value == the expected value.
	CompareAndPut(ctx context.Context, in *CompareAndPutRequest, opts ...grpc.CallOption) (*CompareAndPutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	DeleteRange(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error)
}

StoreClient is the client API for Store service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStoreClient 

func NewStoreClient(cc grpc.ClientConnInterface) StoreClient

type StoreServer 

type StoreServer interface {
	// Range gets the keys in the range from the key-value store.
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	// Put puts the given key into the key-value store.
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// BatchGet atomically get values by the given keys from the key-value store.
	BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)
	// BatchPut atomically puts the given keys into the key-value store.
	BatchPut(context.Context, *BatchPutRequest) (*BatchPutResponse, error)
	// BatchDelete atomically deletes the given keys and its associating values
	// from the key-value store.
	BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)
	// CompareAndPut atomically puts the value to the given updated
	// value if the current value == the expected value.
	CompareAndPut(context.Context, *CompareAndPutRequest) (*CompareAndPutResponse, error)
	// DeleteRange deletes the given range from the key-value store.
	DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)
	// contains filtered or unexported methods
}

StoreServer is the server API for Store service. All implementations must embed UnimplementedStoreServer for forward compatibility

type Table 

type Table struct {
	Id          uint64        `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TableName   *v1.TableName `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	TableSchema []byte        `protobuf:"bytes,3,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetId 

func (x *Table) GetId() uint64

func (*Table) GetTableName 

func (x *Table) GetTableName() *v1.TableName

func (*Table) GetTableSchema 

func (x *Table) GetTableSchema() []byte

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

func (x *Table) ProtoReflect() protoreflect.Message

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TableRoute 

type TableRoute struct {
	Table        *Table         `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	RegionRoutes []*RegionRoute `protobuf:"bytes,2,rep,name=region_routes,json=regionRoutes,proto3" json:"region_routes,omitempty"`
	// contains filtered or unexported fields
}

func (*TableRoute) Descriptor deprecated 

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

Deprecated: Use TableRoute.ProtoReflect.Descriptor instead.

func (*TableRoute) GetRegionRoutes 

func (x *TableRoute) GetRegionRoutes() []*RegionRoute

func (*TableRoute) GetTable 

func (x *TableRoute) GetTable() *Table

func (*TableRoute) ProtoMessage 

func (*TableRoute) ProtoMessage()

func (*TableRoute) ProtoReflect 

func (x *TableRoute) ProtoReflect() protoreflect.Message

func (*TableRoute) Reset 

func (x *TableRoute) Reset()

func (*TableRoute) String 

func (x *TableRoute) String() string

type TableRouteValue 

type TableRouteValue struct {
	Peers      []*Peer     `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	TableRoute *TableRoute `protobuf:"bytes,2,opt,name=table_route,json=tableRoute,proto3" json:"table_route,omitempty"`
	// contains filtered or unexported fields
}

This message is only for saving into store. TODO(weny): Remove it, Now, the upgrade tool is still dependent on it.

func (*TableRouteValue) Descriptor deprecated 

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

Deprecated: Use TableRouteValue.ProtoReflect.Descriptor instead.

func (*TableRouteValue) GetPeers 

func (x *TableRouteValue) GetPeers() []*Peer

func (*TableRouteValue) GetTableRoute 

func (x *TableRouteValue) GetTableRoute() *TableRoute

func (*TableRouteValue) ProtoMessage 

func (*TableRouteValue) ProtoMessage()

func (*TableRouteValue) ProtoReflect 

func (x *TableRouteValue) ProtoReflect() protoreflect.Message

func (*TableRouteValue) Reset 

func (x *TableRouteValue) Reset()

func (*TableRouteValue) String 

func (x *TableRouteValue) String() string

type TimeInterval 

type TimeInterval struct {

	// The unix timestamp in millis of the start of this period.
	StartTimestampMillis int64 `protobuf:"varint,1,opt,name=start_timestamp_millis,json=startTimestampMillis,proto3" json:"start_timestamp_millis,omitempty"`
	// The unix timestamp in millis of the end of this period.
	EndTimestampMillis int64 `protobuf:"varint,2,opt,name=end_timestamp_millis,json=endTimestampMillis,proto3" json:"end_timestamp_millis,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeInterval) Descriptor deprecated 

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

Deprecated: Use TimeInterval.ProtoReflect.Descriptor instead.

func (*TimeInterval) GetEndTimestampMillis 

func (x *TimeInterval) GetEndTimestampMillis() int64

func (*TimeInterval) GetStartTimestampMillis 

func (x *TimeInterval) GetStartTimestampMillis() int64

func (*TimeInterval) ProtoMessage 

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) ProtoReflect 

func (x *TimeInterval) ProtoReflect() protoreflect.Message

func (*TimeInterval) Reset 

func (x *TimeInterval) Reset()

func (*TimeInterval) String 

func (x *TimeInterval) String() string

type TruncateTableTask 

type TruncateTableTask struct {
	TruncateTable *v1.TruncateTableExpr `protobuf:"bytes,1,opt,name=truncate_table,json=truncateTable,proto3" json:"truncate_table,omitempty"`
	// contains filtered or unexported fields
}

func (*TruncateTableTask) Descriptor deprecated 

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

Deprecated: Use TruncateTableTask.ProtoReflect.Descriptor instead.

func (*TruncateTableTask) GetTruncateTable 

func (x *TruncateTableTask) GetTruncateTable() *v1.TruncateTableExpr

func (*TruncateTableTask) ProtoMessage 

func (*TruncateTableTask) ProtoMessage()

func (*TruncateTableTask) ProtoReflect 

func (x *TruncateTableTask) ProtoReflect() protoreflect.Message

func (*TruncateTableTask) Reset 

func (x *TruncateTableTask) Reset()

func (*TruncateTableTask) String 

func (x *TruncateTableTask) String() string

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServer) BatchGet 

func (UnimplementedClusterServer) BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

func (UnimplementedClusterServer) MetasrvPeers added in v0.7.0 

func (UnimplementedClusterServer) MetasrvPeers(context.Context, *MetasrvPeersRequest) (*MetasrvPeersResponse, error)

func (UnimplementedClusterServer) Range 

func (UnimplementedClusterServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

type UnimplementedDdlTaskServer 

type UnimplementedDdlTaskServer struct {
}

UnimplementedDdlTaskServer must be embedded to have forward compatible implementations.

func (UnimplementedDdlTaskServer) SubmitDdlTask 

func (UnimplementedDdlTaskServer) SubmitDdlTask(context.Context, *SubmitDdlTaskRequest) (*SubmitDdlTaskResponse, error)

type UnimplementedHeartbeatServer 

type UnimplementedHeartbeatServer struct {
}

UnimplementedHeartbeatServer must be embedded to have forward compatible implementations.

func (UnimplementedHeartbeatServer) AskLeader 

func (UnimplementedHeartbeatServer) AskLeader(context.Context, *AskLeaderRequest) (*AskLeaderResponse, error)

func (UnimplementedHeartbeatServer) Heartbeat 

func (UnimplementedHeartbeatServer) Heartbeat(Heartbeat_HeartbeatServer) error

type UnimplementedLockServer 

type UnimplementedLockServer struct {
}

UnimplementedLockServer must be embedded to have forward compatible implementations.

func (UnimplementedLockServer) Lock 

func (UnimplementedLockServer) Lock(context.Context, *LockRequest) (*LockResponse, error)

func (UnimplementedLockServer) Unlock 

func (UnimplementedLockServer) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)

type UnimplementedProcedureServiceServer added in v0.7.0 

type UnimplementedProcedureServiceServer struct {
}

UnimplementedProcedureServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProcedureServiceServer) Ddl added in v0.7.0 

func (UnimplementedProcedureServiceServer) Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)

func (UnimplementedProcedureServiceServer) Details added in v0.9.0 

func (UnimplementedProcedureServiceServer) Details(context.Context, *ProcedureDetailRequest) (*ProcedureDetailResponse, error)

func (UnimplementedProcedureServiceServer) Migrate added in v0.7.0 

func (UnimplementedProcedureServiceServer) Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)

func (UnimplementedProcedureServiceServer) Query added in v0.7.0 

func (UnimplementedProcedureServiceServer) Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)

type UnimplementedRouterServer 

type UnimplementedRouterServer struct {
}

UnimplementedRouterServer must be embedded to have forward compatible implementations.

func (UnimplementedRouterServer) Route 

func (UnimplementedRouterServer) Route(context.Context, *RouteRequest) (*RouteResponse, error)

type UnimplementedStoreServer 

type UnimplementedStoreServer struct {
}

UnimplementedStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedStoreServer) BatchDelete 

func (UnimplementedStoreServer) BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)

func (UnimplementedStoreServer) BatchGet 

func (UnimplementedStoreServer) BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

func (UnimplementedStoreServer) BatchPut 

func (UnimplementedStoreServer) BatchPut(context.Context, *BatchPutRequest) (*BatchPutResponse, error)

func (UnimplementedStoreServer) CompareAndPut 

func (UnimplementedStoreServer) CompareAndPut(context.Context, *CompareAndPutRequest) (*CompareAndPutResponse, error)

func (UnimplementedStoreServer) DeleteRange 

func (UnimplementedStoreServer) DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

func (UnimplementedStoreServer) Put 

func (UnimplementedStoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedStoreServer) Range 

func (UnimplementedStoreServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

type UnlockRequest 

type UnlockRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// key is the lock ownership key granted by Lock.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlockRequest) Descriptor deprecated 

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

Deprecated: Use UnlockRequest.ProtoReflect.Descriptor instead.

func (*UnlockRequest) GetHeader 

func (x *UnlockRequest) GetHeader() *RequestHeader

func (*UnlockRequest) GetKey 

func (x *UnlockRequest) GetKey() []byte

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) ProtoReflect 

func (x *UnlockRequest) ProtoReflect() protoreflect.Message

func (*UnlockRequest) Reset 

func (x *UnlockRequest) Reset()

func (*UnlockRequest) String 

func (x *UnlockRequest) String() string

type UnlockResponse 

type UnlockResponse struct {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*UnlockResponse) Descriptor deprecated 

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

Deprecated: Use UnlockResponse.ProtoReflect.Descriptor instead.

func (*UnlockResponse) GetHeader 

func (x *UnlockResponse) GetHeader() *ResponseHeader

func (*UnlockResponse) ProtoMessage 

func (*UnlockResponse) ProtoMessage()

func (*UnlockResponse) ProtoReflect 

func (x *UnlockResponse) ProtoReflect() protoreflect.Message

func (*UnlockResponse) Reset 

func (x *UnlockResponse) Reset()

func (*UnlockResponse) String 

func (x *UnlockResponse) String() string

type UnsafeClusterServer 

type UnsafeClusterServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServer will result in compilation errors.

type UnsafeDdlTaskServer 

type UnsafeDdlTaskServer interface {
	// contains filtered or unexported methods
}

UnsafeDdlTaskServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DdlTaskServer will result in compilation errors.

type UnsafeHeartbeatServer 

type UnsafeHeartbeatServer interface {
	// contains filtered or unexported methods
}

UnsafeHeartbeatServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HeartbeatServer will result in compilation errors.

type UnsafeLockServer 

type UnsafeLockServer interface {
	// contains filtered or unexported methods
}

UnsafeLockServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LockServer will result in compilation errors.

type UnsafeProcedureServiceServer added in v0.7.0 

type UnsafeProcedureServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeProcedureServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcedureServiceServer will result in compilation errors.

type UnsafeRouterServer 

type UnsafeRouterServer interface {
	// contains filtered or unexported methods
}

UnsafeRouterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RouterServer will result in compilation errors.

type UnsafeStoreServer 

type UnsafeStoreServer interface {
	// contains filtered or unexported methods
}

UnsafeStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoreServer will result in compilation errors.

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.