store

package

Go to main page

Versions in this module

v3

v3.9.0

Sep 13, 2022

v3.8.9

Sep 9, 2022

v3.8.8

Aug 31, 2022

v3.8.7

Jun 13, 2022

v3.8.6

Apr 1, 2022

v3.8.5

Feb 18, 2022

v3.8.4

Feb 10, 2022

Changes in this version

+ type BlobListOptions struct

+ Namespace string

+ Prefix string

+ func (*BlobListOptions) Descriptor() ([]byte, []int)

+ func (*BlobListOptions) ProtoMessage()

+ func (x *BlobListOptions) GetNamespace() string

+ func (x *BlobListOptions) GetPrefix() string

+ func (x *BlobListOptions) ProtoReflect() protoreflect.Message

+ func (x *BlobListOptions) Reset()

+ func (x *BlobListOptions) String() string

+ type BlobListRequest struct

+ Options *BlobListOptions

+ func (*BlobListRequest) Descriptor() ([]byte, []int)

+ func (*BlobListRequest) ProtoMessage()

+ func (x *BlobListRequest) GetOptions() *BlobListOptions

+ func (x *BlobListRequest) ProtoReflect() protoreflect.Message

+ func (x *BlobListRequest) Reset()

+ func (x *BlobListRequest) String() string

+ type BlobListResponse struct

+ Keys []string

+ func (*BlobListResponse) Descriptor() ([]byte, []int)

+ func (*BlobListResponse) ProtoMessage()

+ func (x *BlobListResponse) GetKeys() []string

+ func (x *BlobListResponse) ProtoReflect() protoreflect.Message

+ func (x *BlobListResponse) Reset()

+ func (x *BlobListResponse) String() string

type BlobStoreClient

+ List func(ctx context.Context, in *BlobListRequest, opts ...grpc.CallOption) (*BlobListResponse, error)

type BlobStoreHandler

+ List func(context.Context, *BlobListRequest, *BlobListResponse) error

type BlobStoreServer

+ List func(context.Context, *BlobListRequest) (*BlobListResponse, error)

type BlobStoreService

+ List func(ctx context.Context, in *BlobListRequest, opts ...client.CallOption) (*BlobListResponse, error)

type UnimplementedBlobStoreServer

+ func (*UnimplementedBlobStoreServer) List(context.Context, *BlobListRequest) (*BlobListResponse, error)

v3.8.3

Jan 13, 2022

Changes in this version

+ var File_proto_store_store_proto protoreflect.FileDescriptor

+ func RegisterBlobStoreServer(s *grpc.Server, srv BlobStoreServer)

+ func RegisterStoreServer(s *grpc.Server, srv StoreServer)

+ type BlobStoreClient interface

+ Delete func(ctx context.Context, in *BlobDeleteRequest, opts ...grpc.CallOption) (*BlobDeleteResponse, error)

+ Read func(ctx context.Context, in *BlobReadRequest, opts ...grpc.CallOption) (BlobStore_ReadClient, error)

+ Write func(ctx context.Context, opts ...grpc.CallOption) (BlobStore_WriteClient, error)

+ func NewBlobStoreClient(cc grpc.ClientConnInterface) BlobStoreClient

+ type BlobStoreServer interface

+ Delete func(context.Context, *BlobDeleteRequest) (*BlobDeleteResponse, error)

+ Read func(*BlobReadRequest, BlobStore_ReadServer) error

+ Write func(BlobStore_WriteServer) error

+ type BlobStore_ReadClient interface

+ Recv func() (*BlobReadResponse, error)

+ type BlobStore_ReadServer interface

+ Send func(*BlobReadResponse) error

+ type BlobStore_WriteClient interface

+ CloseAndRecv func() (*BlobWriteResponse, error)

+ Send func(*BlobWriteRequest) error

+ type BlobStore_WriteServer interface

+ Recv func() (*BlobWriteRequest, error)

+ SendAndClose func(*BlobWriteResponse) error

