indexgatewaypb

package
v2.1.1-0...-c609277 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2021 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGateway = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGateway   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterIndexGatewayServer 

func RegisterIndexGatewayServer(s *grpc.Server, srv IndexGatewayServer)

Types

type IndexGatewayClient 

type IndexGatewayClient interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(ctx context.Context, in *QueryIndexRequest, opts ...grpc.CallOption) (IndexGateway_QueryIndexClient, error)
}

IndexGatewayClient is the client API for IndexGateway service.

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

func NewIndexGatewayClient 

func NewIndexGatewayClient(cc *grpc.ClientConn) IndexGatewayClient

type IndexGatewayServer 

type IndexGatewayServer interface {
	/// QueryIndex reads the indexes required for given query & sends back the batch of rows
	/// in rpc streams
	QueryIndex(*QueryIndexRequest, IndexGateway_QueryIndexServer) error
}

IndexGatewayServer is the server API for IndexGateway service.

type IndexGateway_QueryIndexClient 

type IndexGateway_QueryIndexClient interface {
	Recv() (*QueryIndexResponse, error)
	grpc.ClientStream
}

type IndexGateway_QueryIndexServer 

type IndexGateway_QueryIndexServer interface {
	Send(*QueryIndexResponse) error
	grpc.ServerStream
}

type IndexQuery 

type IndexQuery struct {
	TableName        string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	HashValue        string `protobuf:"bytes,2,opt,name=hashValue,proto3" json:"hashValue,omitempty"`
	RangeValuePrefix []byte `protobuf:"bytes,3,opt,name=rangeValuePrefix,proto3" json:"rangeValuePrefix,omitempty"`
	RangeValueStart  []byte `protobuf:"bytes,4,opt,name=rangeValueStart,proto3" json:"rangeValueStart,omitempty"`
	ValueEqual       []byte `protobuf:"bytes,5,opt,name=valueEqual,proto3" json:"valueEqual,omitempty"`
}

func (*IndexQuery) Descriptor 

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

func (*IndexQuery) Equal 

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

func (*IndexQuery) GetHashValue 

func (m *IndexQuery) GetHashValue() string

func (*IndexQuery) GetRangeValuePrefix 

func (m *IndexQuery) GetRangeValuePrefix() []byte

func (*IndexQuery) GetRangeValueStart 

func (m *IndexQuery) GetRangeValueStart() []byte

func (*IndexQuery) GetTableName 

func (m *IndexQuery) GetTableName() string

func (*IndexQuery) GetValueEqual 

func (m *IndexQuery) GetValueEqual() []byte

func (*IndexQuery) GoString 

func (this *IndexQuery) GoString() string

func (*IndexQuery) Marshal 

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

func (*IndexQuery) MarshalTo 

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

func (*IndexQuery) MarshalToSizedBuffer 

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

func (*IndexQuery) ProtoMessage 

func (*IndexQuery) ProtoMessage()

func (*IndexQuery) Reset 

func (m *IndexQuery) Reset()

func (*IndexQuery) Size 

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

func (*IndexQuery) String 

func (this *IndexQuery) String() string

func (*IndexQuery) Unmarshal 

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

func (*IndexQuery) XXX_DiscardUnknown 

func (m *IndexQuery) XXX_DiscardUnknown()

func (*IndexQuery) XXX_Marshal 

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

func (*IndexQuery) XXX_Merge 

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

func (*IndexQuery) XXX_Size 

func (m *IndexQuery) XXX_Size() int

func (*IndexQuery) XXX_Unmarshal 

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

type QueryIndexRequest 

type QueryIndexRequest struct {
	Queries []*IndexQuery `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
}

func (*QueryIndexRequest) Descriptor 

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

func (*QueryIndexRequest) Equal 

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

func (*QueryIndexRequest) GetQueries 

func (m *QueryIndexRequest) GetQueries() []*IndexQuery

func (*QueryIndexRequest) GoString 

func (this *QueryIndexRequest) GoString() string

func (*QueryIndexRequest) Marshal 

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

func (*QueryIndexRequest) MarshalTo 

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

func (*QueryIndexRequest) MarshalToSizedBuffer 

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

func (*QueryIndexRequest) ProtoMessage 

func (*QueryIndexRequest) ProtoMessage()

func (*QueryIndexRequest) Reset 

func (m *QueryIndexRequest) Reset()

func (*QueryIndexRequest) Size 

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

func (*QueryIndexRequest) String 

func (this *QueryIndexRequest) String() string

func (*QueryIndexRequest) Unmarshal 

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

func (*QueryIndexRequest) XXX_DiscardUnknown 

func (m *QueryIndexRequest) XXX_DiscardUnknown()

func (*QueryIndexRequest) XXX_Marshal 

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

func (*QueryIndexRequest) XXX_Merge 

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

func (*QueryIndexRequest) XXX_Size 

func (m *QueryIndexRequest) XXX_Size() int

func (*QueryIndexRequest) XXX_Unmarshal 

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

type QueryIndexResponse 

type QueryIndexResponse struct {
	QueryKey string `protobuf:"bytes,1,opt,name=QueryKey,proto3" json:"QueryKey,omitempty"`
	Rows     []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
}

func (*QueryIndexResponse) Descriptor 

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

func (*QueryIndexResponse) Equal 

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

func (*QueryIndexResponse) GetQueryKey 

func (m *QueryIndexResponse) GetQueryKey() string

func (*QueryIndexResponse) GetRows 

func (m *QueryIndexResponse) GetRows() []*Row

func (*QueryIndexResponse) GoString 

func (this *QueryIndexResponse) GoString() string

func (*QueryIndexResponse) Marshal 

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

func (*QueryIndexResponse) MarshalTo 

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

func (*QueryIndexResponse) MarshalToSizedBuffer 

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

func (*QueryIndexResponse) ProtoMessage 

func (*QueryIndexResponse) ProtoMessage()

func (*QueryIndexResponse) Reset 

func (m *QueryIndexResponse) Reset()

func (*QueryIndexResponse) Size 

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

func (*QueryIndexResponse) String 

func (this *QueryIndexResponse) String() string

func (*QueryIndexResponse) Unmarshal 

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

func (*QueryIndexResponse) XXX_DiscardUnknown 

func (m *QueryIndexResponse) XXX_DiscardUnknown()

func (*QueryIndexResponse) XXX_Marshal 

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

func (*QueryIndexResponse) XXX_Merge 

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

func (*QueryIndexResponse) XXX_Size 

func (m *QueryIndexResponse) XXX_Size() int

func (*QueryIndexResponse) XXX_Unmarshal 

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

type Row 

type Row struct {
	RangeValue []byte `protobuf:"bytes,1,opt,name=rangeValue,proto3" json:"rangeValue,omitempty"`
	Value      []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Row) Descriptor 

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

func (*Row) Equal 

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

func (*Row) GetRangeValue 

func (m *Row) GetRangeValue() []byte

func (*Row) GetValue 

func (m *Row) GetValue() []byte

func (*Row) GoString 

func (this *Row) GoString() string

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) MarshalToSizedBuffer 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (this *Row) String() string

func (*Row) Unmarshal 

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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

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

func (*Row) XXX_Merge 

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

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

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

type UnimplementedIndexGatewayServer 

type UnimplementedIndexGatewayServer struct {
}

UnimplementedIndexGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedIndexGatewayServer) QueryIndex 

func (*UnimplementedIndexGatewayServer) QueryIndex(req *QueryIndexRequest, srv IndexGateway_QueryIndexServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.