carnotpb

package
v0.0.0-...-73c8340 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCarnot        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCarnot          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCarnot = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterResultSinkServiceServer 

func RegisterResultSinkServiceServer(s *grpc.Server, srv ResultSinkServiceServer)

Types

type ResultSinkServiceClient 

type ResultSinkServiceClient interface {
	TransferResultChunk(ctx context.Context, opts ...grpc.CallOption) (ResultSinkService_TransferResultChunkClient, error)
}

ResultSinkServiceClient is the client API for ResultSinkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewResultSinkServiceClient 

func NewResultSinkServiceClient(cc *grpc.ClientConn) ResultSinkServiceClient

type ResultSinkServiceServer 

type ResultSinkServiceServer interface {
	TransferResultChunk(ResultSinkService_TransferResultChunkServer) error
}

ResultSinkServiceServer is the server API for ResultSinkService service.

type ResultSinkService_TransferResultChunkClient 

type ResultSinkService_TransferResultChunkClient interface {
	Send(*TransferResultChunkRequest) error
	CloseAndRecv() (*TransferResultChunkResponse, error)
	grpc.ClientStream
}

type ResultSinkService_TransferResultChunkServer 

type ResultSinkService_TransferResultChunkServer interface {
	SendAndClose(*TransferResultChunkResponse) error
	Recv() (*TransferResultChunkRequest, error)
	grpc.ServerStream
}

type TransferResultChunkRequest 

type TransferResultChunkRequest struct {
	Address string       `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	QueryID *uuidpb.UUID `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*TransferResultChunkRequest_QueryResult
	//	*TransferResultChunkRequest_ExecutionAndTimingInfo
	//	*TransferResultChunkRequest_ExecutionError
	//	*TransferResultChunkRequest_InitiateConn
	Result isTransferResultChunkRequest_Result `protobuf_oneof:"result"`
}

func (*TransferResultChunkRequest) Descriptor 

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

func (*TransferResultChunkRequest) Equal 

func (this *TransferResultChunkRequest) Equal(that interface{}) bool

func (*TransferResultChunkRequest) GetAddress 

func (m *TransferResultChunkRequest) GetAddress() string

func (*TransferResultChunkRequest) GetExecutionAndTimingInfo 

func (m *TransferResultChunkRequest) GetExecutionAndTimingInfo() *TransferResultChunkRequest_QueryExecutionAndTimingInfo

func (*TransferResultChunkRequest) GetExecutionError 

func (m *TransferResultChunkRequest) GetExecutionError() *statuspb.Status

func (*TransferResultChunkRequest) GetInitiateConn 

func (m *TransferResultChunkRequest) GetInitiateConn() *TransferResultChunkRequest_InitiateConnection

func (*TransferResultChunkRequest) GetQueryID 

func (m *TransferResultChunkRequest) GetQueryID() *uuidpb.UUID

func (*TransferResultChunkRequest) GetQueryResult 

func (m *TransferResultChunkRequest) GetQueryResult() *TransferResultChunkRequest_SinkResult

func (*TransferResultChunkRequest) GetResult 

func (m *TransferResultChunkRequest) GetResult() isTransferResultChunkRequest_Result

func (*TransferResultChunkRequest) GoString 

func (this *TransferResultChunkRequest) GoString() string

func (*TransferResultChunkRequest) Marshal 

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

func (*TransferResultChunkRequest) MarshalTo 

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

func (*TransferResultChunkRequest) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest) ProtoMessage 

func (*TransferResultChunkRequest) ProtoMessage()

func (*TransferResultChunkRequest) Reset 

func (m *TransferResultChunkRequest) Reset()

func (*TransferResultChunkRequest) Size 

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

func (*TransferResultChunkRequest) String 

func (this *TransferResultChunkRequest) String() string

func (*TransferResultChunkRequest) Unmarshal 

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

func (*TransferResultChunkRequest) XXX_DiscardUnknown 

func (m *TransferResultChunkRequest) XXX_DiscardUnknown()

