datastore

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2018 License: MIT Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SyncAction_name = map[int32]string{
	0: "SET",
	1: "DELETE",
}
View Source 
var SyncAction_value = map[string]int32{
	"SET":    0,
	"DELETE": 1,
}

Functions

func RegisterDatastoreServer 

func RegisterDatastoreServer(s *grpc.Server, srv DatastoreServer)

Types

type AcquireLockRequest 

type AcquireLockRequest struct {
	Timeout              *types.Duration `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AcquireLockRequest) Descriptor 

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

func (*AcquireLockRequest) GetTimeout 

func (m *AcquireLockRequest) GetTimeout() *types.Duration

func (*AcquireLockRequest) ProtoMessage 

func (*AcquireLockRequest) ProtoMessage()

func (*AcquireLockRequest) Reset 

func (m *AcquireLockRequest) Reset()

func (*AcquireLockRequest) String 

func (m *AcquireLockRequest) String() string

func (*AcquireLockRequest) XXX_DiscardUnknown 

func (m *AcquireLockRequest) XXX_DiscardUnknown()

func (*AcquireLockRequest) XXX_Marshal 

func (m *AcquireLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AcquireLockRequest) XXX_Merge 

func (dst *AcquireLockRequest) XXX_Merge(src proto.Message)

func (*AcquireLockRequest) XXX_Size 

func (m *AcquireLockRequest) XXX_Size() int

func (*AcquireLockRequest) XXX_Unmarshal 

func (m *AcquireLockRequest) XXX_Unmarshal(b []byte) error

type BackupRequest 

type BackupRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupRequest) Descriptor 

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

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset 

func (m *BackupRequest) Reset()

func (*BackupRequest) String 

func (m *BackupRequest) String() string

func (*BackupRequest) XXX_DiscardUnknown 

func (m *BackupRequest) XXX_DiscardUnknown()

func (*BackupRequest) XXX_Marshal 

func (m *BackupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupRequest) XXX_Merge 

func (dst *BackupRequest) XXX_Merge(src proto.Message)

func (*BackupRequest) XXX_Size 

func (m *BackupRequest) XXX_Size() int

func (*BackupRequest) XXX_Unmarshal 

func (m *BackupRequest) XXX_Unmarshal(b []byte) error

type BackupResponse 

type BackupResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackupResponse) Descriptor 

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

func (*BackupResponse) GetData 

func (m *BackupResponse) GetData() []byte

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) Reset 

func (m *BackupResponse) Reset()

func (*BackupResponse) String 

func (m *BackupResponse) String() string

func (*BackupResponse) XXX_DiscardUnknown 

func (m *BackupResponse) XXX_DiscardUnknown()

func (*BackupResponse) XXX_Marshal 

func (m *BackupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BackupResponse) XXX_Merge 

func (dst *BackupResponse) XXX_Merge(src proto.Message)

func (*BackupResponse) XXX_Size 

func (m *BackupResponse) XXX_Size() int

func (*BackupResponse) XXX_Unmarshal 

func (m *BackupResponse) XXX_Unmarshal(b []byte) error

type CreateBucketRequest 

type CreateBucketRequest struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateBucketRequest) Descriptor 

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

func (*CreateBucketRequest) GetBucket 

func (m *CreateBucketRequest) GetBucket() string

func (*CreateBucketRequest) ProtoMessage 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) Reset 

func (m *CreateBucketRequest) Reset()

func (*CreateBucketRequest) String 

func (m *CreateBucketRequest) String() string

func (*CreateBucketRequest) XXX_DiscardUnknown 

func (m *CreateBucketRequest) XXX_DiscardUnknown()

func (*CreateBucketRequest) XXX_Marshal 

func (m *CreateBucketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateBucketRequest) XXX_Merge 

func (dst *CreateBucketRequest) XXX_Merge(src proto.Message)

func (*CreateBucketRequest) XXX_Size 

func (m *CreateBucketRequest) XXX_Size() int

func (*CreateBucketRequest) XXX_Unmarshal 

func (m *CreateBucketRequest) XXX_Unmarshal(b []byte) error

type DatastoreClient 

type DatastoreClient interface {
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	AcquireLock(ctx context.Context, in *AcquireLockRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ReleaseLock(ctx context.Context, in *ReleaseLockRequest, opts ...grpc.CallOption) (*types.Empty, error)
	CreateBucket(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupResponse, error)
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*types.Empty, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Datastore_SyncClient, error)
	PeerSync(ctx context.Context, in *PeerSyncRequest, opts ...grpc.CallOption) (*types.Empty, error)
}

DatastoreClient is the client API for Datastore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatastoreClient 

func NewDatastoreClient(cc *grpc.ClientConn) DatastoreClient

type DatastoreServer 

type DatastoreServer interface {
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	AcquireLock(context.Context, *AcquireLockRequest) (*types.Empty, error)
	ReleaseLock(context.Context, *ReleaseLockRequest) (*types.Empty, error)
	CreateBucket(context.Context, *CreateBucketRequest) (*types.Empty, error)
	Set(context.Context, *SetRequest) (*types.Empty, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	Delete(context.Context, *DeleteRequest) (*types.Empty, error)
	Backup(context.Context, *BackupRequest) (*BackupResponse, error)
	Restore(context.Context, *RestoreRequest) (*types.Empty, error)
	Sync(*SyncRequest, Datastore_SyncServer) error
	PeerSync(context.Context, *PeerSyncRequest) (*types.Empty, error)
}

DatastoreServer is the server API for Datastore service.

type Datastore_SyncClient 

type Datastore_SyncClient interface {
	Recv() (*SyncOperation, error)
	grpc.ClientStream
}

type Datastore_SyncServer 

type Datastore_SyncServer interface {
	Send(*SyncOperation) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Sync                 bool     `protobuf:"varint,3,opt,name=sync,proto3" json:"sync,omitempty"`
	NoTombstone          bool     `protobuf:"varint,4,opt,name=no_tombstone,json=noTombstone,proto3" json:"no_tombstone,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetBucket 

func (m *DeleteRequest) GetBucket() string

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() string

func (*DeleteRequest) GetNoTombstone 

func (m *DeleteRequest) GetNoTombstone() bool

func (*DeleteRequest) GetSync 

func (m *DeleteRequest) GetSync() bool

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (dst *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type GetRequest 

type GetRequest struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetBucket 

func (m *GetRequest) GetBucket() string

func (*GetRequest) GetKey 

func (m *GetRequest) GetKey() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (dst *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetResponse 

type GetResponse struct {
	Bucket               string    `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Data                 *KeyValue `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetBucket 

func (m *GetResponse) GetBucket() string

func (*GetResponse) GetData 

func (m *GetResponse) GetData() *KeyValue

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetResponse) XXX_Merge 

func (dst *GetResponse) XXX_Merge(src proto.Message)

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

func (m *GetResponse) XXX_Unmarshal(b []byte) error

type InfoRequest added in v0.2.0 

type InfoRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoRequest) Descriptor added in v0.2.0 

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

func (*InfoRequest) ProtoMessage added in v0.2.0 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset added in v0.2.0 

func (m *InfoRequest) Reset()

func (*InfoRequest) String added in v0.2.0 

func (m *InfoRequest) String() string

func (*InfoRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal added in v0.2.0 

func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoRequest) XXX_Merge added in v0.2.0 

func (dst *InfoRequest) XXX_Merge(src proto.Message)

func (*InfoRequest) XXX_Size added in v0.2.0 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal added in v0.2.0 

func (m *InfoRequest) XXX_Unmarshal(b []byte) error

type InfoResponse added in v0.2.0 

type InfoResponse struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoResponse) Descriptor added in v0.2.0 

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

func (*InfoResponse) GetID added in v0.2.0 

func (m *InfoResponse) GetID() string

func (*InfoResponse) ProtoMessage added in v0.2.0 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset added in v0.2.0 

func (m *InfoResponse) Reset()

func (*InfoResponse) String added in v0.2.0 

func (m *InfoResponse) String() string

func (*InfoResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal added in v0.2.0 

func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoResponse) XXX_Merge added in v0.2.0 

func (dst *InfoResponse) XXX_Merge(src proto.Message)

func (*InfoResponse) XXX_Size added in v0.2.0 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal added in v0.2.0 

func (m *InfoResponse) XXX_Unmarshal(b []byte) error

type KeyValue 

type KeyValue struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) GetKey 

