Versions in this module Expand all Collapse all v0 v0.1.0 Sep 15, 2018 Changes in this version + var SyncAction_name = map[int32]string + var SyncAction_value = map[string]int32 + func RegisterDatastoreServer(s *grpc.Server, srv DatastoreServer) + type AcquireLockRequest struct + Timeout *types.Duration + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AcquireLockRequest) Descriptor() ([]byte, []int) + func (*AcquireLockRequest) ProtoMessage() + func (dst *AcquireLockRequest) XXX_Merge(src proto.Message) + func (m *AcquireLockRequest) GetTimeout() *types.Duration + func (m *AcquireLockRequest) Reset() + func (m *AcquireLockRequest) String() string + func (m *AcquireLockRequest) XXX_DiscardUnknown() + func (m *AcquireLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AcquireLockRequest) XXX_Size() int + func (m *AcquireLockRequest) XXX_Unmarshal(b []byte) error + type BackupRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BackupRequest) Descriptor() ([]byte, []int) + func (*BackupRequest) ProtoMessage() + func (dst *BackupRequest) XXX_Merge(src proto.Message) + func (m *BackupRequest) Reset() + func (m *BackupRequest) String() string + func (m *BackupRequest) XXX_DiscardUnknown() + func (m *BackupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BackupRequest) XXX_Size() int + func (m *BackupRequest) XXX_Unmarshal(b []byte) error + type BackupResponse struct + Data []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BackupResponse) Descriptor() ([]byte, []int) + func (*BackupResponse) ProtoMessage() + func (dst *BackupResponse) XXX_Merge(src proto.Message) + func (m *BackupResponse) GetData() []byte + func (m *BackupResponse) Reset() + func (m *BackupResponse) String() string + func (m *BackupResponse) XXX_DiscardUnknown() + func (m *BackupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BackupResponse) XXX_Size() int + func (m *BackupResponse) XXX_Unmarshal(b []byte) error + type CreateBucketRequest struct + Bucket string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateBucketRequest) Descriptor() ([]byte, []int) + func (*CreateBucketRequest) ProtoMessage() + func (dst *CreateBucketRequest) XXX_Merge(src proto.Message) + func (m *CreateBucketRequest) GetBucket() string + func (m *CreateBucketRequest) Reset() + func (m *CreateBucketRequest) String() string + func (m *CreateBucketRequest) XXX_DiscardUnknown() + func (m *CreateBucketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateBucketRequest) XXX_Size() int + func (m *CreateBucketRequest) XXX_Unmarshal(b []byte) error + type DatastoreClient interface + AcquireLock func(ctx context.Context, in *AcquireLockRequest, opts ...grpc.CallOption) (*types.Empty, error) + Backup func(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupResponse, error) + CreateBucket func(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*types.Empty, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*types.Empty, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + PeerSync func(ctx context.Context, in *PeerSyncRequest, opts ...grpc.CallOption) (*types.Empty, error) + ReleaseLock func(ctx context.Context, in *ReleaseLockRequest, opts ...grpc.CallOption) (*types.Empty, error) + Restore func(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*types.Empty, error) + Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) + Set func(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*types.Empty, error) + Shutdown func(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*types.Empty, error) + Sync func(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Datastore_SyncClient, error) + func NewDatastoreClient(cc *grpc.ClientConn) DatastoreClient + type DatastoreServer interface + AcquireLock func(context.Context, *AcquireLockRequest) (*types.Empty, error) + Backup func(context.Context, *BackupRequest) (*BackupResponse, error) + CreateBucket func(context.Context, *CreateBucketRequest) (*types.Empty, error) + Delete func(context.Context, *DeleteRequest) (*types.Empty, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + PeerSync func(context.Context, *PeerSyncRequest) (*types.Empty, error) + ReleaseLock func(context.Context, *ReleaseLockRequest) (*types.Empty, error) + Restore func(context.Context, *RestoreRequest) (*types.Empty, error) + Search func(context.Context, *SearchRequest) (*SearchResponse, error) + Set func(context.Context, *SetRequest) (*types.Empty, error) + Shutdown func(context.Context, *ShutdownRequest) (*types.Empty, error) + Sync func(*SyncRequest, Datastore_SyncServer) error + type Datastore_SyncClient interface + Recv func() (*SyncOperation, error) + type Datastore_SyncServer interface + Send func(*SyncOperation) error + type DeleteRequest struct + Bucket string + Key string + NoTombstone bool + Sync bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (dst *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) GetBucket() string + func (m *DeleteRequest) GetKey() string + func (m *DeleteRequest) GetNoTombstone() bool + func (m *DeleteRequest) GetSync() bool + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) String() string + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type GetRequest struct + Bucket string + Key string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (dst *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) GetBucket() string + func (m *GetRequest) GetKey() string + func (m *GetRequest) Reset() + func (m *GetRequest) String() string + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Bucket string + Data *KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (dst *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) GetBucket() string + func (m *GetResponse) GetData() *KeyValue + func (m *GetResponse) Reset() + func (m *GetResponse) String() string + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type KeyValue struct + Key string + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyValue) Descriptor() ([]byte, []int) + func (*KeyValue) ProtoMessage() + func (dst *KeyValue) XXX_Merge(src proto.Message) + func (m *KeyValue) GetKey() string + func (m *KeyValue) GetValue() []byte + func (m *KeyValue) Reset() + func (m *KeyValue) String() string + func (m *KeyValue) XXX_DiscardUnknown() + func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KeyValue) XXX_Size() int + func (m *KeyValue) XXX_Unmarshal(b []byte) error + type PeerSyncRequest struct + Addr string + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerSyncRequest) Descriptor() ([]byte, []int) + func (*PeerSyncRequest) ProtoMessage() + func (dst *PeerSyncRequest) XXX_Merge(src proto.Message) + func (m *PeerSyncRequest) GetAddr() string + func (m *PeerSyncRequest) GetName() string + func (m *PeerSyncRequest) Reset() + func (m *PeerSyncRequest) String() string + func (m *PeerSyncRequest) XXX_DiscardUnknown() + func (m *PeerSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerSyncRequest) XXX_Size() int + func (m *PeerSyncRequest) XXX_Unmarshal(b []byte) error + type ReleaseLockRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReleaseLockRequest) Descriptor() ([]byte, []int) + func (*ReleaseLockRequest) ProtoMessage() + func (dst *ReleaseLockRequest) XXX_Merge(src proto.Message) + func (m *ReleaseLockRequest) Reset() + func (m *ReleaseLockRequest) String() string + func (m *ReleaseLockRequest) XXX_DiscardUnknown() + func (m *ReleaseLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReleaseLockRequest) XXX_Size() int + func (m *ReleaseLockRequest) XXX_Unmarshal(b []byte) error + type RestoreRequest struct + Data []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RestoreRequest) Descriptor() ([]byte, []int) + func (*RestoreRequest) ProtoMessage() + func (dst *RestoreRequest) XXX_Merge(src proto.Message) + func (m *RestoreRequest) GetData() []byte + func (m *RestoreRequest) Reset() + func (m *RestoreRequest) String() string + func (m *RestoreRequest) XXX_DiscardUnknown() + func (m *RestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RestoreRequest) XXX_Size() int + func (m *RestoreRequest) XXX_Unmarshal(b []byte) error + type SearchRequest struct + Bucket string + Prefix string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SearchRequest) Descriptor() ([]byte, []int) + func (*SearchRequest) ProtoMessage() + func (dst *SearchRequest) XXX_Merge(src proto.Message) + func (m *SearchRequest) GetBucket() string + func (m *SearchRequest) GetPrefix() string + func (m *SearchRequest) Reset() + func (m *SearchRequest) String() string + func (m *SearchRequest) XXX_DiscardUnknown() + func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SearchRequest) XXX_Size() int + func (m *SearchRequest) XXX_Unmarshal(b []byte) error + type SearchResponse struct + Bucket string + Data []*KeyValue + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SearchResponse) Descriptor() ([]byte, []int) + func (*SearchResponse) ProtoMessage() + func (dst *SearchResponse) XXX_Merge(src proto.Message) + func (m *SearchResponse) GetBucket() string + func (m *SearchResponse) GetData() []*KeyValue + func (m *SearchResponse) Reset() + func (m *SearchResponse) String() string + func (m *SearchResponse) XXX_DiscardUnknown() + func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SearchResponse) XXX_Size() int + func (m *SearchResponse) XXX_Unmarshal(b []byte) error + type SetRequest struct + Bucket string + Key string + Sync bool + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetRequest) Descriptor() ([]byte, []int) + func (*SetRequest) ProtoMessage() + func (dst *SetRequest) XXX_Merge(src proto.Message) + func (m *SetRequest) GetBucket() string + func (m *SetRequest) GetKey() string + func (m *SetRequest) GetSync() bool + func (m *SetRequest) GetValue() []byte + func (m *SetRequest) Reset() + func (m *SetRequest) String() string + func (m *SetRequest) XXX_DiscardUnknown() + func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetRequest) XXX_Size() int + func (m *SetRequest) XXX_Unmarshal(b []byte) error + type ShutdownRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShutdownRequest) Descriptor() ([]byte, []int) + func (*ShutdownRequest) ProtoMessage() + func (dst *ShutdownRequest) XXX_Merge(src proto.Message) + func (m *ShutdownRequest) Reset() + func (m *ShutdownRequest) String() string + func (m *ShutdownRequest) XXX_DiscardUnknown() + func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShutdownRequest) XXX_Size() int + func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error + type SyncAction int32 + const SyncAction_DELETE + const SyncAction_SET + func (SyncAction) EnumDescriptor() ([]byte, []int) + func (x SyncAction) String() string + type SyncOperation struct + Action SyncAction + Bucket string + Key string + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncOperation) Descriptor() ([]byte, []int) + func (*SyncOperation) ProtoMessage() + func (dst *SyncOperation) XXX_Merge(src proto.Message) + func (m *SyncOperation) GetAction() SyncAction + func (m *SyncOperation) GetBucket() string + func (m *SyncOperation) GetKey() string + func (m *SyncOperation) GetValue() []byte + func (m *SyncOperation) Reset() + func (m *SyncOperation) String() string + func (m *SyncOperation) XXX_DiscardUnknown() + func (m *SyncOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SyncOperation) XXX_Size() int + func (m *SyncOperation) XXX_Unmarshal(b []byte) error + type SyncRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncRequest) Descriptor() ([]byte, []int) + func (*SyncRequest) ProtoMessage() + func (dst *SyncRequest) XXX_Merge(src proto.Message) + func (m *SyncRequest) Reset() + func (m *SyncRequest) String() string + func (m *SyncRequest) XXX_DiscardUnknown() + func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SyncRequest) XXX_Size() int + func (m *SyncRequest) XXX_Unmarshal(b []byte) error