func (*TransferResultChunkRequest) XXX_Marshal 

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

func (*TransferResultChunkRequest) XXX_Merge 

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

func (*TransferResultChunkRequest) XXX_OneofWrappers 

func (*TransferResultChunkRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransferResultChunkRequest) XXX_Size 

func (m *TransferResultChunkRequest) XXX_Size() int

func (*TransferResultChunkRequest) XXX_Unmarshal 

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

type TransferResultChunkRequest_ExecutionAndTimingInfo 

type TransferResultChunkRequest_ExecutionAndTimingInfo struct {
	ExecutionAndTimingInfo *TransferResultChunkRequest_QueryExecutionAndTimingInfo `` /* 137-byte string literal not displayed */
}

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) Equal 

func (this *TransferResultChunkRequest_ExecutionAndTimingInfo) Equal(that interface{}) bool

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) GoString 

func (this *TransferResultChunkRequest_ExecutionAndTimingInfo) GoString() string

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) MarshalTo 

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

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) Size 

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

func (*TransferResultChunkRequest_ExecutionAndTimingInfo) String 

func (this *TransferResultChunkRequest_ExecutionAndTimingInfo) String() string

type TransferResultChunkRequest_ExecutionError 

type TransferResultChunkRequest_ExecutionError struct {
	ExecutionError *statuspb.Status `protobuf:"bytes,7,opt,name=execution_error,json=executionError,proto3,oneof" json:"execution_error,omitempty"`
}

func (*TransferResultChunkRequest_ExecutionError) Equal 

func (this *TransferResultChunkRequest_ExecutionError) Equal(that interface{}) bool

func (*TransferResultChunkRequest_ExecutionError) GoString 

func (this *TransferResultChunkRequest_ExecutionError) GoString() string

func (*TransferResultChunkRequest_ExecutionError) MarshalTo 

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

func (*TransferResultChunkRequest_ExecutionError) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_ExecutionError) Size 

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

func (*TransferResultChunkRequest_ExecutionError) String 

func (this *TransferResultChunkRequest_ExecutionError) String() string

type TransferResultChunkRequest_InitiateConn 

type TransferResultChunkRequest_InitiateConn struct {
	InitiateConn *TransferResultChunkRequest_InitiateConnection `protobuf:"bytes,8,opt,name=initiate_conn,json=initiateConn,proto3,oneof" json:"initiate_conn,omitempty"`
}

func (*TransferResultChunkRequest_InitiateConn) Equal 

func (this *TransferResultChunkRequest_InitiateConn) Equal(that interface{}) bool

func (*TransferResultChunkRequest_InitiateConn) GoString 

func (this *TransferResultChunkRequest_InitiateConn) GoString() string

func (*TransferResultChunkRequest_InitiateConn) MarshalTo 

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

func (*TransferResultChunkRequest_InitiateConn) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_InitiateConn) Size 

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

func (*TransferResultChunkRequest_InitiateConn) String 

func (this *TransferResultChunkRequest_InitiateConn) String() string

type TransferResultChunkRequest_InitiateConnection 

type TransferResultChunkRequest_InitiateConnection struct {
}

func (*TransferResultChunkRequest_InitiateConnection) Descriptor 

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

func (*TransferResultChunkRequest_InitiateConnection) Equal 

func (this *TransferResultChunkRequest_InitiateConnection) Equal(that interface{}) bool

func (*TransferResultChunkRequest_InitiateConnection) GoString 

func (this *TransferResultChunkRequest_InitiateConnection) GoString() string

func (*TransferResultChunkRequest_InitiateConnection) Marshal 

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

func (*TransferResultChunkRequest_InitiateConnection) MarshalTo 

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

func (*TransferResultChunkRequest_InitiateConnection) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_InitiateConnection) ProtoMessage 

func (*TransferResultChunkRequest_InitiateConnection) ProtoMessage()

func (*TransferResultChunkRequest_InitiateConnection) Reset 

func (m *TransferResultChunkRequest_InitiateConnection) Reset()