func (m *KeyValue) GetKey() string

func (*KeyValue) GetValue 

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

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) XXX_DiscardUnknown 

func (m *KeyValue) XXX_DiscardUnknown()

func (*KeyValue) XXX_Marshal 

func (m *KeyValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValue) XXX_Merge 

func (dst *KeyValue) XXX_Merge(src proto.Message)

func (*KeyValue) XXX_Size 

func (m *KeyValue) XXX_Size() int

func (*KeyValue) XXX_Unmarshal 

func (m *KeyValue) XXX_Unmarshal(b []byte) error

type PeerSyncRequest 

type PeerSyncRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerSyncRequest) Descriptor 

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

func (*PeerSyncRequest) GetAddress added in v0.2.0 

func (m *PeerSyncRequest) GetAddress() string

func (*PeerSyncRequest) GetID added in v0.2.0 

func (m *PeerSyncRequest) GetID() string

func (*PeerSyncRequest) ProtoMessage 

func (*PeerSyncRequest) ProtoMessage()

func (*PeerSyncRequest) Reset 

func (m *PeerSyncRequest) Reset()

func (*PeerSyncRequest) String 

func (m *PeerSyncRequest) String() string

func (*PeerSyncRequest) XXX_DiscardUnknown 

func (m *PeerSyncRequest) XXX_DiscardUnknown()

