__

package
v0.0.0-...-2588cc6 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	OpType_name = map[int32]string{
		0: "UNKNOWN",
		1: "PREWRITE",
		2: "COMMIT",
		3: "ROLLBACK",
	}
	OpType_value = map[string]int32{
		"UNKNOWN":  0,
		"PREWRITE": 1,
		"COMMIT":   2,
		"ROLLBACK": 3,
	}
)

Enum value maps for OpType.

View Source 
var (
	TaskOp_name = map[int32]string{
		0: "Attach",
		1: "Detach",
	}
	TaskOp_value = map[string]int32{
		"Attach": 0,
		"Detach": 1,
	}
)

Enum value maps for TaskOp.

View Source 
var (
	Table_OP_name = map[int32]string{
		0: "CREATE",
		1: "DROP",
		2: "ALTER",
	}
	Table_OP_value = map[string]int32{
		"CREATE": 0,
		"DROP":   1,
		"ALTER":  2,
	}
)

Enum value maps for Table_OP.

View Source 
var (
	Schema_OP_name = map[int32]string{
		0: "CREATE",
		1: "DROP",
	}
	Schema_OP_value = map[string]int32{
		"CREATE": 0,
		"DROP":   1,
	}
)

Enum value maps for Schema_OP.

View Source 
var ApiService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tistreampb.ApiService",
	HandlerType: (*ApiServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PullData",
			Handler:    _ApiService_PullData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "apiservicepb.proto",
}

ApiService_ServiceDesc is the grpc.ServiceDesc for ApiService 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 DispatcherService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tistreampb.DispatcherService",
	HandlerType: (*DispatcherServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NotifiyTenantHasUpdate",
			Handler:    _DispatcherService_NotifiyTenantHasUpdate_Handler,
		},
		{
			MethodName: "ScheduleNewTenant",
			Handler:    _DispatcherService_ScheduleNewTenant_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dispatcherpb.proto",
}

DispatcherService_ServiceDesc is the grpc.ServiceDesc for DispatcherService 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_apiservicepb_proto protoreflect.FileDescriptor
View Source 
var File_dispatcherpb_proto protoreflect.FileDescriptor
View Source 
var File_eventpb_proto protoreflect.FileDescriptor
View Source 
var File_metapb_proto protoreflect.FileDescriptor
View Source 
var File_metaservicepb_proto protoreflect.FileDescriptor
View Source 
var File_schemapb_proto protoreflect.FileDescriptor
View Source 
var File_schemaservicepb_proto protoreflect.FileDescriptor
View Source 
var File_sorterservicepb_proto protoreflect.FileDescriptor
View Source 
var MetaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tistreampb.MetaService",
	HandlerType: (*MetaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TenantHasNewChange",
			Handler:    _MetaService_TenantHasNewChange_Handler,
		},
		{
			MethodName: "DispatcherHeartbeat",
			Handler:    _MetaService_DispatcherHeartbeat_Handler,
		},
		{
			MethodName: "SorterHeartbeat",
			Handler:    _MetaService_SorterHeartbeat_Handler,
		},
		{
			MethodName: "FetchSchemaRegistryAddr",
			Handler:    _MetaService_FetchSchemaRegistryAddr_Handler,
		},
		{
			MethodName: "FetchRangeSorterAddr",
			Handler:    _MetaService_FetchRangeSorterAddr_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "metaservicepb.proto",
}

MetaService_ServiceDesc is the grpc.ServiceDesc for MetaService 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 SchemaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tistreampb.SchemaService",
	HandlerType: (*SchemaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterSchemaSnap",
			Handler:    _SchemaService_RegisterSchemaSnap_Handler,
		},
		{
			MethodName: "RegisterDDLChange",
			Handler:    _SchemaService_RegisterDDLChange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "schemaservicepb.proto",
}

SchemaService_ServiceDesc is the grpc.ServiceDesc for SchemaService 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 SorterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tistreampb.SorterService",
	HandlerType: (*SorterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewDataChanges",
			Handler:    _SorterService_NewDataChanges_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sorterservicepb.proto",
}

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

Functions

func RegisterApiServiceServer 

func RegisterApiServiceServer(s grpc.ServiceRegistrar, srv ApiServiceServer)

func RegisterDispatcherServiceServer 

func RegisterDispatcherServiceServer(s grpc.ServiceRegistrar, srv DispatcherServiceServer)

func RegisterMetaServiceServer 

func RegisterMetaServiceServer(s grpc.ServiceRegistrar, srv MetaServiceServer)

func RegisterSchemaServiceServer 

func RegisterSchemaServiceServer(s grpc.ServiceRegistrar, srv SchemaServiceServer)

func RegisterSorterServiceServer 

func RegisterSorterServiceServer(s grpc.ServiceRegistrar, srv SorterServiceServer)

Types

type ApiServiceClient 

type ApiServiceClient interface {
	PullData(ctx context.Context, in *PullTenantDataReq, opts ...grpc.CallOption) (*PullTenantDataResp, error)
}

ApiServiceClient is the client API for ApiService 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 NewApiServiceClient 

func NewApiServiceClient(cc grpc.ClientConnInterface) ApiServiceClient

type ApiServiceServer 

type ApiServiceServer interface {
	PullData(context.Context, *PullTenantDataReq) (*PullTenantDataResp, error)
	// contains filtered or unexported methods
}

ApiServiceServer is the server API for ApiService service. All implementations must embed UnimplementedApiServiceServer for forward compatibility

type DDLChange 