func (*TransferResultChunkRequest_InitiateConnection) Size 

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

func (*TransferResultChunkRequest_InitiateConnection) String 

func (this *TransferResultChunkRequest_InitiateConnection) String() string

func (*TransferResultChunkRequest_InitiateConnection) Unmarshal 

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

func (*TransferResultChunkRequest_InitiateConnection) XXX_DiscardUnknown 

func (m *TransferResultChunkRequest_InitiateConnection) XXX_DiscardUnknown()

func (*TransferResultChunkRequest_InitiateConnection) XXX_Marshal 

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

func (*TransferResultChunkRequest_InitiateConnection) XXX_Merge 

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

func (*TransferResultChunkRequest_InitiateConnection) XXX_Size 

func (m *TransferResultChunkRequest_InitiateConnection) XXX_Size() int

func (*TransferResultChunkRequest_InitiateConnection) XXX_Unmarshal 

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

type TransferResultChunkRequest_QueryExecutionAndTimingInfo 

type TransferResultChunkRequest_QueryExecutionAndTimingInfo struct {
	ExecutionStats      *queryresultspb.QueryExecutionStats   `protobuf:"bytes,2,opt,name=execution_stats,json=executionStats,proto3" json:"execution_stats,omitempty"`
	AgentExecutionStats []*queryresultspb.AgentExecutionStats `protobuf:"bytes,3,rep,name=agent_execution_stats,json=agentExecutionStats,proto3" json:"agent_execution_stats,omitempty"`
}

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Descriptor 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Equal 

func (this *TransferResultChunkRequest_QueryExecutionAndTimingInfo) Equal(that interface{}) bool

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) GetAgentExecutionStats 

func (m *TransferResultChunkRequest_QueryExecutionAndTimingInfo) GetAgentExecutionStats() []*queryresultspb.AgentExecutionStats

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) GetExecutionStats 

func (m *TransferResultChunkRequest_QueryExecutionAndTimingInfo) GetExecutionStats() *queryresultspb.QueryExecutionStats

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) GoString 

func (this *TransferResultChunkRequest_QueryExecutionAndTimingInfo) GoString() string

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Marshal 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) MarshalTo 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) ProtoMessage 

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) ProtoMessage()

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Reset 

func (m *TransferResultChunkRequest_QueryExecutionAndTimingInfo) Reset()

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Size 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) String 

func (this *TransferResultChunkRequest_QueryExecutionAndTimingInfo) String() string

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) Unmarshal 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_DiscardUnknown 

