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

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

    func (*InfoRequest) Descriptor

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

    func (*InfoRequest) ProtoMessage

    func (*InfoRequest) ProtoMessage()

    func (*InfoRequest) Reset

    func (m *InfoRequest) Reset()

    func (*InfoRequest) String

    func (m *InfoRequest) String() string

    func (*InfoRequest) XXX_DiscardUnknown

    func (m *InfoRequest) XXX_DiscardUnknown()

    func (*InfoRequest) XXX_Marshal

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

    func (*InfoRequest) XXX_Merge

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

    func (*InfoRequest) XXX_Size

    func (m *InfoRequest) XXX_Size() int

    func (*InfoRequest) XXX_Unmarshal

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

    type InfoResponse

    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

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

    func (*InfoResponse) GetID

    func (m *InfoResponse) GetID() string

    func (*InfoResponse) ProtoMessage

    func (*InfoResponse) ProtoMessage()

    func (*InfoResponse) Reset

    func (m *InfoResponse) Reset()

    func (*InfoResponse) String

    func (m *InfoResponse) String() string

    func (*InfoResponse) XXX_DiscardUnknown

    func (m *InfoResponse) XXX_DiscardUnknown()

    func (*InfoResponse) XXX_Marshal

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

    func (*InfoResponse) XXX_Merge

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

    func (*InfoResponse) XXX_Size

    func (m *InfoResponse) XXX_Size() int

    func (*InfoResponse) XXX_Unmarshal

    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

    func (m *PeerSyncRequest) GetAddress() string

    func (*PeerSyncRequest) GetID

    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