type DDLChange struct {
	Table  *Table  `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*DDLChange) Descriptor deprecated 

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

Deprecated: Use DDLChange.ProtoReflect.Descriptor instead.

func (*DDLChange) GetSchema 

func (x *DDLChange) GetSchema() *Schema

func (*DDLChange) GetTable 

func (x *DDLChange) GetTable() *Table

func (*DDLChange) ProtoMessage 

func (*DDLChange) ProtoMessage()

func (*DDLChange) ProtoReflect 

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

func (*DDLChange) Reset 

func (x *DDLChange) Reset()

func (*DDLChange) String 

func (x *DDLChange) String() string

type DispatcherHeartbeatReq 

type DispatcherHeartbeatReq struct {
	Addr        string            `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`                                  // dispatcher addr, used to distiguish dispatchers.
	Throughput  uint64            `protobuf:"varint,2,opt,name=throughput,proto3" json:"throughput,omitempty"`                     // throughput since last heartbeat.
	TenantStats []*TenantSubStats `protobuf:"bytes,3,rep,name=tenant_stats,json=tenantStats,proto3" json:"tenant_stats,omitempty"` // tenant id and throughput.
	// contains filtered or unexported fields
}

func (*DispatcherHeartbeatReq) Descriptor deprecated 

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

Deprecated: Use DispatcherHeartbeatReq.ProtoReflect.Descriptor instead.

func (*DispatcherHeartbeatReq) GetAddr 

func (x *DispatcherHeartbeatReq) GetAddr() string

func (*DispatcherHeartbeatReq) GetTenantStats 

func (x *DispatcherHeartbeatReq) GetTenantStats() []*TenantSubStats

func (*DispatcherHeartbeatReq) GetThroughput 

func (x *DispatcherHeartbeatReq) GetThroughput() uint64

func (*DispatcherHeartbeatReq) ProtoMessage 

func (*DispatcherHeartbeatReq) ProtoMessage()

func (*DispatcherHeartbeatReq) ProtoReflect 

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

func (*DispatcherHeartbeatReq) Reset 

func (x *DispatcherHeartbeatReq) Reset()

func (*DispatcherHeartbeatReq) String 

func (x *DispatcherHeartbeatReq) String() string

type DispatcherHeartbeatResp 

type DispatcherHeartbeatResp struct {
	// contains filtered or unexported fields
}

func (*DispatcherHeartbeatResp) Descriptor deprecated 

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

Deprecated: Use DispatcherHeartbeatResp.ProtoReflect.Descriptor instead.

func (*DispatcherHeartbeatResp) ProtoMessage 

func (*DispatcherHeartbeatResp) ProtoMessage()

func (*DispatcherHeartbeatResp) ProtoReflect 

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

func (*DispatcherHeartbeatResp) Reset 

func (x *DispatcherHeartbeatResp) Reset()

func (*DispatcherHeartbeatResp) String 

func (x *DispatcherHeartbeatResp) String() string

type DispatcherServiceClient 

type DispatcherServiceClient interface {
	NotifiyTenantHasUpdate(ctx context.Context, in *HasNewChangeReq, opts ...grpc.CallOption) (*HasNewChangeResp, error)
	ScheduleNewTenant(ctx context.Context, in *TenantTasksReq, opts ...grpc.CallOption) (*TenantTasksResp, error)
}

DispatcherServiceClient is the client API for DispatcherService 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 NewDispatcherServiceClient 

func NewDispatcherServiceClient(cc grpc.ClientConnInterface) DispatcherServiceClient

type DispatcherServiceServer 

type DispatcherServiceServer interface {
	NotifiyTenantHasUpdate(context.Context, *HasNewChangeReq) (*HasNewChangeResp, error)
	ScheduleNewTenant(context.Context, *TenantTasksReq) (*TenantTasksResp, error)
	// contains filtered or unexported methods
}

DispatcherServiceServer is the server API for DispatcherService service. All implementations must embed UnimplementedDispatcherServiceServer for forward compatibility

type EventBatch 

type EventBatch struct {
	Rows       []*EventRow       `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Watermarks []*EventWatermark `protobuf:"bytes,2,rep,name=watermarks,proto3" json:"watermarks,omitempty"`
	DdlChanges []*DDLChange      `protobuf:"bytes,3,rep,name=ddl_changes,json=ddlChanges,proto3" json:"ddl_changes,omitempty"`
	// contains filtered or unexported fields
}

func (*EventBatch) Descriptor deprecated 

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

Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.

func (*EventBatch) GetDdlChanges 

func (x *EventBatch) GetDdlChanges() []*DDLChange

func (*EventBatch) GetRows 

func (x *EventBatch) GetRows() []*EventRow

func (*EventBatch) GetWatermarks 

func (x *EventBatch) GetWatermarks() []*EventWatermark

func (*EventBatch) ProtoMessage 

func (*EventBatch) ProtoMessage()

func (*EventBatch) ProtoReflect 

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

func (*EventBatch) Reset 

func (x *EventBatch) Reset()

func (*EventBatch) String 

func (x *EventBatch) String() string

type EventRow 