+ type StoreClient interface

+ Databases func(ctx context.Context, in *DatabasesRequest, opts ...grpc.CallOption) (*DatabasesResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Store_ListClient, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ Tables func(ctx context.Context, in *TablesRequest, opts ...grpc.CallOption) (*TablesResponse, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)

+ func NewStoreClient(cc grpc.ClientConnInterface) StoreClient

+ type StoreServer interface

+ Databases func(context.Context, *DatabasesRequest) (*DatabasesResponse, error)

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

+ List func(*ListRequest, Store_ListServer) error

+ Read func(context.Context, *ReadRequest) (*ReadResponse, error)

+ Tables func(context.Context, *TablesRequest) (*TablesResponse, error)

+ Write func(context.Context, *WriteRequest) (*WriteResponse, error)

+ type Store_ListClient interface

+ Recv func() (*ListResponse, error)

+ type Store_ListServer interface

+ Send func(*ListResponse) error

+ type UnimplementedBlobStoreServer struct

+ func (*UnimplementedBlobStoreServer) Delete(context.Context, *BlobDeleteRequest) (*BlobDeleteResponse, error)

+ func (*UnimplementedBlobStoreServer) Read(*BlobReadRequest, BlobStore_ReadServer) error

+ func (*UnimplementedBlobStoreServer) Write(BlobStore_WriteServer) error

+ type UnimplementedStoreServer struct

+ func (*UnimplementedStoreServer) Databases(context.Context, *DatabasesRequest) (*DatabasesResponse, error)

+ func (*UnimplementedStoreServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

+ func (*UnimplementedStoreServer) List(*ListRequest, Store_ListServer) error

+ func (*UnimplementedStoreServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

+ func (*UnimplementedStoreServer) Tables(context.Context, *TablesRequest) (*TablesResponse, error)

+ func (*UnimplementedStoreServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

v3.8.2

Dec 15, 2021

v3.8.1

Dec 15, 2021

Changes in this version

+ var File_store_proto protoreflect.FileDescriptor

+ func NewBlobStoreEndpoints() []*api.Endpoint

+ func NewStoreEndpoints() []*api.Endpoint

+ func RegisterBlobStoreHandler(s server.Server, hdlr BlobStoreHandler, opts ...server.HandlerOption) error

+ func RegisterStoreHandler(s server.Server, hdlr StoreHandler, opts ...server.HandlerOption) error

+ type BlobDeleteRequest struct

+ Key string

+ Options *BlobOptions

+ func (*BlobDeleteRequest) Descriptor() ([]byte, []int)

+ func (*BlobDeleteRequest) ProtoMessage()

+ func (x *BlobDeleteRequest) GetKey() string

+ func (x *BlobDeleteRequest) GetOptions() *BlobOptions

+ func (x *BlobDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *BlobDeleteRequest) Reset()

+ func (x *BlobDeleteRequest) String() string

+ type BlobDeleteResponse struct

+ func (*BlobDeleteResponse) Descriptor() ([]byte, []int)

+ func (*BlobDeleteResponse) ProtoMessage()

+ func (x *BlobDeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *BlobDeleteResponse) Reset()

+ func (x *BlobDeleteResponse) String() string

+ type BlobOptions struct

+ ContentType string

+ Namespace string

+ Public bool

+ func (*BlobOptions) Descriptor() ([]byte, []int)

+ func (*BlobOptions) ProtoMessage()

+ func (x *BlobOptions) GetContentType() string

+ func (x *BlobOptions) GetNamespace() string

+ func (x *BlobOptions) GetPublic() bool

+ func (x *BlobOptions) ProtoReflect() protoreflect.Message

+ func (x *BlobOptions) Reset()

+ func (x *BlobOptions) String() string

+ type BlobReadRequest struct

+ Key string

+ Options *BlobOptions

+ func (*BlobReadRequest) Descriptor() ([]byte, []int)

+ func (*BlobReadRequest) ProtoMessage()

+ func (x *BlobReadRequest) GetKey() string

+ func (x *BlobReadRequest) GetOptions() *BlobOptions

+ func (x *BlobReadRequest) ProtoReflect() protoreflect.Message

+ func (x *BlobReadRequest) Reset()

+ func (x *BlobReadRequest) String() string

+ type BlobReadResponse struct

+ Blob []byte

+ func (*BlobReadResponse) Descriptor() ([]byte, []int)

+ func (*BlobReadResponse) ProtoMessage()

+ func (x *BlobReadResponse) GetBlob() []byte

+ func (x *BlobReadResponse) ProtoReflect() protoreflect.Message

+ func (x *BlobReadResponse) Reset()

+ func (x *BlobReadResponse) String() string

+ type BlobStoreHandler interface

+ Delete func(context.Context, *BlobDeleteRequest, *BlobDeleteResponse) error

+ Read func(context.Context, *BlobReadRequest, BlobStore_ReadStream) error

+ Write func(context.Context, BlobStore_WriteStream) error

+ type BlobStoreService interface

+ Delete func(ctx context.Context, in *BlobDeleteRequest, opts ...client.CallOption) (*BlobDeleteResponse, error)

+ Read func(ctx context.Context, in *BlobReadRequest, opts ...client.CallOption) (BlobStore_ReadService, error)

+ Write func(ctx context.Context, opts ...client.CallOption) (BlobStore_WriteService, error)

+ func NewBlobStoreService(name string, c client.Client) BlobStoreService

+ type BlobStore_ReadService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*BlobReadResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type BlobStore_ReadStream interface

+ Close func() error

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*BlobReadResponse) error

+ SendMsg func(interface{}) error

+ type BlobStore_WriteService interface

+ CloseAndRecv func() (*BlobWriteResponse, error)

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*BlobWriteRequest) error

+ SendMsg func(interface{}) error

+ type BlobStore_WriteStream interface

+ Context func() context.Context

+ Recv func() (*BlobWriteRequest, error)

+ RecvMsg func(interface{}) error

+ SendAndClose func(*BlobWriteResponse) error

+ SendMsg func(interface{}) error

+ type BlobWriteRequest struct

+ Blob []byte

+ Key string

+ Options *BlobOptions

+ func (*BlobWriteRequest) Descriptor() ([]byte, []int)

+ func (*BlobWriteRequest) ProtoMessage()

+ func (x *BlobWriteRequest) GetBlob() []byte

+ func (x *BlobWriteRequest) GetKey() string

+ func (x *BlobWriteRequest) GetOptions() *BlobOptions

+ func (x *BlobWriteRequest) ProtoReflect() protoreflect.Message

+ func (x *BlobWriteRequest) Reset()

+ func (x *BlobWriteRequest) String() string

+ type BlobWriteResponse struct

+ func (*BlobWriteResponse) Descriptor() ([]byte, []int)

+ func (*BlobWriteResponse) ProtoMessage()

+ func (x *BlobWriteResponse) ProtoReflect() protoreflect.Message

+ func (x *BlobWriteResponse) Reset()

+ func (x *BlobWriteResponse) String() string

+ type DatabasesRequest struct

+ func (*DatabasesRequest) Descriptor() ([]byte, []int)

+ func (*DatabasesRequest) ProtoMessage()

+ func (x *DatabasesRequest) ProtoReflect() protoreflect.Message

+ func (x *DatabasesRequest) Reset()

+ func (x *DatabasesRequest) String() string

+ type DatabasesResponse struct

+ Databases []string

+ func (*DatabasesResponse) Descriptor() ([]byte, []int)

+ func (*DatabasesResponse) ProtoMessage()

+ func (x *DatabasesResponse) GetDatabases() []string

+ func (x *DatabasesResponse) ProtoReflect() protoreflect.Message

+ func (x *DatabasesResponse) Reset()

+ func (x *DatabasesResponse) String() string

+ type DeleteOptions struct

+ Database string

+ Table string

+ func (*DeleteOptions) Descriptor() ([]byte, []int)

+ func (*DeleteOptions) ProtoMessage()

+ func (x *DeleteOptions) GetDatabase() string

+ func (x *DeleteOptions) GetTable() string

+ func (x *DeleteOptions) ProtoReflect() protoreflect.Message

+ func (x *DeleteOptions) Reset()

+ func (x *DeleteOptions) String() string

+ type DeleteRequest struct

+ Key string

+ Options *DeleteOptions

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetKey() string

+ func (x *DeleteRequest) GetOptions() *DeleteOptions

+ func (x *DeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type DeleteResponse struct

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

+ func (*DeleteResponse) ProtoMessage()

+ func (x *DeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteResponse) Reset()

+ func (x *DeleteResponse) String() string

+ type Field struct

+ Type string

+ Value string

+ func (*Field) Descriptor() ([]byte, []int)

+ func (*Field) ProtoMessage()

+ func (x *Field) GetType() string

+ func (x *Field) GetValue() string

+ func (x *Field) ProtoReflect() protoreflect.Message

+ func (x *Field) Reset()

+ func (x *Field) String() string

+ type ListOptions struct

+ Database string

+ Limit uint64

+ Offset uint64

+ Order string

+ Prefix string

+ Suffix string

+ Table string

+ func (*ListOptions) Descriptor() ([]byte, []int)

+ func (*ListOptions) ProtoMessage()

+ func (x *ListOptions) GetDatabase() string

+ func (x *ListOptions) GetLimit() uint64

+ func (x *ListOptions) GetOffset() uint64

+ func (x *ListOptions) GetOrder() string

+ func (x *ListOptions) GetPrefix() string

+ func (x *ListOptions) GetSuffix() string

+ func (x *ListOptions) GetTable() string

+ func (x *ListOptions) ProtoReflect() protoreflect.Message

+ func (x *ListOptions) Reset()

+ func (x *ListOptions) String() string

+ type ListRequest struct

+ Options *ListOptions

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (x *ListRequest) GetOptions() *ListOptions

+ func (x *ListRequest) ProtoReflect() protoreflect.Message

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ type ListResponse struct

+ Keys []string

+ func (*ListResponse) Descriptor() ([]byte, []int)

+ func (*ListResponse) ProtoMessage()

+ func (x *ListResponse) GetKeys() []string

+ func (x *ListResponse) ProtoReflect() protoreflect.Message

+ func (x *ListResponse) Reset()

+ func (x *ListResponse) String() string

+ type ReadOptions struct

+ Database string

+ Limit uint64

+ Offset uint64

+ Order string

+ Prefix bool

+ Suffix bool

+ Table string

+ func (*ReadOptions) Descriptor() ([]byte, []int)

+ func (*ReadOptions) ProtoMessage()

+ func (x *ReadOptions) GetDatabase() string

+ func (x *ReadOptions) GetLimit() uint64

+ func (x *ReadOptions) GetOffset() uint64

+ func (x *ReadOptions) GetOrder() string

+ func (x *ReadOptions) GetPrefix() bool

+ func (x *ReadOptions) GetSuffix() bool

+ func (x *ReadOptions) GetTable() string

+ func (x *ReadOptions) ProtoReflect() protoreflect.Message

+ func (x *ReadOptions) Reset()

+ func (x *ReadOptions) String() string

+ type ReadRequest struct

+ Key string

+ Options *ReadOptions

+ func (*ReadRequest) Descriptor() ([]byte, []int)

+ func (*ReadRequest) ProtoMessage()

+ func (x *ReadRequest) GetKey() string

+ func (x *ReadRequest) GetOptions() *ReadOptions

+ func (x *ReadRequest) ProtoReflect() protoreflect.Message

+ func (x *ReadRequest) Reset()

+ func (x *ReadRequest) String() string

+ type ReadResponse struct

+ Records []*Record

+ func (*ReadResponse) Descriptor() ([]byte, []int)

+ func (*ReadResponse) ProtoMessage()

+ func (x *ReadResponse) GetRecords() []*Record

+ func (x *ReadResponse) ProtoReflect() protoreflect.Message

+ func (x *ReadResponse) Reset()

+ func (x *ReadResponse) String() string

+ type Record struct

+ Expiry int64

+ Key string

+ Metadata map[string]*Field

+ Value []byte

+ func (*Record) Descriptor() ([]byte, []int)

+ func (*Record) ProtoMessage()

+ func (x *Record) GetExpiry() int64

+ func (x *Record) GetKey() string

+ func (x *Record) GetMetadata() map[string]*Field

+ func (x *Record) GetValue() []byte

+ func (x *Record) ProtoReflect() protoreflect.Message

+ func (x *Record) Reset()

+ func (x *Record) String() string

+ type StoreHandler interface

+ Databases func(context.Context, *DatabasesRequest, *DatabasesResponse) error

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

+ List func(context.Context, *ListRequest, Store_ListStream) error

+ Read func(context.Context, *ReadRequest, *ReadResponse) error

+ Tables func(context.Context, *TablesRequest, *TablesResponse) error

+ Write func(context.Context, *WriteRequest, *WriteResponse) error

+ type StoreService interface

+ Databases func(ctx context.Context, in *DatabasesRequest, opts ...client.CallOption) (*DatabasesResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...client.CallOption) (Store_ListService, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)

+ Tables func(ctx context.Context, in *TablesRequest, opts ...client.CallOption) (*TablesResponse, error)

+ Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)

+ func NewStoreService(name string, c client.Client) StoreService

+ type Store_ListService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*ListResponse, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Store_ListStream interface

+ Close func() error

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*ListResponse) error

+ SendMsg func(interface{}) error

+ type TablesRequest struct

+ Database string

+ func (*TablesRequest) Descriptor() ([]byte, []int)

+ func (*TablesRequest) ProtoMessage()

+ func (x *TablesRequest) GetDatabase() string

+ func (x *TablesRequest) ProtoReflect() protoreflect.Message

+ func (x *TablesRequest) Reset()

+ func (x *TablesRequest) String() string

+ type TablesResponse struct

+ Tables []string

+ func (*TablesResponse) Descriptor() ([]byte, []int)

+ func (*TablesResponse) ProtoMessage()

+ func (x *TablesResponse) GetTables() []string

+ func (x *TablesResponse) ProtoReflect() protoreflect.Message

+ func (x *TablesResponse) Reset()

+ func (x *TablesResponse) String() string

+ type WriteOptions struct

+ Database string

+ Table string

+ func (*WriteOptions) Descriptor() ([]byte, []int)

+ func (*WriteOptions) ProtoMessage()

+ func (x *WriteOptions) GetDatabase() string

+ func (x *WriteOptions) GetTable() string

+ func (x *WriteOptions) ProtoReflect() protoreflect.Message

+ func (x *WriteOptions) Reset()

+ func (x *WriteOptions) String() string

+ type WriteRequest struct

+ Options *WriteOptions

+ Record *Record

+ func (*WriteRequest) Descriptor() ([]byte, []int)

+ func (*WriteRequest) ProtoMessage()

+ func (x *WriteRequest) GetOptions() *WriteOptions

+ func (x *WriteRequest) GetRecord() *Record

+ func (x *WriteRequest) ProtoReflect() protoreflect.Message

+ func (x *WriteRequest) Reset()

+ func (x *WriteRequest) String() string

+ type WriteResponse struct

+ func (*WriteResponse) Descriptor() ([]byte, []int)

+ func (*WriteResponse) ProtoMessage()

+ func (x *WriteResponse) ProtoReflect() protoreflect.Message

+ func (x *WriteResponse) Reset()

+ func (x *WriteResponse) String() string

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