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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL