metadbpb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2019 License: GPL-3.0 Imports: 6 Imported by: 3

Documentation

Overview

Package metadbpb is a generated protocol buffer package.

It is generated from these files: 

db_service.proto

It has these top-level messages: 

Status
Pair
Data
PutRequest
PutResponse
GetRequest
GetResponse
GetMultiRequest
GetMultiResponse
DeleteRequest
DeleteResponse
SearchRequest
SearchResponse

Index

Constants

This section is empty.

Variables

View Source 
var DBStatusCode_name = map[int32]string{
	0: "OK",
	1: "OTHER_ERROR",
}
View Source 
var DBStatusCode_value = map[string]int32{
	"OK":          0,
	"OTHER_ERROR": 1,
}

Functions

func RegisterMetaDBServiceHandlers 

func RegisterMetaDBServiceHandlers(s *tcprpc.Server, prefix string, srv MetaDBServiceInterface)

Types

type DBStatusCode 

type DBStatusCode int32
const (
	DBStatusCode_OK          DBStatusCode = 0
	DBStatusCode_OTHER_ERROR DBStatusCode = 1
)

func (DBStatusCode) EnumDescriptor 

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

func (DBStatusCode) String 

func (x DBStatusCode) String() string

type Data 

type Data struct {
	Key    []byte  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Fields []*Pair `protobuf:"bytes,2,rep,name=fields" json:"fields,omitempty"`
	Index  []*Pair `protobuf:"bytes,3,rep,name=index" json:"index,omitempty"`
}

func (*Data) Descriptor 

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

func (*Data) GetFields 

func (m *Data) GetFields() []*Pair

func (*Data) GetIndex 

func (m *Data) GetIndex() []*Pair

func (*Data) GetKey 

func (m *Data) GetKey() []byte

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

type DeleteRequest 

type DeleteRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Key    []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() []byte

func (*DeleteRequest) GetPrefix 

func (m *DeleteRequest) GetPrefix() []byte

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetStatus 

func (m *DeleteResponse) GetStatus() *Status

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

type GetMultiRequest 

type GetMultiRequest struct {
	Prefix []byte   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Keys   [][]byte `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
}

func (*GetMultiRequest) Descriptor 

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

func (*GetMultiRequest) GetKeys 

func (m *GetMultiRequest) GetKeys() [][]byte

func (*GetMultiRequest) GetPrefix 

func (m *GetMultiRequest) GetPrefix() []byte

func (*GetMultiRequest) ProtoMessage 

func (*GetMultiRequest) ProtoMessage()

func (*GetMultiRequest) Reset 

func (m *GetMultiRequest) Reset()

func (*GetMultiRequest) String 

func (m *GetMultiRequest) String() string

type GetMultiResponse 

type GetMultiResponse struct {
	Status  *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Results []*Data `protobuf:"bytes,2,rep,name=results" json:"results,omitempty"`
}

func (*GetMultiResponse) Descriptor 

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

func (*GetMultiResponse) GetResults 

func (m *GetMultiResponse) GetResults() []*Data

func (*GetMultiResponse) GetStatus 

func (m *GetMultiResponse) GetStatus() *Status

func (*GetMultiResponse) ProtoMessage 

func (*GetMultiResponse) ProtoMessage()

func (*GetMultiResponse) Reset 

func (m *GetMultiResponse) Reset()

func (*GetMultiResponse) String 

func (m *GetMultiResponse) String() string

type GetRequest 

type GetRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Key    []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() []byte

func (*GetRequest) GetPrefix 

func (m *GetRequest) GetPrefix() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Data   *Data   `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetData 

func (m *GetResponse) GetData() *Data

func (*GetResponse) GetStatus 

func (m *GetResponse) GetStatus() *Status

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

type MetaDBServiceInterface 

type MetaDBServiceInterface interface {
	Put(context.Context, *PutRequest) (*PutResponse, error)

	Get(context.Context, *GetRequest) (*GetResponse, error)

	GetMulti(context.Context, *GetMultiRequest) (*GetMultiResponse, error)

	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

	Search(context.Context, *SearchRequest) (*SearchResponse, error)
}

type Pair 

type Pair struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Pair) Descriptor 

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

func (*Pair) GetKey 

func (m *Pair) GetKey() []byte

func (*Pair) GetValue 

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

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) String 

func (m *Pair) String() string

type PutRequest 

type PutRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Data   *Data  `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetData 

func (m *PutRequest) GetData() *Data

func (*PutRequest) GetPrefix 

func (m *PutRequest) GetPrefix() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) String 

func (m *PutRequest) String() string

type PutResponse 

type PutResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetStatus 

func (m *PutResponse) GetStatus() *Status

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) String 

func (m *PutResponse) String() string

type SearchRequest 

type SearchRequest struct {
	Prefix  []byte  `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Filters []*Pair `protobuf:"bytes,2,rep,name=filters" json:"filters,omitempty"`
	Token   []byte  `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Limit   int32   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetFilters 

func (m *SearchRequest) GetFilters() []*Pair

func (*SearchRequest) GetLimit 

func (m *SearchRequest) GetLimit() int32

func (*SearchRequest) GetPrefix 

func (m *SearchRequest) GetPrefix() []byte

func (*SearchRequest) GetToken 

func (m *SearchRequest) GetToken() []byte

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

type SearchResponse 

type SearchResponse struct {
	Status    *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Items     []*Data `protobuf:"bytes,2,rep,name=items" json:"items,omitempty"`
	NextToken []byte  `protobuf:"bytes,3,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
}

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetItems 

func (m *SearchResponse) GetItems() []*Data

func (*SearchResponse) GetNextToken 

func (m *SearchResponse) GetNextToken() []byte

func (*SearchResponse) GetStatus 

func (m *SearchResponse) GetStatus() *Status

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

type Status 

type Status struct {
	// A simple error code that can be easily handled by the client.
	Code DBStatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=metadbpb.DBStatusCode" json:"code,omitempty"`
	// A developer-facing human-readable error message in English. It should
	// both explain the error and offer an actionable resolution to it.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Additional error information that the client code can use to handle
	// the error, such as retry delay or a help link.
	Details []*google_protobuf.Any `protobuf:"bytes,3,rep,name=details" json:"details,omitempty"`
}

func (*Status) Descriptor 

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

func (*Status) GetCode 

func (m *Status) GetCode() DBStatusCode

func (*Status) GetDetails 

func (m *Status) GetDetails() []*google_protobuf.Any

func (*Status) GetMessage 

func (m *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

type TCPRPCMetaDBServiceClient 

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

func NewTCPRPCMetaDBServiceClient 

func NewTCPRPCMetaDBServiceClient(cl *tcprpc.Client, pref string) TCPRPCMetaDBServiceClient

func (TCPRPCMetaDBServiceClient) Delete 

func (cl TCPRPCMetaDBServiceClient) Delete(ctx context.Context, args *DeleteRequest) (*DeleteResponse, error)

func (TCPRPCMetaDBServiceClient) Get 

func (cl TCPRPCMetaDBServiceClient) Get(ctx context.Context, args *GetRequest) (*GetResponse, error)

func (TCPRPCMetaDBServiceClient) GetMulti 

func (cl TCPRPCMetaDBServiceClient) GetMulti(ctx context.Context, args *GetMultiRequest) (*GetMultiResponse, error)

func (TCPRPCMetaDBServiceClient) Put 

func (cl TCPRPCMetaDBServiceClient) Put(ctx context.Context, args *PutRequest) (*PutResponse, error)

func (TCPRPCMetaDBServiceClient) Search 

func (cl TCPRPCMetaDBServiceClient) Search(ctx context.Context, args *SearchRequest) (*SearchResponse, 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.