func (m *TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_DiscardUnknown()

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_Marshal 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_Merge 

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

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_Size 

func (m *TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_Size() int

func (*TransferResultChunkRequest_QueryExecutionAndTimingInfo) XXX_Unmarshal 

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

type TransferResultChunkRequest_QueryResult 

type TransferResultChunkRequest_QueryResult struct {
	QueryResult *TransferResultChunkRequest_SinkResult `protobuf:"bytes,5,opt,name=query_result,json=queryResult,proto3,oneof" json:"query_result,omitempty"`
}

func (*TransferResultChunkRequest_QueryResult) Equal 

func (this *TransferResultChunkRequest_QueryResult) Equal(that interface{}) bool

func (*TransferResultChunkRequest_QueryResult) GoString 

func (this *TransferResultChunkRequest_QueryResult) GoString() string

func (*TransferResultChunkRequest_QueryResult) MarshalTo 

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

func (*TransferResultChunkRequest_QueryResult) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_QueryResult) Size 

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

func (*TransferResultChunkRequest_QueryResult) String 

func (this *TransferResultChunkRequest_QueryResult) String() string

type TransferResultChunkRequest_SinkResult 

type TransferResultChunkRequest_SinkResult struct {
	// Types that are valid to be assigned to ResultContents:
	//	*TransferResultChunkRequest_SinkResult_RowBatch
	ResultContents isTransferResultChunkRequest_SinkResult_ResultContents `protobuf_oneof:"result_contents"`
	// Types that are valid to be assigned to Destination:
	//	*TransferResultChunkRequest_SinkResult_GRPCSourceID
	//	*TransferResultChunkRequest_SinkResult_TableName
	Destination isTransferResultChunkRequest_SinkResult_Destination `protobuf_oneof:"destination"`
}

func (*TransferResultChunkRequest_SinkResult) Descriptor 

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

func (*TransferResultChunkRequest_SinkResult) Equal 

func (this *TransferResultChunkRequest_SinkResult) Equal(that interface{}) bool

func (*TransferResultChunkRequest_SinkResult) GetDestination 

func (m *TransferResultChunkRequest_SinkResult) GetDestination() isTransferResultChunkRequest_SinkResult_Destination

func (*TransferResultChunkRequest_SinkResult) GetGRPCSourceID 

func (m *TransferResultChunkRequest_SinkResult) GetGRPCSourceID() uint64

func (*TransferResultChunkRequest_SinkResult) GetResultContents 

func (m *TransferResultChunkRequest_SinkResult) GetResultContents() isTransferResultChunkRequest_SinkResult_ResultContents

func (*TransferResultChunkRequest_SinkResult) GetRowBatch 

func (m *TransferResultChunkRequest_SinkResult) GetRowBatch() *schemapb.RowBatchData

func (*TransferResultChunkRequest_SinkResult) GetTableName 

func (m *TransferResultChunkRequest_SinkResult) GetTableName() string

func (*TransferResultChunkRequest_SinkResult) GoString 

func (this *TransferResultChunkRequest_SinkResult) GoString() string

func (*TransferResultChunkRequest_SinkResult) Marshal 

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

func (*TransferResultChunkRequest_SinkResult) MarshalTo 

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

func (*TransferResultChunkRequest_SinkResult) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_SinkResult) ProtoMessage 

func (*TransferResultChunkRequest_SinkResult) ProtoMessage()

func (*TransferResultChunkRequest_SinkResult) Reset 

func (m *TransferResultChunkRequest_SinkResult) Reset()

func (*TransferResultChunkRequest_SinkResult) Size 

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

func (*TransferResultChunkRequest_SinkResult) String 

func (this *TransferResultChunkRequest_SinkResult) String() string

func (*TransferResultChunkRequest_SinkResult) Unmarshal 

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

func (*TransferResultChunkRequest_SinkResult) XXX_DiscardUnknown 

func (m *TransferResultChunkRequest_SinkResult) XXX_DiscardUnknown()

func (*TransferResultChunkRequest_SinkResult) XXX_Marshal 

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

func (*TransferResultChunkRequest_SinkResult) XXX_Merge 

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

func (*TransferResultChunkRequest_SinkResult) XXX_OneofWrappers 

func (*TransferResultChunkRequest_SinkResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransferResultChunkRequest_SinkResult) XXX_Size 

func (m *TransferResultChunkRequest_SinkResult) XXX_Size() int

func (*TransferResultChunkRequest_SinkResult) XXX_Unmarshal 

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

type TransferResultChunkRequest_SinkResult_GRPCSourceID 

type TransferResultChunkRequest_SinkResult_GRPCSourceID struct {
	GRPCSourceID uint64 `protobuf:"varint,2,opt,name=grpc_source_id,json=grpcSourceId,proto3,oneof" json:"grpc_source_id,omitempty"`
}

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) Equal 

func (this *TransferResultChunkRequest_SinkResult_GRPCSourceID) Equal(that interface{}) bool

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) GoString 

func (this *TransferResultChunkRequest_SinkResult_GRPCSourceID) GoString() string

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) MarshalTo 

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

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) Size 

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

func (*TransferResultChunkRequest_SinkResult_GRPCSourceID) String 

func (this *TransferResultChunkRequest_SinkResult_GRPCSourceID) String() string

type TransferResultChunkRequest_SinkResult_RowBatch 