func (*PeerSyncRequest) XXX_Marshal 

func (m *PeerSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerSyncRequest) XXX_Merge 

func (dst *PeerSyncRequest) XXX_Merge(src proto.Message)

func (*PeerSyncRequest) XXX_Size 

func (m *PeerSyncRequest) XXX_Size() int

func (*PeerSyncRequest) XXX_Unmarshal 

func (m *PeerSyncRequest) XXX_Unmarshal(b []byte) error

type ReleaseLockRequest 

type ReleaseLockRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReleaseLockRequest) Descriptor 

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

func (*ReleaseLockRequest) ProtoMessage 

func (*ReleaseLockRequest) ProtoMessage()

func (*ReleaseLockRequest) Reset 

func (m *ReleaseLockRequest) Reset()

func (*ReleaseLockRequest) String 

func (m *ReleaseLockRequest) String() string

func (*ReleaseLockRequest) XXX_DiscardUnknown 

func (m *ReleaseLockRequest) XXX_DiscardUnknown()

func (*ReleaseLockRequest) XXX_Marshal 

func (m *ReleaseLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReleaseLockRequest) XXX_Merge 

func (dst *ReleaseLockRequest) XXX_Merge(src proto.Message)

func (*ReleaseLockRequest) XXX_Size 

func (m *ReleaseLockRequest) XXX_Size() int

func (*ReleaseLockRequest) XXX_Unmarshal 

func (m *ReleaseLockRequest) XXX_Unmarshal(b []byte) error

type RestoreRequest 

type RestoreRequest struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreRequest) Descriptor 

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

func (*RestoreRequest) GetData 

func (m *RestoreRequest) GetData() []byte

func (*RestoreRequest) ProtoMessage 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) Reset 

func (m *RestoreRequest) Reset()

func (*RestoreRequest) String 

func (m *RestoreRequest) String() string

func (*RestoreRequest) XXX_DiscardUnknown 

func (m *RestoreRequest) XXX_DiscardUnknown()

func (*RestoreRequest) XXX_Marshal 

func (m *RestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreRequest) XXX_Merge 

func (dst *RestoreRequest) XXX_Merge(src proto.Message)

func (*RestoreRequest) XXX_Size 

func (m *RestoreRequest) XXX_Size() int

func (*RestoreRequest) XXX_Unmarshal 

func (m *RestoreRequest) XXX_Unmarshal(b []byte) error

type SearchRequest 

