Documentation ¶
Index ¶
- func DeGobber(in []byte, target interface{}) error
- func Gobber(i interface{}) []byte
- func SortKeys(in []*Key)
- type Key
- type RPC
- func (r *RPC) Delete(ctx context.Context, in *pb.Key) (*pb.Empty, error)
- func (r *RPC) Get(ctx context.Context, in *pb.Key) (*pb.Object, error)
- func (r *RPC) GetNewKey(ctx context.Context, in *pb.Bucket) (*pb.Key, error)
- func (r *RPC) ListBuckets(in *pb.Empty, stream pb.SStoreRPC_ListBucketsServer) error
- func (r *RPC) ListKeys(in *pb.Bucket, stream pb.SStoreRPC_ListKeysServer) error
- func (r *RPC) Put(ctx context.Context, in *pb.Object) (*pb.Key, error)
- func (r *RPC) Search(in *pb.Key, stream pb.SStoreRPC_SearchServer) error
- func (r *RPC) Version(ctx context.Context, in *pb.Key) (*pb.Key, error)
- type SStoreClient
- func (ss *SStoreClient) Close()
- func (ss *SStoreClient) Connect(addr string, opts ...grpc.DialOption)
- func (ss *SStoreClient) Delete(key *Key) error
- func (ss *SStoreClient) Get(key *Key, obj Storable) error
- func (ss *SStoreClient) ListBuckets() ([]string, error)
- func (ss *SStoreClient) ListKeys(bucket string) ([]*Key, error)
- func (ss *SStoreClient) NewKey(bucket string) (*Key, error)
- func (ss *SStoreClient) Put(key *Key, obj Storable) (*Key, error)
- func (ss *SStoreClient) Search(bucket, prefix string) ([]*Key, error)
- func (ss *SStoreClient) Version(key *Key) (uint64, error)
- type SStoreServer
- type Storable
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RPC ¶
type RPC struct { pb.UnimplementedSStoreRPCServer // contains filtered or unexported fields }
func (*RPC) ListBuckets ¶
type SStoreClient ¶
type SStoreClient struct { Address string Options []grpc.DialOption Conn *grpc.ClientConn Client pb.SStoreRPCClient }
func (*SStoreClient) Close ¶
func (ss *SStoreClient) Close()
func (*SStoreClient) Connect ¶
func (ss *SStoreClient) Connect(addr string, opts ...grpc.DialOption)
func (*SStoreClient) Delete ¶
func (ss *SStoreClient) Delete(key *Key) error
func (*SStoreClient) ListBuckets ¶
func (ss *SStoreClient) ListBuckets() ([]string, error)
type SStoreServer ¶
type SStoreServer struct { Address string Opts []grpc.ServerOption GServer *grpc.Server // contains filtered or unexported fields }
func NewSStoreServer ¶
func NewSStoreServer(dpath, dname string, opts ...grpc.ServerOption) *SStoreServer
func (*SStoreServer) Serve ¶
func (ss *SStoreServer) Serve(address string)
Click to show internal directories.
Click to hide internal directories.