type EventRow struct {
	StartTs  uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	CommitTs uint64 `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	OpType   OpType `protobuf:"varint,3,opt,name=op_type,json=opType,proto3,enum=tistreampb.OpType" json:"op_type,omitempty"`
	Key      []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	OldValue []byte `protobuf:"bytes,6,opt,name=old_value,json=oldValue,proto3" json:"old_value,omitempty"`
	// contains filtered or unexported fields
}

func (*EventRow) Descriptor deprecated 

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

Deprecated: Use EventRow.ProtoReflect.Descriptor instead.

func (*EventRow) GetCommitTs 

func (x *EventRow) GetCommitTs() uint64

func (*EventRow) GetKey 

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

func (*EventRow) GetOldValue 

func (x *EventRow) GetOldValue() []byte

func (*EventRow) GetOpType 

func (x *EventRow) GetOpType() OpType

func (*EventRow) GetStartTs 

func (x *EventRow) GetStartTs() uint64

func (*EventRow) GetValue 

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

func (*EventRow) ProtoMessage 

func (*EventRow) ProtoMessage()

func (*EventRow) ProtoReflect 

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

func (*EventRow) Reset 

func (x *EventRow) Reset()

func (*EventRow) String 

func (x *EventRow) String() string

type EventWatermark 

type EventWatermark struct {
	Ts           uint64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	RangeId      uint64 `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	RangeVersion uint64 `protobuf:"varint,3,opt,name=range_version,json=rangeVersion,proto3" json:"range_version,omitempty"`
	RangeStart   []byte `protobuf:"bytes,4,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"`
	RangeEnd     []byte `protobuf:"bytes,5,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	// contains filtered or unexported fields
}

func (*EventWatermark) Descriptor deprecated 

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

Deprecated: Use EventWatermark.ProtoReflect.Descriptor instead.

func (*EventWatermark) GetRangeEnd 

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

func (*EventWatermark) GetRangeId 

func (x *EventWatermark) GetRangeId() uint64

func (*EventWatermark) GetRangeStart 

func (x *EventWatermark) GetRangeStart() []byte

func (*EventWatermark) GetRangeVersion 

func (x *EventWatermark) GetRangeVersion() uint64

func (*EventWatermark) GetTs 

func (x *EventWatermark) GetTs() uint64

func (*EventWatermark) ProtoMessage 

func (*EventWatermark) ProtoMessage()

func (*EventWatermark) ProtoReflect 

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

func (*EventWatermark) Reset 

func (x *EventWatermark) Reset()

func (*EventWatermark) String 

func (x *EventWatermark) String() string

type FetchRangeSorterAddrReq 

type FetchRangeSorterAddrReq struct {
	TenantId uint64      `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Range    *Task_Range `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRangeSorterAddrReq) Descriptor deprecated 

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

Deprecated: Use FetchRangeSorterAddrReq.ProtoReflect.Descriptor instead.

func (*FetchRangeSorterAddrReq) GetRange 

func (x *FetchRangeSorterAddrReq) GetRange() *Task_Range

func (*FetchRangeSorterAddrReq) GetTenantId 

func (x *FetchRangeSorterAddrReq) GetTenantId() uint64

func (*FetchRangeSorterAddrReq) ProtoMessage 

func (*FetchRangeSorterAddrReq) ProtoMessage()

func (*FetchRangeSorterAddrReq) ProtoReflect 

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

func (*FetchRangeSorterAddrReq) Reset 

func (x *FetchRangeSorterAddrReq) Reset()

func (*FetchRangeSorterAddrReq) String 

func (x *FetchRangeSorterAddrReq) String() string

type FetchRangeSorterAddrResp 

type FetchRangeSorterAddrResp struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchRangeSorterAddrResp) Descriptor deprecated 

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

Deprecated: Use FetchRangeSorterAddrResp.ProtoReflect.Descriptor instead.

func (*FetchRangeSorterAddrResp) GetAddr 

func (x *FetchRangeSorterAddrResp) GetAddr() string

func (*FetchRangeSorterAddrResp) ProtoMessage 

func (*FetchRangeSorterAddrResp) ProtoMessage()

func (*FetchRangeSorterAddrResp) ProtoReflect 

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

func (*FetchRangeSorterAddrResp) Reset 

func (x *FetchRangeSorterAddrResp) Reset()

func (*FetchRangeSorterAddrResp) String 

func (x *FetchRangeSorterAddrResp) String() string

type FetchSchemaRegistryAddrReq 

type FetchSchemaRegistryAddrReq struct {
	TenantId uint64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchSchemaRegistryAddrReq) Descriptor deprecated 

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

Deprecated: Use FetchSchemaRegistryAddrReq.ProtoReflect.Descriptor instead.

func (*FetchSchemaRegistryAddrReq) GetTenantId 

func (x *FetchSchemaRegistryAddrReq) GetTenantId() uint64

func (*FetchSchemaRegistryAddrReq) ProtoMessage 

func (*FetchSchemaRegistryAddrReq) ProtoMessage()

func (*FetchSchemaRegistryAddrReq) ProtoReflect 

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

func (*FetchSchemaRegistryAddrReq) Reset 

func (x *FetchSchemaRegistryAddrReq) Reset()

func (*FetchSchemaRegistryAddrReq) String 

func (x *FetchSchemaRegistryAddrReq) String() string

type FetchSchemaRegistryAddrResp 

type FetchSchemaRegistryAddrResp struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchSchemaRegistryAddrResp) Descriptor deprecated 

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

Deprecated: Use FetchSchemaRegistryAddrResp.ProtoReflect.Descriptor instead.

func (*FetchSchemaRegistryAddrResp) GetAddr 

func (x *FetchSchemaRegistryAddrResp) GetAddr() string

func (*FetchSchemaRegistryAddrResp) ProtoMessage 

func (*FetchSchemaRegistryAddrResp) ProtoMessage()

func (*FetchSchemaRegistryAddrResp) ProtoReflect 

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

func (*FetchSchemaRegistryAddrResp) Reset 

func (x *FetchSchemaRegistryAddrResp) Reset()

func (*FetchSchemaRegistryAddrResp) String 

func (x *FetchSchemaRegistryAddrResp) String() string

type HasNewChangeReq 

type HasNewChangeReq struct {
	TenantId []uint64 `protobuf:"varint,1,rep,packed,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

Upstream notify downstream there are new data change files for specified tenants.

func (*HasNewChangeReq) Descriptor deprecated 

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

Deprecated: Use HasNewChangeReq.ProtoReflect.Descriptor instead.

func (*HasNewChangeReq) GetTenantId 

func (x *HasNewChangeReq) GetTenantId() []uint64

func (*HasNewChangeReq) ProtoMessage 

func (*HasNewChangeReq) ProtoMessage()

func (*HasNewChangeReq) ProtoReflect 

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

func (*HasNewChangeReq) Reset 

func (x *HasNewChangeReq) Reset()

func (*HasNewChangeReq) String 

func (x *HasNewChangeReq) String() string

type HasNewChangeResp 

type HasNewChangeResp struct {
	// contains filtered or unexported fields
}

func (*HasNewChangeResp) Descriptor deprecated 

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

Deprecated: Use HasNewChangeResp.ProtoReflect.Descriptor instead.

func (*HasNewChangeResp) ProtoMessage 

func (*HasNewChangeResp) ProtoMessage()

func (*HasNewChangeResp) ProtoReflect 

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

func (*HasNewChangeResp) Reset 

func (x *HasNewChangeResp) Reset()

func (*HasNewChangeResp) String 

func (x *HasNewChangeResp) String() string

type MetaServiceClient 

type MetaServiceClient interface {
	TenantHasNewChange(ctx context.Context, in *HasNewChangeReq, opts ...grpc.CallOption) (*HasNewChangeResp, error)
	DispatcherHeartbeat(ctx context.Context, in *DispatcherHeartbeatReq, opts ...grpc.CallOption) (*DispatcherHeartbeatResp, error)
	SorterHeartbeat(ctx context.Context, in *SorterHeartbeatReq, opts ...grpc.CallOption) (*SorterHeartbeatResp, error)
	FetchSchemaRegistryAddr(ctx context.Context, in *FetchSchemaRegistryAddrReq, opts ...grpc.CallOption) (*FetchSchemaRegistryAddrResp, error)
	FetchRangeSorterAddr(ctx context.Context, in *FetchRangeSorterAddrReq, opts ...grpc.CallOption) (*FetchRangeSorterAddrResp, error)
}

MetaServiceClient is the client API for MetaService 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 NewMetaServiceClient 

func NewMetaServiceClient(cc grpc.ClientConnInterface) MetaServiceClient

type MetaServiceServer 

type MetaServiceServer interface {
	TenantHasNewChange(context.Context, *HasNewChangeReq) (*HasNewChangeResp, error)
	DispatcherHeartbeat(context.Context, *DispatcherHeartbeatReq) (*DispatcherHeartbeatResp, error)
	SorterHeartbeat(context.Context, *SorterHeartbeatReq) (*SorterHeartbeatResp, error)
	FetchSchemaRegistryAddr(context.Context, *FetchSchemaRegistryAddrReq) (*FetchSchemaRegistryAddrResp, error)
	FetchRangeSorterAddr(context.Context, *FetchRangeSorterAddrReq) (*FetchRangeSorterAddrResp, error)
	// contains filtered or unexported methods
}

MetaServiceServer is the server API for MetaService service. All implementations must embed UnimplementedMetaServiceServer for forward compatibility

type OpType 

type OpType int32
const (
	OpType_UNKNOWN  OpType = 0
	OpType_PREWRITE OpType = 1
	OpType_COMMIT   OpType = 2
	OpType_ROLLBACK OpType = 3
)

func (OpType) Descriptor 

func (OpType) Descriptor() protoreflect.EnumDescriptor

func (OpType) Enum 

func (x OpType) Enum() *OpType

func (OpType) EnumDescriptor deprecated 

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

Deprecated: Use OpType.Descriptor instead.

func (OpType) Number 

func (x OpType) Number() protoreflect.EnumNumber

func (OpType) String 

func (x OpType) String() string

func (OpType) Type 

func (OpType) Type() protoreflect.EnumType

type PullTenantDataReq 

type PullTenantDataReq struct {
	TenantId      uint64      `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Range         *Task_Range `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	LowWatermark  uint64      `protobuf:"varint,3,opt,name=low_watermark,json=lowWatermark,proto3" json:"low_watermark,omitempty"`
	HighWatermark uint64      `protobuf:"varint,4,opt,name=high_watermark,json=highWatermark,proto3" json:"high_watermark,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTenantDataReq) Descriptor deprecated 

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

Deprecated: Use PullTenantDataReq.ProtoReflect.Descriptor instead.

func (*PullTenantDataReq) GetHighWatermark 

func (x *PullTenantDataReq) GetHighWatermark() uint64

func (*PullTenantDataReq) GetLowWatermark 

func (x *PullTenantDataReq) GetLowWatermark() uint64

func (*PullTenantDataReq) GetRange 

func (x *PullTenantDataReq) GetRange() *Task_Range

func (*PullTenantDataReq) GetTenantId 

func (x *PullTenantDataReq) GetTenantId() uint64

func (*PullTenantDataReq) ProtoMessage 

func (*PullTenantDataReq) ProtoMessage()

func (*PullTenantDataReq) ProtoReflect 

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

func (*PullTenantDataReq) Reset 

func (x *PullTenantDataReq) Reset()

func (*PullTenantDataReq) String 

func (x *PullTenantDataReq) String() string

type PullTenantDataResp 

type PullTenantDataResp struct {
	Rows []*EventRow `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTenantDataResp) Descriptor deprecated 

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

Deprecated: Use PullTenantDataResp.ProtoReflect.Descriptor instead.

func (*PullTenantDataResp) GetRows 

func (x *PullTenantDataResp) GetRows() []*EventRow

func (*PullTenantDataResp) ProtoMessage 

func (*PullTenantDataResp) ProtoMessage()

func (*PullTenantDataResp) ProtoReflect 

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

func (*PullTenantDataResp) Reset 

func (x *PullTenantDataResp) Reset()

func (*PullTenantDataResp) String 

func (x *PullTenantDataResp) String() string

type RangeChangesReq 

type RangeChangesReq struct {
	TenantId   uint64            `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Range      *Task_Range       `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Rows       []*EventRow       `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	Watermarks []*EventWatermark `protobuf:"bytes,4,rep,name=watermarks,proto3" json:"watermarks,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeChangesReq) Descriptor deprecated 

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

Deprecated: Use RangeChangesReq.ProtoReflect.Descriptor instead.

func (*RangeChangesReq) GetRange 

func (x *RangeChangesReq) GetRange() *Task_Range

func (*RangeChangesReq) GetRows 

func (x *RangeChangesReq) GetRows() []*EventRow

func (*RangeChangesReq) GetTenantId 

func (x *RangeChangesReq) GetTenantId() uint64

func (*RangeChangesReq) GetWatermarks 

func (x *RangeChangesReq) GetWatermarks() []*EventWatermark

func (*RangeChangesReq) ProtoMessage 

func (*RangeChangesReq) ProtoMessage()

func (*RangeChangesReq) ProtoReflect 

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

func (*RangeChangesReq) Reset 

func (x *RangeChangesReq) Reset()

func (*RangeChangesReq) String 

func (x *RangeChangesReq) String() string

type RangeChangesResp 

type RangeChangesResp struct {
	ErrMsg string `protobuf:"bytes,1,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeChangesResp) Descriptor deprecated 

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

Deprecated: Use RangeChangesResp.ProtoReflect.Descriptor instead.

func (*RangeChangesResp) GetErrMsg 

func (x *RangeChangesResp) GetErrMsg() string

func (*RangeChangesResp) ProtoMessage 

func (*RangeChangesResp) ProtoMessage()

func (*RangeChangesResp) ProtoReflect 

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

func (*RangeChangesResp) Reset 

func (x *RangeChangesResp) Reset()

func (*RangeChangesResp) String 

func (x *RangeChangesResp) String() string

type RangesSnapshot 

type RangesSnapshot struct {
	TenantId uint64        `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Ts       uint64        `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	Ranges   []*Task_Range `protobuf:"bytes,3,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

Snapshot of all ranges for a tenant at a specified timestamp.

func (*RangesSnapshot) Descriptor deprecated 

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

Deprecated: Use RangesSnapshot.ProtoReflect.Descriptor instead.

func (*RangesSnapshot) GetRanges 

func (x *RangesSnapshot) GetRanges() []*Task_Range

func (*RangesSnapshot) GetTenantId 

func (x *RangesSnapshot) GetTenantId() uint64

func (*RangesSnapshot) GetTs 

func (x *RangesSnapshot) GetTs() uint64

func (*RangesSnapshot) ProtoMessage 

func (*RangesSnapshot) ProtoMessage()

func (*RangesSnapshot) ProtoReflect 

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

func (*RangesSnapshot) Reset 

func (x *RangesSnapshot) Reset()

func (*RangesSnapshot) String 

func (x *RangesSnapshot) String() string

type RegisterDDLReq 

type RegisterDDLReq struct {
	TenantId uint64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Ts       uint64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	// Types that are assignable to Ddl:
	//
	//	*RegisterDDLReq_TableDdl
	//	*RegisterDDLReq_SchemaDdl
	Ddl isRegisterDDLReq_Ddl `protobuf_oneof:"ddl"`
	// contains filtered or unexported fields
}

func (*RegisterDDLReq) Descriptor deprecated 

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

Deprecated: Use RegisterDDLReq.ProtoReflect.Descriptor instead.

func (*RegisterDDLReq) GetDdl 

func (m *RegisterDDLReq) GetDdl() isRegisterDDLReq_Ddl

func (*RegisterDDLReq) GetSchemaDdl 

func (x *RegisterDDLReq) GetSchemaDdl() *Schema

func (*RegisterDDLReq) GetTableDdl 

func (x *RegisterDDLReq) GetTableDdl() *Table

func (*RegisterDDLReq) GetTenantId 

func (x *RegisterDDLReq) GetTenantId() uint64

func (*RegisterDDLReq) GetTs 

func (x *RegisterDDLReq) GetTs() uint64

func (*RegisterDDLReq) ProtoMessage 

func (*RegisterDDLReq) ProtoMessage()

func (*RegisterDDLReq) ProtoReflect 

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

func (*RegisterDDLReq) Reset 

func (x *RegisterDDLReq) Reset()

func (*RegisterDDLReq) String 

func (x *RegisterDDLReq) String() string

type RegisterDDLReq_SchemaDdl 

type RegisterDDLReq_SchemaDdl struct {
	SchemaDdl *Schema `protobuf:"bytes,4,opt,name=schema_ddl,json=schemaDdl,proto3,oneof"`
}

type RegisterDDLReq_TableDdl 

type RegisterDDLReq_TableDdl struct {
	TableDdl *Table `protobuf:"bytes,3,opt,name=table_ddl,json=tableDdl,proto3,oneof"`
}

type RegisterDDLResp 

type RegisterDDLResp struct {
	TenantId uint64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ErrMsg   string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterDDLResp) Descriptor deprecated 

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

Deprecated: Use RegisterDDLResp.ProtoReflect.Descriptor instead.

func (*RegisterDDLResp) GetErrMsg 

func (x *RegisterDDLResp) GetErrMsg() string

func (*RegisterDDLResp) GetTenantId 

func (x *RegisterDDLResp) GetTenantId() uint64

func (*RegisterDDLResp) ProtoMessage 

func (*RegisterDDLResp) ProtoMessage()

func (*RegisterDDLResp) ProtoReflect 

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

func (*RegisterDDLResp) Reset 

func (x *RegisterDDLResp) Reset()

func (*RegisterDDLResp) String 

func (x *RegisterDDLResp) String() string

type RegisterSchemaSnapReq 

type RegisterSchemaSnapReq struct {
	TenantId   uint64          `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Ts         uint64          `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	SchemaSnap *SchemaSnapshot `protobuf:"bytes,3,opt,name=schema_snap,json=schemaSnap,proto3" json:"schema_snap,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSchemaSnapReq) Descriptor deprecated 

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

Deprecated: Use RegisterSchemaSnapReq.ProtoReflect.Descriptor instead.

func (*RegisterSchemaSnapReq) GetSchemaSnap 

func (x *RegisterSchemaSnapReq) GetSchemaSnap() *SchemaSnapshot

func (*RegisterSchemaSnapReq) GetTenantId 

func (x *RegisterSchemaSnapReq) GetTenantId() uint64

func (*RegisterSchemaSnapReq) GetTs 

func (x *RegisterSchemaSnapReq) GetTs() uint64

func (*RegisterSchemaSnapReq) ProtoMessage 

func (*RegisterSchemaSnapReq) ProtoMessage()

func (*RegisterSchemaSnapReq) ProtoReflect 

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

func (*RegisterSchemaSnapReq) Reset 

func (x *RegisterSchemaSnapReq) Reset()

func (*RegisterSchemaSnapReq) String 

func (x *RegisterSchemaSnapReq) String() string

type RegisterSchemaSnapResp 

type RegisterSchemaSnapResp struct {
	TenantId uint64 `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ErrMsg   string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSchemaSnapResp) Descriptor deprecated 

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

Deprecated: Use RegisterSchemaSnapResp.ProtoReflect.Descriptor instead.

func (*RegisterSchemaSnapResp) GetErrMsg 

func (x *RegisterSchemaSnapResp) GetErrMsg() string

func (*RegisterSchemaSnapResp) GetTenantId 

func (x *RegisterSchemaSnapResp) GetTenantId() uint64

func (*RegisterSchemaSnapResp) ProtoMessage 

func (*RegisterSchemaSnapResp) ProtoMessage()

func (*RegisterSchemaSnapResp) ProtoReflect 

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

func (*RegisterSchemaSnapResp) Reset 

func (x *RegisterSchemaSnapResp) Reset()

func (*RegisterSchemaSnapResp) String 

func (x *RegisterSchemaSnapResp) String() string

type Schema 

type Schema struct {
	Name      string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id        uint64    `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Charset   string    `protobuf:"bytes,3,opt,name=charset,proto3" json:"charset,omitempty"`
	Collation string    `protobuf:"bytes,4,opt,name=collation,proto3" json:"collation,omitempty"`
	Op        Schema_OP `protobuf:"varint,5,opt,name=op,proto3,enum=tistreampb.Schema_OP" json:"op,omitempty"`
	Ts        uint64    `protobuf:"varint,6,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetCharset 

func (x *Schema) GetCharset() string

func (*Schema) GetCollation 

func (x *Schema) GetCollation() string

func (*Schema) GetId 

func (x *Schema) GetId() uint64

func (*Schema) GetName 

func (x *Schema) GetName() string

func (*Schema) GetOp 

func (x *Schema) GetOp() Schema_OP

func (*Schema) GetTs 

func (x *Schema) GetTs() uint64

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SchemaServiceClient 

type SchemaServiceClient interface {
	RegisterSchemaSnap(ctx context.Context, in *RegisterSchemaSnapReq, opts ...grpc.CallOption) (*RegisterSchemaSnapResp, error)
	RegisterDDLChange(ctx context.Context, in *RegisterDDLReq, opts ...grpc.CallOption) (*RegisterDDLResp, error)
}

SchemaServiceClient is the client API for SchemaService 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 NewSchemaServiceClient 

func NewSchemaServiceClient(cc grpc.ClientConnInterface) SchemaServiceClient

type SchemaServiceServer 

type SchemaServiceServer interface {
	RegisterSchemaSnap(context.Context, *RegisterSchemaSnapReq) (*RegisterSchemaSnapResp, error)
	RegisterDDLChange(context.Context, *RegisterDDLReq) (*RegisterDDLResp, error)
	// contains filtered or unexported methods
}

SchemaServiceServer is the server API for SchemaService service. All implementations must embed UnimplementedSchemaServiceServer for forward compatibility

type SchemaSnapshot 

type SchemaSnapshot struct {
	Ts      uint64          `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Schemas []*SchemaTables `protobuf:"bytes,2,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaSnapshot) Descriptor deprecated 

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

Deprecated: Use SchemaSnapshot.ProtoReflect.Descriptor instead.

func (*SchemaSnapshot) GetSchemas 

func (x *SchemaSnapshot) GetSchemas() []*SchemaTables

func (*SchemaSnapshot) GetTs 

func (x *SchemaSnapshot) GetTs() uint64

func (*SchemaSnapshot) ProtoMessage 

func (*SchemaSnapshot) ProtoMessage()

func (*SchemaSnapshot) ProtoReflect 

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

func (*SchemaSnapshot) Reset 

func (x *SchemaSnapshot) Reset()

func (*SchemaSnapshot) String 

func (x *SchemaSnapshot) String() string

type SchemaTables 

type SchemaTables struct {
	Schema *Schema  `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Tables []*Table `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaTables) Descriptor deprecated 

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

Deprecated: Use SchemaTables.ProtoReflect.Descriptor instead.

func (*SchemaTables) GetSchema 

func (x *SchemaTables) GetSchema() *Schema

func (*SchemaTables) GetTables 

func (x *SchemaTables) GetTables() []*Table

func (*SchemaTables) ProtoMessage 

func (*SchemaTables) ProtoMessage()

func (*SchemaTables) ProtoReflect 

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

func (*SchemaTables) Reset 

func (x *SchemaTables) Reset()

func (*SchemaTables) String 

func (x *SchemaTables) String() string

type Schema_OP 

type Schema_OP int32
const (
	Schema_CREATE Schema_OP = 0
	Schema_DROP   Schema_OP = 1
)

func (Schema_OP) Descriptor 

func (Schema_OP) Descriptor() protoreflect.EnumDescriptor

func (Schema_OP) Enum 

func (x Schema_OP) Enum() *Schema_OP

func (Schema_OP) EnumDescriptor deprecated 

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

Deprecated: Use Schema_OP.Descriptor instead.

func (Schema_OP) Number 

func (x Schema_OP) Number() protoreflect.EnumNumber

func (Schema_OP) String 

func (x Schema_OP) String() string

func (Schema_OP) Type 

func (Schema_OP) Type() protoreflect.EnumType

type SorterHeartbeatReq 

type SorterHeartbeatReq struct {
	Addr        string            `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`                                  // sorter addr, used to distiguish dispatchers.
	Throughput  uint64            `protobuf:"varint,2,opt,name=throughput,proto3" json:"throughput,omitempty"`                     // throughput since last heartbeat.
	TenantStats []*TenantSubStats `protobuf:"bytes,3,rep,name=tenant_stats,json=tenantStats,proto3" json:"tenant_stats,omitempty"` // tenant id and throughput.
	// contains filtered or unexported fields
}

func (*SorterHeartbeatReq) Descriptor deprecated 

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

Deprecated: Use SorterHeartbeatReq.ProtoReflect.Descriptor instead.

func (*SorterHeartbeatReq) GetAddr 

func (x *SorterHeartbeatReq) GetAddr() string

func (*SorterHeartbeatReq) GetTenantStats 

func (x *SorterHeartbeatReq) GetTenantStats() []*TenantSubStats

func (*SorterHeartbeatReq) GetThroughput 

func (x *SorterHeartbeatReq) GetThroughput() uint64

func (*SorterHeartbeatReq) ProtoMessage 

func (*SorterHeartbeatReq) ProtoMessage()

func (*SorterHeartbeatReq) ProtoReflect 

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

func (*SorterHeartbeatReq) Reset 

func (x *SorterHeartbeatReq) Reset()

func (*SorterHeartbeatReq) String 

func (x *SorterHeartbeatReq) String() string

type SorterHeartbeatResp 

type SorterHeartbeatResp struct {
	// contains filtered or unexported fields
}

func (*SorterHeartbeatResp) Descriptor deprecated 

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

Deprecated: Use SorterHeartbeatResp.ProtoReflect.Descriptor instead.

func (*SorterHeartbeatResp) ProtoMessage 

func (*SorterHeartbeatResp) ProtoMessage()

func (*SorterHeartbeatResp) ProtoReflect 

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

func (*SorterHeartbeatResp) Reset 

func (x *SorterHeartbeatResp) Reset()

func (*SorterHeartbeatResp) String 

func (x *SorterHeartbeatResp) String() string

type SorterServiceClient 

type SorterServiceClient interface {
	NewDataChanges(ctx context.Context, in *RangeChangesReq, opts ...grpc.CallOption) (*RangeChangesResp, error)
}

SorterServiceClient is the client API for SorterService 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 NewSorterServiceClient 

func NewSorterServiceClient(cc grpc.ClientConnInterface) SorterServiceClient

type SorterServiceServer 

type SorterServiceServer interface {
	NewDataChanges(context.Context, *RangeChangesReq) (*RangeChangesResp, error)
	// contains filtered or unexported methods
}

SorterServiceServer is the server API for SorterService service. All implementations must embed UnimplementedSorterServiceServer for forward compatibility

type Table 

type Table struct {
	Name            string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id              uint64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Op              Table_OP `protobuf:"varint,3,opt,name=op,proto3,enum=tistreampb.Table_OP" json:"op,omitempty"`
	Ts              uint64   `protobuf:"varint,4,opt,name=ts,proto3" json:"ts,omitempty"`
	Statement       string   `protobuf:"bytes,5,opt,name=statement,proto3" json:"statement,omitempty"`
	CreateStatement string   `protobuf:"bytes,6,opt,name=create_statement,json=createStatement,proto3" json:"create_statement,omitempty"`
	Schema          *Schema  `protobuf:"bytes,7,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetCreateStatement 

func (x *Table) GetCreateStatement() string

func (*Table) GetId 

func (x *Table) GetId() uint64

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) GetOp 

func (x *Table) GetOp() Table_OP

func (*Table) GetSchema 

func (x *Table) GetSchema() *Schema

func (*Table) GetStatement 

func (x *Table) GetStatement() string

func (*Table) GetTs 

func (x *Table) GetTs() uint64

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 Table_OP 

type Table_OP int32
const (
	Table_CREATE Table_OP = 0
	Table_DROP   Table_OP = 1
	Table_ALTER  Table_OP = 2
)

func (Table_OP) Descriptor 

func (Table_OP) Descriptor() protoreflect.EnumDescriptor

func (Table_OP) Enum 

func (x Table_OP) Enum() *Table_OP

func (Table_OP) EnumDescriptor deprecated 

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

Deprecated: Use Table_OP.Descriptor instead.

func (Table_OP) Number 

func (x Table_OP) Number() protoreflect.EnumNumber

func (Table_OP) String 

func (x Table_OP) String() string

func (Table_OP) Type 

func (Table_OP) Type() protoreflect.EnumType

type Task 

type Task struct {
	TenantId   uint64      `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Range      *Task_Range `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	SorterAddr string      `protobuf:"bytes,3,opt,name=sorter_addr,json=sorterAddr,proto3" json:"sorter_addr,omitempty"`
	SnapAddr   string      `protobuf:"bytes,4,opt,name=snap_addr,json=snapAddr,proto3" json:"snap_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetRange 

func (x *Task) GetRange() *Task_Range

func (*Task) GetSnapAddr 

func (x *Task) GetSnapAddr() string

func (*Task) GetSorterAddr 

func (x *Task) GetSorterAddr() string

func (*Task) GetTenantId 

func (x *Task) GetTenantId() uint64

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskOp 

type TaskOp int32
const (
	TaskOp_Attach TaskOp = 0
	TaskOp_Detach TaskOp = 1
)

func (TaskOp) Descriptor 

func (TaskOp) Descriptor() protoreflect.EnumDescriptor

func (TaskOp) Enum 

func (x TaskOp) Enum() *TaskOp

func (TaskOp) EnumDescriptor deprecated 

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

Deprecated: Use TaskOp.Descriptor instead.

func (TaskOp) Number 

func (x TaskOp) Number() protoreflect.EnumNumber

func (TaskOp) String 

func (x TaskOp) String() string

func (TaskOp) Type 

func (TaskOp) Type() protoreflect.EnumType

type Task_Range 

type Task_Range struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Uuid  string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` // unique id for a range. it is used as the folder name for the range.
	// contains filtered or unexported fields
}

func (*Task_Range) Descriptor deprecated 

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

Deprecated: Use Task_Range.ProtoReflect.Descriptor instead.

func (*Task_Range) GetEnd 

func (x *Task_Range) GetEnd() []byte

func (*Task_Range) GetStart 

func (x *Task_Range) GetStart() []byte

func (*Task_Range) GetUuid 

func (x *Task_Range) GetUuid() string

func (*Task_Range) ProtoMessage 

func (*Task_Range) ProtoMessage()

func (*Task_Range) ProtoReflect 

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

func (*Task_Range) Reset 

func (x *Task_Range) Reset()

func (*Task_Range) String 

func (x *Task_Range) String() string

type TenantSubStats 

type TenantSubStats struct {
	TenantId   uint64      `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Range      *Task_Range `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Throughput uint64      `protobuf:"varint,3,opt,name=throughput,proto3" json:"throughput,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantSubStats) Descriptor deprecated 

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

Deprecated: Use TenantSubStats.ProtoReflect.Descriptor instead.

func (*TenantSubStats) GetRange 

func (x *TenantSubStats) GetRange() *Task_Range

func (*TenantSubStats) GetTenantId 

func (x *TenantSubStats) GetTenantId() uint64

func (*TenantSubStats) GetThroughput 

func (x *TenantSubStats) GetThroughput() uint64

func (*TenantSubStats) ProtoMessage 

func (*TenantSubStats) ProtoMessage()

func (*TenantSubStats) ProtoReflect 

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

func (*TenantSubStats) Reset 

func (x *TenantSubStats) Reset()

func (*TenantSubStats) String 

func (x *TenantSubStats) String() string

type TenantTasksReq 

type TenantTasksReq struct {
	TenantId uint64  `protobuf:"varint,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Tasks    []*Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Op       TaskOp  `protobuf:"varint,3,opt,name=op,proto3,enum=tistreampb.TaskOp" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantTasksReq) Descriptor deprecated 

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

Deprecated: Use TenantTasksReq.ProtoReflect.Descriptor instead.

func (*TenantTasksReq) GetOp 

func (x *TenantTasksReq) GetOp() TaskOp

func (*TenantTasksReq) GetTasks 

func (x *TenantTasksReq) GetTasks() []*Task

func (*TenantTasksReq) GetTenantId 

func (x *TenantTasksReq) GetTenantId() uint64

func (*TenantTasksReq) ProtoMessage 

func (*TenantTasksReq) ProtoMessage()

func (*TenantTasksReq) ProtoReflect 

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

func (*TenantTasksReq) Reset 

func (x *TenantTasksReq) Reset()

func (*TenantTasksReq) String 

func (x *TenantTasksReq) String() string

type TenantTasksResp 

type TenantTasksResp struct {
	// contains filtered or unexported fields
}

func (*TenantTasksResp) Descriptor deprecated 

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

Deprecated: Use TenantTasksResp.ProtoReflect.Descriptor instead.

func (*TenantTasksResp) ProtoMessage 

func (*TenantTasksResp) ProtoMessage()

func (*TenantTasksResp) ProtoReflect 

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

func (*TenantTasksResp) Reset 

func (x *TenantTasksResp) Reset()

func (*TenantTasksResp) String 

func (x *TenantTasksResp) String() string

type UnimplementedApiServiceServer 

type UnimplementedApiServiceServer struct {
}

UnimplementedApiServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedApiServiceServer) PullData 

func (UnimplementedApiServiceServer) PullData(context.Context, *PullTenantDataReq) (*PullTenantDataResp, error)

type UnimplementedDispatcherServiceServer 

type UnimplementedDispatcherServiceServer struct {
}

UnimplementedDispatcherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDispatcherServiceServer) NotifiyTenantHasUpdate 

func (UnimplementedDispatcherServiceServer) NotifiyTenantHasUpdate(context.Context, *HasNewChangeReq) (*HasNewChangeResp, error)

func (UnimplementedDispatcherServiceServer) ScheduleNewTenant 

func (UnimplementedDispatcherServiceServer) ScheduleNewTenant(context.Context, *TenantTasksReq) (*TenantTasksResp, error)

type UnimplementedMetaServiceServer 

type UnimplementedMetaServiceServer struct {
}

UnimplementedMetaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetaServiceServer) DispatcherHeartbeat 

func (UnimplementedMetaServiceServer) DispatcherHeartbeat(context.Context, *DispatcherHeartbeatReq) (*DispatcherHeartbeatResp, error)

func (UnimplementedMetaServiceServer) FetchRangeSorterAddr 

func (UnimplementedMetaServiceServer) FetchRangeSorterAddr(context.Context, *FetchRangeSorterAddrReq) (*FetchRangeSorterAddrResp, error)

func (UnimplementedMetaServiceServer) FetchSchemaRegistryAddr 

func (UnimplementedMetaServiceServer) FetchSchemaRegistryAddr(context.Context, *FetchSchemaRegistryAddrReq) (*FetchSchemaRegistryAddrResp, error)

func (UnimplementedMetaServiceServer) SorterHeartbeat 

func (UnimplementedMetaServiceServer) SorterHeartbeat(context.Context, *SorterHeartbeatReq) (*SorterHeartbeatResp, error)

func (UnimplementedMetaServiceServer) TenantHasNewChange 

func (UnimplementedMetaServiceServer) TenantHasNewChange(context.Context, *HasNewChangeReq) (*HasNewChangeResp, error)

type UnimplementedSchemaServiceServer 

type UnimplementedSchemaServiceServer struct {
}

UnimplementedSchemaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSchemaServiceServer) RegisterDDLChange 

func (UnimplementedSchemaServiceServer) RegisterDDLChange(context.Context, *RegisterDDLReq) (*RegisterDDLResp, error)

func (UnimplementedSchemaServiceServer) RegisterSchemaSnap 

func (UnimplementedSchemaServiceServer) RegisterSchemaSnap(context.Context, *RegisterSchemaSnapReq) (*RegisterSchemaSnapResp, error)

type UnimplementedSorterServiceServer 

type UnimplementedSorterServiceServer struct {
}

UnimplementedSorterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSorterServiceServer) NewDataChanges 

func (UnimplementedSorterServiceServer) NewDataChanges(context.Context, *RangeChangesReq) (*RangeChangesResp, error)

type UnsafeApiServiceServer 

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

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

type UnsafeDispatcherServiceServer 

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

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

type UnsafeMetaServiceServer 

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

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

type UnsafeSchemaServiceServer 

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

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

type UnsafeSorterServiceServer 

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

UnsafeSorterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SorterServiceServer 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.