type TransferResultChunkRequest_SinkResult_RowBatch struct {
	RowBatch *schemapb.RowBatchData `protobuf:"bytes,1,opt,name=row_batch,json=rowBatch,proto3,oneof" json:"row_batch,omitempty"`
}

func (*TransferResultChunkRequest_SinkResult_RowBatch) Equal 

func (this *TransferResultChunkRequest_SinkResult_RowBatch) Equal(that interface{}) bool

func (*TransferResultChunkRequest_SinkResult_RowBatch) GoString 

func (this *TransferResultChunkRequest_SinkResult_RowBatch) GoString() string

func (*TransferResultChunkRequest_SinkResult_RowBatch) MarshalTo 

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

func (*TransferResultChunkRequest_SinkResult_RowBatch) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_SinkResult_RowBatch) Size 

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

func (*TransferResultChunkRequest_SinkResult_RowBatch) String 

func (this *TransferResultChunkRequest_SinkResult_RowBatch) String() string

type TransferResultChunkRequest_SinkResult_TableName 

type TransferResultChunkRequest_SinkResult_TableName struct {
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3,oneof" json:"table_name,omitempty"`
}

func (*TransferResultChunkRequest_SinkResult_TableName) Equal 

func (this *TransferResultChunkRequest_SinkResult_TableName) Equal(that interface{}) bool

func (*TransferResultChunkRequest_SinkResult_TableName) GoString 

func (this *TransferResultChunkRequest_SinkResult_TableName) GoString() string

func (*TransferResultChunkRequest_SinkResult_TableName) MarshalTo 

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

func (*TransferResultChunkRequest_SinkResult_TableName) MarshalToSizedBuffer 

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

func (*TransferResultChunkRequest_SinkResult_TableName) Size 

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

func (*TransferResultChunkRequest_SinkResult_TableName) String 

func (this *TransferResultChunkRequest_SinkResult_TableName) String() string

type TransferResultChunkResponse 

type TransferResultChunkResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*TransferResultChunkResponse) Descriptor 

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

func (*TransferResultChunkResponse) Equal 

func (this *TransferResultChunkResponse) Equal(that interface{}) bool

func (*TransferResultChunkResponse) GetMessage 

func (m *TransferResultChunkResponse) GetMessage() string

func (*TransferResultChunkResponse) GetSuccess 

func (m *TransferResultChunkResponse) GetSuccess() bool

func (*TransferResultChunkResponse) GoString 

func (this *TransferResultChunkResponse) GoString() string

func (*TransferResultChunkResponse) Marshal 

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

func (*TransferResultChunkResponse) MarshalTo 

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

func (*TransferResultChunkResponse) MarshalToSizedBuffer 

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

func (*TransferResultChunkResponse) ProtoMessage 

func (*TransferResultChunkResponse) ProtoMessage()

func (*TransferResultChunkResponse) Reset 

func (m *TransferResultChunkResponse) Reset()

func (*TransferResultChunkResponse) Size 

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

func (*TransferResultChunkResponse) String 

func (this *TransferResultChunkResponse) String() string

func (*TransferResultChunkResponse) Unmarshal 

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

func (*TransferResultChunkResponse) XXX_DiscardUnknown 

func (m *TransferResultChunkResponse) XXX_DiscardUnknown()

func (*TransferResultChunkResponse) XXX_Marshal 

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

func (*TransferResultChunkResponse) XXX_Merge 

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

func (*TransferResultChunkResponse) XXX_Size 

func (m *TransferResultChunkResponse) XXX_Size() int

func (*TransferResultChunkResponse) XXX_Unmarshal 

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

type UnimplementedResultSinkServiceServer 

type UnimplementedResultSinkServiceServer struct {
}

UnimplementedResultSinkServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedResultSinkServiceServer) TransferResultChunk 

func (*UnimplementedResultSinkServiceServer) TransferResultChunk(srv ResultSinkService_TransferResultChunkServer) error

Source Files

View all Source files

Directories

Path Synopsis
Package mock_carnotpb is a generated GoMock package.
 Package mock_carnotpb is a generated GoMock package.

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.