Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

go_micro_store

package

Go to main page

Versions in this module

v2

v2.9.5

May 2, 2021

v2.9.4

Feb 18, 2021

v2.9.3

Dec 25, 2020

Changes in this version

+ var File_store_service_proto_store_proto protoreflect.FileDescriptor

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

+ 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 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)

v2.9.2

Nov 14, 2020

Changes in this version

+ var File_github_com_micro_go_micro_store_service_proto_store_proto protoreflect.FileDescriptor

+ func NewStoreEndpoints() []*api.Endpoint

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

+ 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

+ 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) 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

+ 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) 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

+ Expiry int64

+ Table string

+ Ttl int64

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

+ func (*WriteOptions) ProtoMessage()

+ func (x *WriteOptions) GetDatabase() string

+ func (x *WriteOptions) GetExpiry() int64

+ func (x *WriteOptions) GetTable() string

+ func (x *WriteOptions) GetTtl() int64

+ 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