type SearchRequest struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix               string   `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetBucket 

func (m *SearchRequest) GetBucket() string

func (*SearchRequest) GetPrefix 

func (m *SearchRequest) GetPrefix() string

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal 

func (m *SearchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchRequest) XXX_Merge 

func (dst *SearchRequest) XXX_Merge(src proto.Message)

func (*SearchRequest) XXX_Size 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal 

func (m *SearchRequest) XXX_Unmarshal(b []byte) error

type SearchResponse 

type SearchResponse struct {
	Bucket               string      `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Data                 []*KeyValue `protobuf:"bytes,2,rep,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetBucket 

func (m *SearchResponse) GetBucket() string

func (*SearchResponse) GetData 

func (m *SearchResponse) GetData() []*KeyValue

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) XXX_DiscardUnknown 

func (m *SearchResponse) XXX_DiscardUnknown()

func (*SearchResponse) XXX_Marshal 

func (m *SearchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchResponse) XXX_Merge 

func (dst *SearchResponse) XXX_Merge(src proto.Message)

func (*SearchResponse) XXX_Size 

func (m *SearchResponse) XXX_Size() int

func (*SearchResponse) XXX_Unmarshal 

func (m *SearchResponse) XXX_Unmarshal(b []byte) error

type SetRequest 

type SetRequest struct {
	Bucket               string   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Sync                 bool     `protobuf:"varint,4,opt,name=sync,proto3" json:"sync,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetRequest) Descriptor 

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

func (*SetRequest) GetBucket 

func (m *SetRequest) GetBucket() string

func (*SetRequest) GetKey 

func (m *SetRequest) GetKey() string

func (*SetRequest) GetSync 

func (m *SetRequest) GetSync() bool

func (*SetRequest) GetValue 

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

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

func (m *SetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetRequest) XXX_Merge 

func (dst *SetRequest) XXX_Merge(src proto.Message)

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

func (m *SetRequest) XXX_Unmarshal(b []byte) error

type SyncAction 

type SyncAction int32
const (
	SyncAction_SET    SyncAction = 0
	SyncAction_DELETE SyncAction = 1
)

func (SyncAction) EnumDescriptor 

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

func (SyncAction) String 

func (x SyncAction) String() string

type SyncOperation 

type SyncOperation struct {
	Action               SyncAction `protobuf:"varint,1,opt,name=action,proto3,enum=stellar.services.datastore.v1.SyncAction" json:"action,omitempty"`
	Bucket               string     `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Key                  string     `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte     `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SyncOperation) Descriptor 

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

func (*SyncOperation) GetAction 

func (m *SyncOperation) GetAction() SyncAction

func (*SyncOperation) GetBucket 

func (m *SyncOperation) GetBucket() string

func (*SyncOperation) GetKey 

func (m *SyncOperation) GetKey() string

func (*SyncOperation) GetValue 

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

func (*SyncOperation) ProtoMessage 

func (*SyncOperation) ProtoMessage()

func (*SyncOperation) Reset 

func (m *SyncOperation) Reset()

func (*SyncOperation) String 

func (m *SyncOperation) String() string

func (*SyncOperation) XXX_DiscardUnknown 

func (m *SyncOperation) XXX_DiscardUnknown()

func (*SyncOperation) XXX_Marshal 

func (m *SyncOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncOperation) XXX_Merge 

func (dst *SyncOperation) XXX_Merge(src proto.Message)

func (*SyncOperation) XXX_Size 

func (m *SyncOperation) XXX_Size() int

func (*SyncOperation) XXX_Unmarshal 

func (m *SyncOperation) XXX_Unmarshal(b []byte) error

type SyncRequest 

type SyncRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SyncRequest) Descriptor 

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

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset 

func (m *SyncRequest) Reset()

func (*SyncRequest) String 

func (m *SyncRequest) String() string

func (*SyncRequest) XXX_DiscardUnknown 

func (m *SyncRequest) XXX_DiscardUnknown()

func (*SyncRequest) XXX_Marshal 

func (m *SyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncRequest) XXX_Merge 

func (dst *SyncRequest) XXX_Merge(src proto.Message)

func (*SyncRequest) XXX_Size 

func (m *SyncRequest) XXX_Size() int

func (*SyncRequest) XXX_Unmarshal 

func (m *SyncRequest) XXX_Unmarshal(b []byte) 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.