ptarmiganpb

package
v0.0.0-...-2627f95 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2020 License: MIT Imports: 17 Imported by: 0

Documentation

Overview

Package ptarmiganpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPtarmigan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPtarmigan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPtarmigan = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Condition_Quantifier_name = map[int32]string{
	0: "FOR_ALL",
	1: "EXISTS",
}
View Source 
var Condition_Quantifier_value = map[string]int32{
	"FOR_ALL": 0,
	"EXISTS":  1,
}
View Source 
var Event_EventType_name = map[int32]string{
	0: "PUT",
	1: "DELETE",
}
View Source 
var Event_EventType_value = map[string]int32{
	"PUT":    0,
	"DELETE": 1,
}
View Source 
var Field_name = map[int32]string{
	0: "VERSION",
	1: "CREATE",
	2: "MOD",
	3: "VALUE",
	4: "LEASE",
	5: "KEY",
}
View Source 
var Field_value = map[string]int32{
	"VERSION": 0,
	"CREATE":  1,
	"MOD":     2,
	"VALUE":   3,
	"LEASE":   4,
	"KEY":     5,
}
View Source 
var KVPredicate_Operator_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
	2: "GT",
	3: "GTE",
	4: "LT",
	5: "LTE",
	6: "STARTS_WITH",
}
View Source 
var KVPredicate_Operator_value = map[string]int32{
	"EQUAL":       0,
	"NOT_EQUAL":   1,
	"GT":          2,
	"GTE":         3,
	"LT":          4,
	"LTE":         5,
	"STARTS_WITH": 6,
}
View Source 
var KVQueryRequest_SortOrder_name = map[int32]string{
	0: "NONE",
	1: "ASC",
	2: "DESC",
}
View Source 
var KVQueryRequest_SortOrder_value = map[string]int32{
	"NONE": 0,
	"ASC":  1,
	"DESC": 2,
}

Functions

func RegisterKVHandler 

func RegisterKVHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterKVHandler registers the http handlers for service KV to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterKVHandlerClient 

func RegisterKVHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KVClient) error

RegisterKVHandlerClient registers the http handlers for service KV to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "KVClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "KVClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "KVClient" to call the correct interceptors.

func RegisterKVHandlerFromEndpoint 

func RegisterKVHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterKVHandlerFromEndpoint is same as RegisterKVHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterKVHandlerServer 

func RegisterKVHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KVServer) error

RegisterKVHandlerServer registers the http handlers for service KV to "mux". UnaryRPC :call KVServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterKVServer 

func RegisterKVServer(s *grpc.Server, srv KVServer)

func RegisterLeasesHandler 

func RegisterLeasesHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLeasesHandler registers the http handlers for service Leases to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLeasesHandlerClient 

func RegisterLeasesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LeasesClient) error

RegisterLeasesHandlerClient registers the http handlers for service Leases to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LeasesClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LeasesClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LeasesClient" to call the correct interceptors.

func RegisterLeasesHandlerFromEndpoint 

func RegisterLeasesHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLeasesHandlerFromEndpoint is same as RegisterLeasesHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLeasesHandlerServer 

func RegisterLeasesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LeasesServer) error

RegisterLeasesHandlerServer registers the http handlers for service Leases to "mux". UnaryRPC :call LeasesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterLeasesServer 

func RegisterLeasesServer(s *grpc.Server, srv LeasesServer)

Types

type Condition 

type Condition struct {
	// domain describes the set of keys which form the range
	// of quantification.
	Domain []KVPredicate `protobuf:"bytes,1,rep,name=domain,proto3" json:"domain"`
	// predicate describes a condition which must hold for some
	// number of keys in the domain.
	Predicate KVPredicate `protobuf:"bytes,2,opt,name=predicate,proto3" json:"predicate"`
	// quantifier adjusts how many keys in the domain must match
	// the predicate.
	// quantifier < 0 means "for all": for all keys in the domain the predicate must hold
	// quantifier = 0 means "there does not exist"
	Quantifier Condition_Quantifier `protobuf:"varint,3,opt,name=quantifier,proto3,enum=ptarmiganpb.Condition_Quantifier" json:"quantifier,omitempty"`
}

Condition can be used to describe some existential or universal quantifier for range of keys.

func (*Condition) Descriptor 

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

func (*Condition) Marshal 

func (m *Condition) Marshal() (dAtA []byte, err error)

func (*Condition) MarshalTo 

func (m *Condition) MarshalTo(dAtA []byte) (int, error)

func (*Condition) MarshalToSizedBuffer 

func (m *Condition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Condition) ProtoMessage 

func (*Condition) ProtoMessage()

func (*Condition) Reset 

func (m *Condition) Reset()

func (*Condition) Size 

func (m *Condition) Size() (n int)

func (*Condition) String 

func (m *Condition) String() string

func (*Condition) Unmarshal 

func (m *Condition) Unmarshal(dAtA []byte) error

func (*Condition) XXX_DiscardUnknown 

func (m *Condition) XXX_DiscardUnknown()

func (*Condition) XXX_Marshal 

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

func (*Condition) XXX_Merge 

func (m *Condition) XXX_Merge(src proto.Message)

func (*Condition) XXX_Size 

func (m *Condition) XXX_Size() int

func (*Condition) XXX_Unmarshal 

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

type Condition_Quantifier 

type Condition_Quantifier int32
const (
	FOR_ALL Condition_Quantifier = 0
	EXISTS  Condition_Quantifier = 1
)

func (Condition_Quantifier) EnumDescriptor 

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

func (Condition_Quantifier) String 

func (x Condition_Quantifier) String() string

type Event 

type Event struct {
	// type is the kind of event. If type is a PUT, it indicates
	// new data has been stored to the key. If type is a DELETE,
	// it indicates the key was deleted.
	Type Event_EventType `protobuf:"varint,1,opt,name=type,proto3,enum=ptarmiganpb.Event_EventType" json:"type,omitempty"`
	// kv holds the KeyValue for the event.
	// A PUT event contains current kv pair.
	// A PUT event with kv.Version=1 indicates the creation of a key.
	// A DELETE/EXPIRE event contains the deleted key with
	// its modification revision set to the revision of deletion.
	Kv KeyValue `protobuf:"bytes,2,opt,name=kv,proto3" json:"kv"`
	// prev_kv holds the key-value pair before the event happens.
	PrevKv *KeyValue `protobuf:"bytes,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
}

func (*Event) Descriptor 

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

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_EventType 

type Event_EventType int32
const (
	PUT    Event_EventType = 0
	DELETE Event_EventType = 1
)

func (Event_EventType) EnumDescriptor 

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

func (Event_EventType) String 

func (x Event_EventType) String() string

type Field 

type Field int32
const (
	VERSION Field = 0
	CREATE  Field = 1
	MOD     Field = 2
	VALUE   Field = 3
	LEASE   Field = 4
	KEY     Field = 5
)

func (Field) EnumDescriptor 

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

func (Field) String 

func (x Field) String() string

type KVClient 

type KVClient interface {
	// Query retrieves kvs from a partition
	Query(ctx context.Context, in *KVQueryRequest, opts ...grpc.CallOption) (*KVQueryResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	Txn(ctx context.Context, in *KVTxnRequest, opts ...grpc.CallOption) (*KVTxnResponse, error)
	// Compact compacts the event history in the key-value store. The key-value
	// store should be periodically compacted or the event history will continue to grow
	// indefinitely.
	Compact(ctx context.Context, in *KVCompactionRequest, opts ...grpc.CallOption) (*KVCompactionResponse, error)
	// Watch creates a watcher to watch for events happening or that have happened.
	// The entire event history can be watched starting from the last compaction revision.
	Watch(ctx context.Context, in *KVWatchRequest, opts ...grpc.CallOption) (KV_WatchClient, error)
}

KVClient is the client API for KV service.

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

func NewKVClient 

func NewKVClient(cc *grpc.ClientConn) KVClient

type KVCompactionRequest 

type KVCompactionRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// revision is the key-value store revision for the compaction operation.
	Revision int64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
}

CompactionRequest compacts the key-value store up to a given revision. All superseded keys with a revision less than the compaction revision will be removed.

func (*KVCompactionRequest) Descriptor 

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

func (*KVCompactionRequest) Marshal 

func (m *KVCompactionRequest) Marshal() (dAtA []byte, err error)

func (*KVCompactionRequest) MarshalTo 

func (m *KVCompactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVCompactionRequest) MarshalToSizedBuffer 

func (m *KVCompactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVCompactionRequest) ProtoMessage 

func (*KVCompactionRequest) ProtoMessage()

func (*KVCompactionRequest) Reset 

func (m *KVCompactionRequest) Reset()

func (*KVCompactionRequest) Size 

func (m *KVCompactionRequest) Size() (n int)

func (*KVCompactionRequest) String 

func (m *KVCompactionRequest) String() string

func (*KVCompactionRequest) Unmarshal 

func (m *KVCompactionRequest) Unmarshal(dAtA []byte) error

func (*KVCompactionRequest) XXX_DiscardUnknown 

func (m *KVCompactionRequest) XXX_DiscardUnknown()

func (*KVCompactionRequest) XXX_Marshal 

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

func (*KVCompactionRequest) XXX_Merge 

func (m *KVCompactionRequest) XXX_Merge(src proto.Message)

func (*KVCompactionRequest) XXX_Size 

func (m *KVCompactionRequest) XXX_Size() int

func (*KVCompactionRequest) XXX_Unmarshal 

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

type KVCompactionResponse 

type KVCompactionResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
}

func (*KVCompactionResponse) Descriptor 

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

func (*KVCompactionResponse) Marshal 

func (m *KVCompactionResponse) Marshal() (dAtA []byte, err error)

func (*KVCompactionResponse) MarshalTo 

func (m *KVCompactionResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVCompactionResponse) MarshalToSizedBuffer 

func (m *KVCompactionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVCompactionResponse) ProtoMessage 

func (*KVCompactionResponse) ProtoMessage()

func (*KVCompactionResponse) Reset 

func (m *KVCompactionResponse) Reset()

func (*KVCompactionResponse) Size 

func (m *KVCompactionResponse) Size() (n int)

func (*KVCompactionResponse) String 

func (m *KVCompactionResponse) String() string

func (*KVCompactionResponse) Unmarshal 

func (m *KVCompactionResponse) Unmarshal(dAtA []byte) error

func (*KVCompactionResponse) XXX_DiscardUnknown 

func (m *KVCompactionResponse) XXX_DiscardUnknown()

func (*KVCompactionResponse) XXX_Marshal 

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

func (*KVCompactionResponse) XXX_Merge 

func (m *KVCompactionResponse) XXX_Merge(src proto.Message)

func (*KVCompactionResponse) XXX_Size 

func (m *KVCompactionResponse) XXX_Size() int

func (*KVCompactionResponse) XXX_Unmarshal 

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

type KVDeleteRequest 

type KVDeleteRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// Only keys matching the predicates in the selection will be deleted
	Selection []KVPredicate `protobuf:"bytes,2,rep,name=selection,proto3" json:"selection"`
	// If prev_kv is set, ptarmigan gets the previous key-value pairs before deleting it.
	// The previous key-value pairs will be returned in the delete response.
	PrevKv bool `protobuf:"varint,3,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
}

func (*KVDeleteRequest) Descriptor 

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

func (*KVDeleteRequest) Marshal 

func (m *KVDeleteRequest) Marshal() (dAtA []byte, err error)

func (*KVDeleteRequest) MarshalTo 

func (m *KVDeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVDeleteRequest) MarshalToSizedBuffer 

func (m *KVDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVDeleteRequest) ProtoMessage 

func (*KVDeleteRequest) ProtoMessage()

func (*KVDeleteRequest) Reset 

func (m *KVDeleteRequest) Reset()

func (*KVDeleteRequest) Size 

func (m *KVDeleteRequest) Size() (n int)

func (*KVDeleteRequest) String 

func (m *KVDeleteRequest) String() string

func (*KVDeleteRequest) Unmarshal 

func (m *KVDeleteRequest) Unmarshal(dAtA []byte) error

func (*KVDeleteRequest) XXX_DiscardUnknown 

func (m *KVDeleteRequest) XXX_DiscardUnknown()

func (*KVDeleteRequest) XXX_Marshal 

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

func (*KVDeleteRequest) XXX_Merge 

func (m *KVDeleteRequest) XXX_Merge(src proto.Message)

func (*KVDeleteRequest) XXX_Size 

func (m *KVDeleteRequest) XXX_Size() int

func (*KVDeleteRequest) XXX_Unmarshal 

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

type KVDeleteResponse 

type KVDeleteResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// deleted is the number of keys deleted by the delete range request.
	Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// if prev_kv is set in the request, the previous key-value pairs will be returned.
	PrevKvs []KeyValue `protobuf:"bytes,3,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs"`
}

func (*KVDeleteResponse) Descriptor 

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

func (*KVDeleteResponse) Marshal 

func (m *KVDeleteResponse) Marshal() (dAtA []byte, err error)

func (*KVDeleteResponse) MarshalTo 

func (m *KVDeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVDeleteResponse) MarshalToSizedBuffer 

func (m *KVDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVDeleteResponse) ProtoMessage 

func (*KVDeleteResponse) ProtoMessage()

func (*KVDeleteResponse) Reset 

func (m *KVDeleteResponse) Reset()

func (*KVDeleteResponse) Size 

func (m *KVDeleteResponse) Size() (n int)

func (*KVDeleteResponse) String 

func (m *KVDeleteResponse) String() string

func (*KVDeleteResponse) Unmarshal 

func (m *KVDeleteResponse) Unmarshal(dAtA []byte) error

func (*KVDeleteResponse) XXX_DiscardUnknown 

func (m *KVDeleteResponse) XXX_DiscardUnknown()

func (*KVDeleteResponse) XXX_Marshal 

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

func (*KVDeleteResponse) XXX_Merge 

func (m *KVDeleteResponse) XXX_Merge(src proto.Message)

func (*KVDeleteResponse) XXX_Size 

func (m *KVDeleteResponse) XXX_Size() int

func (*KVDeleteResponse) XXX_Unmarshal 

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

type KVPredicate 

type KVPredicate struct {
	// operator is the logical comparison operation for this comparison.
	Operator KVPredicate_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=ptarmiganpb.KVPredicate_Operator" json:"operator,omitempty"`
	// field is the key-value field to inspect for the comparison.
	Field Field `protobuf:"varint,2,opt,name=field,proto3,enum=ptarmiganpb.Field" json:"field,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*KVPredicate_Int64
	//	*KVPredicate_Bytes
	Value isKVPredicate_Value `protobuf_oneof:"value"`
}

func (*KVPredicate) Descriptor 

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

func (*KVPredicate) GetBytes 

func (m *KVPredicate) GetBytes() []byte

func (*KVPredicate) GetInt64 

func (m *KVPredicate) GetInt64() int64

func (*KVPredicate) GetValue 

func (m *KVPredicate) GetValue() isKVPredicate_Value

func (KVPredicate) IsEmpty 

func (predicate KVPredicate) IsEmpty() bool

IsEmpty returns true is this predicate is empty

func (*KVPredicate) Marshal 

func (m *KVPredicate) Marshal() (dAtA []byte, err error)

func (*KVPredicate) MarshalTo 

func (m *KVPredicate) MarshalTo(dAtA []byte) (int, error)

func (*KVPredicate) MarshalToSizedBuffer 

func (m *KVPredicate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPredicate) ProtoMessage 

func (*KVPredicate) ProtoMessage()

func (*KVPredicate) Reset 

func (m *KVPredicate) Reset()

func (*KVPredicate) Size 

func (m *KVPredicate) Size() (n int)

func (*KVPredicate) String 

func (m *KVPredicate) String() string

func (*KVPredicate) Unmarshal 

func (m *KVPredicate) Unmarshal(dAtA []byte) error

func (*KVPredicate) XXX_DiscardUnknown 

func (m *KVPredicate) XXX_DiscardUnknown()

func (*KVPredicate) XXX_Marshal 

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

func (*KVPredicate) XXX_Merge 

func (m *KVPredicate) XXX_Merge(src proto.Message)

func (*KVPredicate) XXX_OneofWrappers 

func (*KVPredicate) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KVPredicate) XXX_Size 

func (m *KVPredicate) XXX_Size() int

func (*KVPredicate) XXX_Unmarshal 

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

type KVPredicate_Bytes 

type KVPredicate_Bytes struct {
	Bytes []byte `protobuf:"bytes,4,opt,name=bytes,proto3,oneof" json:"bytes,omitempty"`
}

func (*KVPredicate_Bytes) MarshalTo 

func (m *KVPredicate_Bytes) MarshalTo(dAtA []byte) (int, error)

func (*KVPredicate_Bytes) MarshalToSizedBuffer 

func (m *KVPredicate_Bytes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPredicate_Bytes) Size 

func (m *KVPredicate_Bytes) Size() (n int)

type KVPredicate_Int64 

type KVPredicate_Int64 struct {
	Int64 int64 `protobuf:"varint,3,opt,name=int64,proto3,oneof" json:"int64,omitempty"`
}

func (*KVPredicate_Int64) MarshalTo 

func (m *KVPredicate_Int64) MarshalTo(dAtA []byte) (int, error)

func (*KVPredicate_Int64) MarshalToSizedBuffer 

func (m *KVPredicate_Int64) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPredicate_Int64) Size 

func (m *KVPredicate_Int64) Size() (n int)

type KVPredicate_Operator 

type KVPredicate_Operator int32

[FIELD] [COMPARISON] VALUE 

const (
	// =
	EQUAL KVPredicate_Operator = 0
	// !=
	NOT_EQUAL KVPredicate_Operator = 1
	// >
	GT KVPredicate_Operator = 2
	// >=
	GTE KVPredicate_Operator = 3
	// <
	LT KVPredicate_Operator = 4
	// <=
	LTE         KVPredicate_Operator = 5
	STARTS_WITH KVPredicate_Operator = 6
)

func (KVPredicate_Operator) EnumDescriptor 

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

func (KVPredicate_Operator) String 

func (x KVPredicate_Operator) String() string

type KVPutRequest 

type KVPutRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// Only keys matching the predicates in the selection will be updated
	Selection []KVPredicate `protobuf:"bytes,2,rep,name=selection,proto3" json:"selection"`
	// key is the key, in bytes, to create or update. Selection is ignored
	// if key is specified
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// value is the value, in bytes, to associate with the key in the key-value store.
	Value []byte `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// lease is the lease ID to associate with the key in the key-value store. A lease
	// value of 0 indicates no lease.
	Lease int64 `protobuf:"varint,5,opt,name=lease,proto3" json:"lease,omitempty"`
	// If prev_kv is set, ptarmigan gets the previous key-value pair before changing it.
	// The previous key-value pair will be returned in the put response.
	PrevKv bool `protobuf:"varint,6,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
	// If ignore_value is set, ptarmigan updates the key using its current value.
	// Returns an error if the key does not exist.
	IgnoreValue bool `protobuf:"varint,7,opt,name=ignore_value,json=ignoreValue,proto3" json:"ignore_value,omitempty"`
	// If ignore_lease is set, ptarmigan updates the key using its current lease.
	// Returns an error if the key does not exist.
	IgnoreLease bool `protobuf:"varint,8,opt,name=ignore_lease,json=ignoreLease,proto3" json:"ignore_lease,omitempty"`
}

func (*KVPutRequest) Descriptor 

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

func (*KVPutRequest) Marshal 

func (m *KVPutRequest) Marshal() (dAtA []byte, err error)

func (*KVPutRequest) MarshalTo 

func (m *KVPutRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVPutRequest) MarshalToSizedBuffer 

func (m *KVPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPutRequest) ProtoMessage 

func (*KVPutRequest) ProtoMessage()

func (*KVPutRequest) Reset 

func (m *KVPutRequest) Reset()

func (*KVPutRequest) Size 

func (m *KVPutRequest) Size() (n int)

func (*KVPutRequest) String 

func (m *KVPutRequest) String() string

func (*KVPutRequest) Unmarshal 

func (m *KVPutRequest) Unmarshal(dAtA []byte) error

func (*KVPutRequest) XXX_DiscardUnknown 

func (m *KVPutRequest) XXX_DiscardUnknown()

func (*KVPutRequest) XXX_Marshal 

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

func (*KVPutRequest) XXX_Merge 

func (m *KVPutRequest) XXX_Merge(src proto.Message)

func (*KVPutRequest) XXX_Size 

func (m *KVPutRequest) XXX_Size() int

func (*KVPutRequest) XXX_Unmarshal 

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

type KVPutResponse 

type KVPutResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// if prev_kv is set in the request, the previous key-value pairs will be returned.
	PrevKvs []KeyValue `protobuf:"bytes,2,rep,name=prev_kvs,json=prevKvs,proto3" json:"prev_kvs"`
}

func (*KVPutResponse) Descriptor 

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

func (*KVPutResponse) Marshal 

func (m *KVPutResponse) Marshal() (dAtA []byte, err error)

func (*KVPutResponse) MarshalTo 

func (m *KVPutResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVPutResponse) MarshalToSizedBuffer 

func (m *KVPutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVPutResponse) ProtoMessage 

func (*KVPutResponse) ProtoMessage()

func (*KVPutResponse) Reset 

func (m *KVPutResponse) Reset()

func (*KVPutResponse) Size 

func (m *KVPutResponse) Size() (n int)

func (*KVPutResponse) String 

func (m *KVPutResponse) String() string

func (*KVPutResponse) Unmarshal 

func (m *KVPutResponse) Unmarshal(dAtA []byte) error

func (*KVPutResponse) XXX_DiscardUnknown 

func (m *KVPutResponse) XXX_DiscardUnknown()

func (*KVPutResponse) XXX_Marshal 

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

func (*KVPutResponse) XXX_Merge 

func (m *KVPutResponse) XXX_Merge(src proto.Message)

func (*KVPutResponse) XXX_Size 

func (m *KVPutResponse) XXX_Size() int

func (*KVPutResponse) XXX_Unmarshal 

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

type KVQueryRequest 

type KVQueryRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// Only keys matching the predicates in the selection will be included in the result
	Selection []KVPredicate `protobuf:"bytes,2,rep,name=selection,proto3" json:"selection"`
	// Use after to get the next page of results by inserting the after cursor from the
	// previous page.
	After string `protobuf:"bytes,3,opt,name=after,proto3" json:"after,omitempty"`
	// limit is the limit on the number of keys returned in the result.
	// If limit is set to 0 the default limit is used.
	Limit int64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// revision is the revision of the store to use for the query.
	// If revision is less or equal to zero, the range is over the newest key-value store.
	// If the revision has been compacted, ErrCompacted is returned as a response.
	Revision int64 `protobuf:"varint,5,opt,name=revision,proto3" json:"revision,omitempty"`
	// sort_order is the order for returned sorted results.
	SortOrder KVQueryRequest_SortOrder `` /* 131-byte string literal not displayed */
	// sort_target is the key-value field to use for sorting.
	SortTarget Field `protobuf:"varint,7,opt,name=sort_target,json=sortTarget,proto3,enum=ptarmiganpb.Field" json:"sort_target,omitempty"`
	// serializable sets the range request to use serializable member-local reads.
	// Range requests are linearizable by default; linearizable requests have higher
	// latency and lower throughput than serializable requests but reflect the current
	// consensus of the cluster. For better performance, in exchange for possible stale reads,
	// a serializable range request is served locally without needing to reach consensus
	// with other nodes in the cluster.
	Serializable bool `protobuf:"varint,8,opt,name=serializable,proto3" json:"serializable,omitempty"`
	// exclude_values when set excludes values from the resulting kvs
	ExcludeValues bool `protobuf:"varint,9,opt,name=exclude_values,json=excludeValues,proto3" json:"exclude_values,omitempty"`
	// include_count when set includes the total count of keys matching
	// the query constraints in the result
	IncludeCount bool `protobuf:"varint,10,opt,name=include_count,json=includeCount,proto3" json:"include_count,omitempty"`
}

func (*KVQueryRequest) Descriptor 

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

func (*KVQueryRequest) Marshal 

func (m *KVQueryRequest) Marshal() (dAtA []byte, err error)

func (*KVQueryRequest) MarshalTo 

func (m *KVQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVQueryRequest) MarshalToSizedBuffer 

func (m *KVQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVQueryRequest) ProtoMessage 

func (*KVQueryRequest) ProtoMessage()

func (*KVQueryRequest) Reset 

func (m *KVQueryRequest) Reset()

func (*KVQueryRequest) Size 

func (m *KVQueryRequest) Size() (n int)

func (*KVQueryRequest) String 

func (m *KVQueryRequest) String() string

func (*KVQueryRequest) Unmarshal 

func (m *KVQueryRequest) Unmarshal(dAtA []byte) error

func (*KVQueryRequest) XXX_DiscardUnknown 

func (m *KVQueryRequest) XXX_DiscardUnknown()

func (*KVQueryRequest) XXX_Marshal 

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

func (*KVQueryRequest) XXX_Merge 

func (m *KVQueryRequest) XXX_Merge(src proto.Message)

func (*KVQueryRequest) XXX_Size 

func (m *KVQueryRequest) XXX_Size() int

func (*KVQueryRequest) XXX_Unmarshal 

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

type KVQueryRequest_SortOrder 

type KVQueryRequest_SortOrder int32
const (
	NONE KVQueryRequest_SortOrder = 0
	ASC  KVQueryRequest_SortOrder = 1
	DESC KVQueryRequest_SortOrder = 2
)

func (KVQueryRequest_SortOrder) EnumDescriptor 

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

func (KVQueryRequest_SortOrder) String 

func (x KVQueryRequest_SortOrder) String() string

type KVQueryResponse 

type KVQueryResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// kvs is the list of key-value pairs matched by the query.
	Kvs []KeyValue `protobuf:"bytes,2,rep,name=kvs,proto3" json:"kvs"`
	// more indicates if there are more keys matching the query.
	More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	// after is a cursor that can be used in to get the next page
	// of results after this one.
	After string `protobuf:"bytes,4,opt,name=after,proto3" json:"after,omitempty"`
	// count is set to the total number of keys matching the query.
	Count int64 `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
}

func (*KVQueryResponse) Descriptor 

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

func (*KVQueryResponse) Marshal 

func (m *KVQueryResponse) Marshal() (dAtA []byte, err error)

func (*KVQueryResponse) MarshalTo 

func (m *KVQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVQueryResponse) MarshalToSizedBuffer 

func (m *KVQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVQueryResponse) ProtoMessage 

func (*KVQueryResponse) ProtoMessage()

func (*KVQueryResponse) Reset 

func (m *KVQueryResponse) Reset()

func (*KVQueryResponse) Size 

func (m *KVQueryResponse) Size() (n int)

func (*KVQueryResponse) String 

func (m *KVQueryResponse) String() string

func (*KVQueryResponse) Unmarshal 

func (m *KVQueryResponse) Unmarshal(dAtA []byte) error

func (*KVQueryResponse) XXX_DiscardUnknown 

func (m *KVQueryResponse) XXX_DiscardUnknown()

func (*KVQueryResponse) XXX_Marshal 

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

func (*KVQueryResponse) XXX_Merge 

func (m *KVQueryResponse) XXX_Merge(src proto.Message)

func (*KVQueryResponse) XXX_Size 

func (m *KVQueryResponse) XXX_Size() int

func (*KVQueryResponse) XXX_Unmarshal 

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

type KVRequestOp 

type KVRequestOp struct {
	// request is a union of request types accepted by a transaction.
	//
	// Types that are valid to be assigned to Request:
	//	*KVRequestOp_RequestQuery
	//	*KVRequestOp_RequestPut
	//	*KVRequestOp_RequestDelete
	//	*KVRequestOp_RequestTxn
	Request isKVRequestOp_Request `protobuf_oneof:"request"`
}

func (*KVRequestOp) Descriptor 

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

func (*KVRequestOp) GetRequest 

func (m *KVRequestOp) GetRequest() isKVRequestOp_Request

func (*KVRequestOp) GetRequestDelete 

func (m *KVRequestOp) GetRequestDelete() *KVDeleteRequest

func (*KVRequestOp) GetRequestPut 

func (m *KVRequestOp) GetRequestPut() *KVPutRequest

func (*KVRequestOp) GetRequestQuery 

func (m *KVRequestOp) GetRequestQuery() *KVQueryRequest

func (*KVRequestOp) GetRequestTxn 

func (m *KVRequestOp) GetRequestTxn() *KVTxnRequest

func (*KVRequestOp) Marshal 

func (m *KVRequestOp) Marshal() (dAtA []byte, err error)

func (*KVRequestOp) MarshalTo 

func (m *KVRequestOp) MarshalTo(dAtA []byte) (int, error)

func (*KVRequestOp) MarshalToSizedBuffer 

func (m *KVRequestOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVRequestOp) ProtoMessage 

func (*KVRequestOp) ProtoMessage()

func (*KVRequestOp) Reset 

func (m *KVRequestOp) Reset()

func (*KVRequestOp) Size 

func (m *KVRequestOp) Size() (n int)

func (*KVRequestOp) String 

func (m *KVRequestOp) String() string

func (*KVRequestOp) Unmarshal 

func (m *KVRequestOp) Unmarshal(dAtA []byte) error

func (*KVRequestOp) XXX_DiscardUnknown 

func (m *KVRequestOp) XXX_DiscardUnknown()

func (*KVRequestOp) XXX_Marshal 

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

func (*KVRequestOp) XXX_Merge 

func (m *KVRequestOp) XXX_Merge(src proto.Message)

func (*KVRequestOp) XXX_OneofWrappers 

func (*KVRequestOp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KVRequestOp) XXX_Size 

func (m *KVRequestOp) XXX_Size() int

func (*KVRequestOp) XXX_Unmarshal 

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

type KVRequestOp_RequestDelete 

type KVRequestOp_RequestDelete struct {
	RequestDelete *KVDeleteRequest `protobuf:"bytes,3,opt,name=request_delete,json=requestDelete,proto3,oneof" json:"request_delete,omitempty"`
}

func (*KVRequestOp_RequestDelete) MarshalTo 

func (m *KVRequestOp_RequestDelete) MarshalTo(dAtA []byte) (int, error)

func (*KVRequestOp_RequestDelete) MarshalToSizedBuffer 

func (m *KVRequestOp_RequestDelete) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVRequestOp_RequestDelete) Size 

func (m *KVRequestOp_RequestDelete) Size() (n int)

type KVRequestOp_RequestPut 

type KVRequestOp_RequestPut struct {
	RequestPut *KVPutRequest `protobuf:"bytes,2,opt,name=request_put,json=requestPut,proto3,oneof" json:"request_put,omitempty"`
}

func (*KVRequestOp_RequestPut) MarshalTo 

func (m *KVRequestOp_RequestPut) MarshalTo(dAtA []byte) (int, error)

func (*KVRequestOp_RequestPut) MarshalToSizedBuffer 

func (m *KVRequestOp_RequestPut) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVRequestOp_RequestPut) Size 

func (m *KVRequestOp_RequestPut) Size() (n int)

type KVRequestOp_RequestQuery 

type KVRequestOp_RequestQuery struct {
	RequestQuery *KVQueryRequest `protobuf:"bytes,1,opt,name=request_query,json=requestQuery,proto3,oneof" json:"request_query,omitempty"`
}

func (*KVRequestOp_RequestQuery) MarshalTo 

func (m *KVRequestOp_RequestQuery) MarshalTo(dAtA []byte) (int, error)

func (*KVRequestOp_RequestQuery) MarshalToSizedBuffer 

func (m *KVRequestOp_RequestQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVRequestOp_RequestQuery) Size 

func (m *KVRequestOp_RequestQuery) Size() (n int)

type KVRequestOp_RequestTxn 

type KVRequestOp_RequestTxn struct {
	RequestTxn *KVTxnRequest `protobuf:"bytes,4,opt,name=request_txn,json=requestTxn,proto3,oneof" json:"request_txn,omitempty"`
}

func (*KVRequestOp_RequestTxn) MarshalTo 

func (m *KVRequestOp_RequestTxn) MarshalTo(dAtA []byte) (int, error)

func (*KVRequestOp_RequestTxn) MarshalToSizedBuffer 

func (m *KVRequestOp_RequestTxn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVRequestOp_RequestTxn) Size 

func (m *KVRequestOp_RequestTxn) Size() (n int)

type KVResponseOp 

type KVResponseOp struct {
	// response is a union of response types returned by a transaction.
	//
	// Types that are valid to be assigned to Response:
	//	*KVResponseOp_ResponseQuery
	//	*KVResponseOp_ResponsePut
	//	*KVResponseOp_ResponseDelete
	//	*KVResponseOp_ResponseTxn
	Response isKVResponseOp_Response `protobuf_oneof:"response"`
}

func (*KVResponseOp) Descriptor 

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

func (*KVResponseOp) GetResponse 

func (m *KVResponseOp) GetResponse() isKVResponseOp_Response

func (*KVResponseOp) GetResponseDelete 

func (m *KVResponseOp) GetResponseDelete() *KVDeleteResponse

func (*KVResponseOp) GetResponsePut 

func (m *KVResponseOp) GetResponsePut() *KVPutResponse

func (*KVResponseOp) GetResponseQuery 

func (m *KVResponseOp) GetResponseQuery() *KVQueryResponse

func (*KVResponseOp) GetResponseTxn 

func (m *KVResponseOp) GetResponseTxn() *KVTxnResponse

func (*KVResponseOp) Marshal 

func (m *KVResponseOp) Marshal() (dAtA []byte, err error)

func (*KVResponseOp) MarshalTo 

func (m *KVResponseOp) MarshalTo(dAtA []byte) (int, error)

func (*KVResponseOp) MarshalToSizedBuffer 

func (m *KVResponseOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVResponseOp) ProtoMessage 

func (*KVResponseOp) ProtoMessage()

func (*KVResponseOp) Reset 

func (m *KVResponseOp) Reset()

func (*KVResponseOp) Size 

func (m *KVResponseOp) Size() (n int)

func (*KVResponseOp) String 

func (m *KVResponseOp) String() string

func (*KVResponseOp) Unmarshal 

func (m *KVResponseOp) Unmarshal(dAtA []byte) error

func (*KVResponseOp) XXX_DiscardUnknown 

func (m *KVResponseOp) XXX_DiscardUnknown()

func (*KVResponseOp) XXX_Marshal 

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

func (*KVResponseOp) XXX_Merge 

func (m *KVResponseOp) XXX_Merge(src proto.Message)

func (*KVResponseOp) XXX_OneofWrappers 

func (*KVResponseOp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KVResponseOp) XXX_Size 

func (m *KVResponseOp) XXX_Size() int

func (*KVResponseOp) XXX_Unmarshal 

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

type KVResponseOp_ResponseDelete 

type KVResponseOp_ResponseDelete struct {
	ResponseDelete *KVDeleteResponse `protobuf:"bytes,3,opt,name=response_delete,json=responseDelete,proto3,oneof" json:"response_delete,omitempty"`
}

func (*KVResponseOp_ResponseDelete) MarshalTo 

func (m *KVResponseOp_ResponseDelete) MarshalTo(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseDelete) MarshalToSizedBuffer 

func (m *KVResponseOp_ResponseDelete) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseDelete) Size 

func (m *KVResponseOp_ResponseDelete) Size() (n int)

type KVResponseOp_ResponsePut 

type KVResponseOp_ResponsePut struct {
	ResponsePut *KVPutResponse `protobuf:"bytes,2,opt,name=response_put,json=responsePut,proto3,oneof" json:"response_put,omitempty"`
}

func (*KVResponseOp_ResponsePut) MarshalTo 

func (m *KVResponseOp_ResponsePut) MarshalTo(dAtA []byte) (int, error)

func (*KVResponseOp_ResponsePut) MarshalToSizedBuffer 

func (m *KVResponseOp_ResponsePut) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVResponseOp_ResponsePut) Size 

func (m *KVResponseOp_ResponsePut) Size() (n int)

type KVResponseOp_ResponseQuery 

type KVResponseOp_ResponseQuery struct {
	ResponseQuery *KVQueryResponse `protobuf:"bytes,1,opt,name=response_query,json=responseQuery,proto3,oneof" json:"response_query,omitempty"`
}

func (*KVResponseOp_ResponseQuery) MarshalTo 

func (m *KVResponseOp_ResponseQuery) MarshalTo(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseQuery) MarshalToSizedBuffer 

func (m *KVResponseOp_ResponseQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseQuery) Size 

func (m *KVResponseOp_ResponseQuery) Size() (n int)

type KVResponseOp_ResponseTxn 

type KVResponseOp_ResponseTxn struct {
	ResponseTxn *KVTxnResponse `protobuf:"bytes,4,opt,name=response_txn,json=responseTxn,proto3,oneof" json:"response_txn,omitempty"`
}

func (*KVResponseOp_ResponseTxn) MarshalTo 

func (m *KVResponseOp_ResponseTxn) MarshalTo(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseTxn) MarshalToSizedBuffer 

func (m *KVResponseOp_ResponseTxn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVResponseOp_ResponseTxn) Size 

func (m *KVResponseOp_ResponseTxn) Size() (n int)

type KVServer 

type KVServer interface {
	// Query retrieves kvs from a partition
	Query(context.Context, *KVQueryRequest) (*KVQueryResponse, error)
	// Txn processes multiple requests in a single transaction.
	// A txn request increments the revision of the key-value store
	// and generates events with the same revision for every completed request.
	Txn(context.Context, *KVTxnRequest) (*KVTxnResponse, error)
	// Compact compacts the event history in the key-value store. The key-value
	// store should be periodically compacted or the event history will continue to grow
	// indefinitely.
	Compact(context.Context, *KVCompactionRequest) (*KVCompactionResponse, error)
	// Watch creates a watcher to watch for events happening or that have happened.
	// The entire event history can be watched starting from the last compaction revision.
	Watch(*KVWatchRequest, KV_WatchServer) error
}

KVServer is the server API for KV service.

type KVTxnRequest 

type KVTxnRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// conditions is a list of predicates representing a conjunction of terms.
	// If all conditions are true, then the success requests will be processed in order,
	// and the response will contain their respective responses in order.
	// If one or more conditions are false, then the failure requests will be processed in order,
	// and the response will contain their respective responses in order.
	Conditions []Condition `protobuf:"bytes,2,rep,name=conditions,proto3" json:"conditions"`
	// success is a list of requests which will be applied when compare evaluates to true.
	Success []KVRequestOp `protobuf:"bytes,3,rep,name=success,proto3" json:"success"`
	// failure is a list of requests which will be applied when compare evaluates to false.
	Failure []KVRequestOp `protobuf:"bytes,4,rep,name=failure,proto3" json:"failure"`
}

func (*KVTxnRequest) Descriptor 

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

func (*KVTxnRequest) Marshal 

func (m *KVTxnRequest) Marshal() (dAtA []byte, err error)

func (*KVTxnRequest) MarshalTo 

func (m *KVTxnRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVTxnRequest) MarshalToSizedBuffer 

func (m *KVTxnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVTxnRequest) ProtoMessage 

func (*KVTxnRequest) ProtoMessage()

func (*KVTxnRequest) Reset 

func (m *KVTxnRequest) Reset()

func (*KVTxnRequest) Size 

func (m *KVTxnRequest) Size() (n int)

func (*KVTxnRequest) String 

func (m *KVTxnRequest) String() string

func (*KVTxnRequest) Unmarshal 

func (m *KVTxnRequest) Unmarshal(dAtA []byte) error

func (*KVTxnRequest) XXX_DiscardUnknown 

func (m *KVTxnRequest) XXX_DiscardUnknown()

func (*KVTxnRequest) XXX_Marshal 

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

func (*KVTxnRequest) XXX_Merge 

func (m *KVTxnRequest) XXX_Merge(src proto.Message)

func (*KVTxnRequest) XXX_Size 

func (m *KVTxnRequest) XXX_Size() int

func (*KVTxnRequest) XXX_Unmarshal 

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

type KVTxnResponse 

type KVTxnResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// succeeded is set to true if the compare evaluated to true or false otherwise.
	Succeeded bool `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	// responses is a list of responses corresponding to the results from applying
	// success if succeeded is true or failure if succeeded is false.
	Responses []KVResponseOp `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses"`
}

func (*KVTxnResponse) Descriptor 

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

func (*KVTxnResponse) Marshal 

func (m *KVTxnResponse) Marshal() (dAtA []byte, err error)

func (*KVTxnResponse) MarshalTo 

func (m *KVTxnResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVTxnResponse) MarshalToSizedBuffer 

func (m *KVTxnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVTxnResponse) ProtoMessage 

func (*KVTxnResponse) ProtoMessage()

func (*KVTxnResponse) Reset 

func (m *KVTxnResponse) Reset()

func (*KVTxnResponse) Size 

func (m *KVTxnResponse) Size() (n int)

func (*KVTxnResponse) String 

func (m *KVTxnResponse) String() string

func (*KVTxnResponse) Unmarshal 

func (m *KVTxnResponse) Unmarshal(dAtA []byte) error

func (*KVTxnResponse) XXX_DiscardUnknown 

func (m *KVTxnResponse) XXX_DiscardUnknown()

func (*KVTxnResponse) XXX_Marshal 

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

func (*KVTxnResponse) XXX_Merge 

func (m *KVTxnResponse) XXX_Merge(src proto.Message)

func (*KVTxnResponse) XXX_Size 

func (m *KVTxnResponse) XXX_Size() int

func (*KVTxnResponse) XXX_Unmarshal 

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

type KVWatchCursor 

type KVWatchCursor struct {
	Revision int64  `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
	Key      []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*KVWatchCursor) Descriptor 

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

func (*KVWatchCursor) Marshal 

func (m *KVWatchCursor) Marshal() (dAtA []byte, err error)

func (*KVWatchCursor) MarshalTo 

func (m *KVWatchCursor) MarshalTo(dAtA []byte) (int, error)

func (*KVWatchCursor) MarshalToSizedBuffer 

func (m *KVWatchCursor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVWatchCursor) ProtoMessage 

func (*KVWatchCursor) ProtoMessage()

func (*KVWatchCursor) Reset 

func (m *KVWatchCursor) Reset()

func (*KVWatchCursor) Size 

func (m *KVWatchCursor) Size() (n int)

func (*KVWatchCursor) String 

func (m *KVWatchCursor) String() string

func (*KVWatchCursor) Unmarshal 

func (m *KVWatchCursor) Unmarshal(dAtA []byte) error

func (*KVWatchCursor) XXX_DiscardUnknown 

func (m *KVWatchCursor) XXX_DiscardUnknown()

func (*KVWatchCursor) XXX_Marshal 

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

func (*KVWatchCursor) XXX_Merge 

func (m *KVWatchCursor) XXX_Merge(src proto.Message)

func (*KVWatchCursor) XXX_Size 

func (m *KVWatchCursor) XXX_Size() int

func (*KVWatchCursor) XXX_Unmarshal 

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

type KVWatchRequest 

type KVWatchRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// start is an optional cursor to watch from (exclusive). No start is "now".
	Start KVWatchCursor `protobuf:"bytes,2,opt,name=start,proto3" json:"start"`
	// Selection of keys to watch
	Keys KeyRange `protobuf:"bytes,3,opt,name=keys,proto3" json:"keys"`
	// progress_notify is set so that the ptarmigan server will periodically send a WatchResponse with
	// no events to the new watcher if there are no recent events. It is useful when clients
	// wish to recover a disconnected watcher starting from a recent known revision.
	// The ptarmigan server may decide how often it will send notifications based on current load.
	ProgressNotify bool `protobuf:"varint,4,opt,name=progress_notify,json=progressNotify,proto3" json:"progress_notify,omitempty"`
	// filter out put events.
	NoPut bool `protobuf:"varint,5,opt,name=no_put,json=noPut,proto3" json:"no_put,omitempty"`
	// filter out delete event.
	NoDelete bool `protobuf:"varint,6,opt,name=no_delete,json=noDelete,proto3" json:"no_delete,omitempty"`
	// If prev_kv is set, created watcher gets the previous KV before the event happens.
	// If the previous KV is already compacted, nothing will be returned.
	PrevKv bool `protobuf:"varint,7,opt,name=prev_kv,json=prevKv,proto3" json:"prev_kv,omitempty"`
}

func (*KVWatchRequest) Descriptor 

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

func (*KVWatchRequest) Marshal 

func (m *KVWatchRequest) Marshal() (dAtA []byte, err error)

func (*KVWatchRequest) MarshalTo 

func (m *KVWatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*KVWatchRequest) MarshalToSizedBuffer 

func (m *KVWatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVWatchRequest) ProtoMessage 

func (*KVWatchRequest) ProtoMessage()

func (*KVWatchRequest) Reset 

func (m *KVWatchRequest) Reset()

func (*KVWatchRequest) Size 

func (m *KVWatchRequest) Size() (n int)

func (*KVWatchRequest) String 

func (m *KVWatchRequest) String() string

func (*KVWatchRequest) Unmarshal 

func (m *KVWatchRequest) Unmarshal(dAtA []byte) error

func (*KVWatchRequest) XXX_DiscardUnknown 

func (m *KVWatchRequest) XXX_DiscardUnknown()

func (*KVWatchRequest) XXX_Marshal 

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

func (*KVWatchRequest) XXX_Merge 

func (m *KVWatchRequest) XXX_Merge(src proto.Message)

func (*KVWatchRequest) XXX_Size 

func (m *KVWatchRequest) XXX_Size() int

func (*KVWatchRequest) XXX_Unmarshal 

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

type KVWatchResponse 

type KVWatchResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// Indicates that the watch request tried watching from a
	// compacted revision. The client should treat the watcher
	// as canceled and should not try to create any watcher with
	// the same start again.
	Compacted bool `protobuf:"varint,2,opt,name=compacted,proto3" json:"compacted,omitempty"`
	// cancel_reason indicates the reason for canceling the watcher.
	CancelReason string `protobuf:"bytes,3,opt,name=cancel_reason,json=cancelReason,proto3" json:"cancel_reason,omitempty"`
	// Watchers should keep track of the latest after cursor
	// so that they can resume where they left off with a
	// subsequent watch request. If the last watch request
	// was canceled due to compaction this cursor is not valid
	// Use of an after cursor from a compacted revision will
	// result in another canceled watch request.
	After KVWatchCursor `protobuf:"bytes,4,opt,name=after,proto3" json:"after"`
	// Events contains a list of events ordered by
	// by [revision,key]. There may be events from several different
	// revisions in the events list, but events from older revisions
	// will appear first.
	Events []Event `protobuf:"bytes,11,rep,name=events,proto3" json:"events"`
}

func (*KVWatchResponse) Descriptor 

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

func (*KVWatchResponse) Marshal 

func (m *KVWatchResponse) Marshal() (dAtA []byte, err error)

func (*KVWatchResponse) MarshalTo 

func (m *KVWatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*KVWatchResponse) MarshalToSizedBuffer 

func (m *KVWatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KVWatchResponse) ProtoMessage 

func (*KVWatchResponse) ProtoMessage()

func (*KVWatchResponse) Reset 

func (m *KVWatchResponse) Reset()

func (*KVWatchResponse) Size 

func (m *KVWatchResponse) Size() (n int)

func (*KVWatchResponse) String 

func (m *KVWatchResponse) String() string

func (*KVWatchResponse) Unmarshal 

func (m *KVWatchResponse) Unmarshal(dAtA []byte) error

func (*KVWatchResponse) XXX_DiscardUnknown 

func (m *KVWatchResponse) XXX_DiscardUnknown()

func (*KVWatchResponse) XXX_Marshal 

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

func (*KVWatchResponse) XXX_Merge 

func (m *KVWatchResponse) XXX_Merge(src proto.Message)

func (*KVWatchResponse) XXX_Size 

func (m *KVWatchResponse) XXX_Size() int

func (*KVWatchResponse) XXX_Unmarshal 

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

type KV_WatchClient 

type KV_WatchClient interface {
	Recv() (*KVWatchResponse, error)
	grpc.ClientStream
}

type KV_WatchServer 

type KV_WatchServer interface {
	Send(*KVWatchResponse) error
	grpc.ServerStream
}

type KeyRange 

type KeyRange struct {
	// Key must be > or >= this value
	//
	// Types that are valid to be assigned to KeyRangeMin:
	//	*KeyRange_KeyGt
	//	*KeyRange_KeyGte
	KeyRangeMin isKeyRange_KeyRangeMin `protobuf_oneof:"key_range_min"`
	// Key must be < or <= this value
	//
	// Types that are valid to be assigned to KeyRangeMax:
	//	*KeyRange_KeyLt
	//	*KeyRange_KeyLte
	KeyRangeMax isKeyRange_KeyRangeMax `protobuf_oneof:"key_range_max"`
	// Key must be prefixed with this value
	KeyStartsWith []byte `protobuf:"bytes,64,opt,name=key_starts_with,json=keyStartsWith,proto3" json:"key_starts_with,omitempty"`
	// Key must equal this value
	Key []byte `protobuf:"bytes,65,opt,name=key,proto3" json:"key,omitempty"`
}

func (*KeyRange) Descriptor 

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

func (*KeyRange) GetKeyGt 

func (m *KeyRange) GetKeyGt() []byte

func (*KeyRange) GetKeyGte 

func (m *KeyRange) GetKeyGte() []byte

func (*KeyRange) GetKeyLt 

func (m *KeyRange) GetKeyLt() []byte

func (*KeyRange) GetKeyLte 

func (m *KeyRange) GetKeyLte() []byte

func (*KeyRange) GetKeyRangeMax 

func (m *KeyRange) GetKeyRangeMax() isKeyRange_KeyRangeMax

func (*KeyRange) GetKeyRangeMin 

func (m *KeyRange) GetKeyRangeMin() isKeyRange_KeyRangeMin

func (*KeyRange) Marshal 

func (m *KeyRange) Marshal() (dAtA []byte, err error)

func (*KeyRange) MarshalTo 

func (m *KeyRange) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange) MarshalToSizedBuffer 

func (m *KeyRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset 

func (m *KeyRange) Reset()

func (*KeyRange) Size 

func (m *KeyRange) Size() (n int)

func (*KeyRange) String 

func (m *KeyRange) String() string

func (*KeyRange) Unmarshal 

func (m *KeyRange) Unmarshal(dAtA []byte) error

func (*KeyRange) XXX_DiscardUnknown 

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal 

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

func (*KeyRange) XXX_Merge 

func (m *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_OneofWrappers 

func (*KeyRange) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*KeyRange) XXX_Size 

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal 

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

type KeyRange_KeyGt 

type KeyRange_KeyGt struct {
	KeyGt []byte `protobuf:"bytes,1,opt,name=key_gt,json=keyGt,proto3,oneof" json:"key_gt,omitempty"`
}

func (*KeyRange_KeyGt) MarshalTo 

func (m *KeyRange_KeyGt) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange_KeyGt) MarshalToSizedBuffer 

func (m *KeyRange_KeyGt) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange_KeyGt) Size 

func (m *KeyRange_KeyGt) Size() (n int)

type KeyRange_KeyGte 

type KeyRange_KeyGte struct {
	KeyGte []byte `protobuf:"bytes,2,opt,name=key_gte,json=keyGte,proto3,oneof" json:"key_gte,omitempty"`
}

func (*KeyRange_KeyGte) MarshalTo 

func (m *KeyRange_KeyGte) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange_KeyGte) MarshalToSizedBuffer 

func (m *KeyRange_KeyGte) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange_KeyGte) Size 

func (m *KeyRange_KeyGte) Size() (n int)

type KeyRange_KeyLt 

type KeyRange_KeyLt struct {
	KeyLt []byte `protobuf:"bytes,3,opt,name=key_lt,json=keyLt,proto3,oneof" json:"key_lt,omitempty"`
}

func (*KeyRange_KeyLt) MarshalTo 

func (m *KeyRange_KeyLt) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange_KeyLt) MarshalToSizedBuffer 

func (m *KeyRange_KeyLt) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange_KeyLt) Size 

func (m *KeyRange_KeyLt) Size() (n int)

type KeyRange_KeyLte 

type KeyRange_KeyLte struct {
	KeyLte []byte `protobuf:"bytes,4,opt,name=key_lte,json=keyLte,proto3,oneof" json:"key_lte,omitempty"`
}

func (*KeyRange_KeyLte) MarshalTo 

func (m *KeyRange_KeyLte) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange_KeyLte) MarshalToSizedBuffer 

func (m *KeyRange_KeyLte) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange_KeyLte) Size 

func (m *KeyRange_KeyLte) Size() (n int)

type KeyValue 

type KeyValue struct {
	// key is the key in bytes. An empty key is not allowed.
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// create_revision is the revision of last creation on this key.
	CreateRevision int64 `protobuf:"varint,2,opt,name=create_revision,json=createRevision,proto3" json:"create_revision,omitempty"`
	// mod_revision is the revision of last modification on this key.
	ModRevision int64 `protobuf:"varint,3,opt,name=mod_revision,json=modRevision,proto3" json:"mod_revision,omitempty"`
	// version is the version of the key. A deletion resets
	// the version to zero and any modification of the key
	// increases its version.
	Version int64 `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	// value is the value held by the key, in bytes.
	Value []byte `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	// lease is the ID of the lease that attached to key.
	// When the attached lease expires, the key will be deleted.
	// If lease is 0, then no lease is attached to the key.
	Lease int64 `protobuf:"varint,6,opt,name=lease,proto3" json:"lease,omitempty"`
}

func (*KeyValue) Descriptor 

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

func (*KeyValue) Marshal 

func (m *KeyValue) Marshal() (dAtA []byte, err error)

func (*KeyValue) MarshalTo 

func (m *KeyValue) MarshalTo(dAtA []byte) (int, error)

func (*KeyValue) MarshalToSizedBuffer 

func (m *KeyValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) Reset 

func (m *KeyValue) Reset()

func (*KeyValue) Size 

func (m *KeyValue) Size() (n int)

func (*KeyValue) String 

func (m *KeyValue) String() string

func (*KeyValue) Unmarshal 

func (m *KeyValue) Unmarshal(dAtA []byte) error

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 (m *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 Lease 

type Lease struct {
	// ID is the lease ID
	ID int64 `protobuf:"varint,2,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
	// TTL is the remaining TTL in seconds for the lease; the lease will expire in under TTL+1 seconds.
	TTL int64 `protobuf:"varint,3,opt,name=TTL,json=tTL,proto3" json:"TTL,omitempty"`
	// GrantedTTL is the initial granted time in seconds upon lease creation/renewal.
	GrantedTTL int64 `protobuf:"varint,4,opt,name=grantedTTL,proto3" json:"grantedTTL,omitempty"`
}

func (*Lease) Descriptor 

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

func (*Lease) Marshal 

func (m *Lease) Marshal() (dAtA []byte, err error)

func (*Lease) MarshalTo 

func (m *Lease) MarshalTo(dAtA []byte) (int, error)

func (*Lease) MarshalToSizedBuffer 

func (m *Lease) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Lease) ProtoMessage 

func (*Lease) ProtoMessage()

func (*Lease) Reset 

func (m *Lease) Reset()

func (*Lease) Size 

func (m *Lease) Size() (n int)

func (*Lease) String 

func (m *Lease) String() string

func (*Lease) Unmarshal 

func (m *Lease) Unmarshal(dAtA []byte) error

func (*Lease) XXX_DiscardUnknown 

func (m *Lease) XXX_DiscardUnknown()

func (*Lease) XXX_Marshal 

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

func (*Lease) XXX_Merge 

func (m *Lease) XXX_Merge(src proto.Message)

func (*Lease) XXX_Size 

func (m *Lease) XXX_Size() int

func (*Lease) XXX_Unmarshal 

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

type LeaseGetRequest 

type LeaseGetRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// ID is the lease ID for the lease.
	ID int64 `protobuf:"varint,2,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
}

func (*LeaseGetRequest) Descriptor 

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

func (*LeaseGetRequest) Marshal 

func (m *LeaseGetRequest) Marshal() (dAtA []byte, err error)

func (*LeaseGetRequest) MarshalTo 

func (m *LeaseGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGetRequest) MarshalToSizedBuffer 

func (m *LeaseGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseGetRequest) ProtoMessage 

func (*LeaseGetRequest) ProtoMessage()

func (*LeaseGetRequest) Reset 

func (m *LeaseGetRequest) Reset()

func (*LeaseGetRequest) Size 

func (m *LeaseGetRequest) Size() (n int)

func (*LeaseGetRequest) String 

func (m *LeaseGetRequest) String() string

func (*LeaseGetRequest) Unmarshal 

func (m *LeaseGetRequest) Unmarshal(dAtA []byte) error

func (*LeaseGetRequest) XXX_DiscardUnknown 

func (m *LeaseGetRequest) XXX_DiscardUnknown()

func (*LeaseGetRequest) XXX_Marshal 

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

func (*LeaseGetRequest) XXX_Merge 

func (m *LeaseGetRequest) XXX_Merge(src proto.Message)

func (*LeaseGetRequest) XXX_Size 

func (m *LeaseGetRequest) XXX_Size() int

func (*LeaseGetRequest) XXX_Unmarshal 

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

type LeaseGetResponse 

type LeaseGetResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Lease  Lease          `protobuf:"bytes,2,opt,name=lease,proto3" json:"lease"`
}

func (*LeaseGetResponse) Descriptor 

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

func (*LeaseGetResponse) Marshal 

func (m *LeaseGetResponse) Marshal() (dAtA []byte, err error)

func (*LeaseGetResponse) MarshalTo 

func (m *LeaseGetResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGetResponse) MarshalToSizedBuffer 

func (m *LeaseGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseGetResponse) ProtoMessage 

func (*LeaseGetResponse) ProtoMessage()

func (*LeaseGetResponse) Reset 

func (m *LeaseGetResponse) Reset()

func (*LeaseGetResponse) Size 

func (m *LeaseGetResponse) Size() (n int)

func (*LeaseGetResponse) String 

func (m *LeaseGetResponse) String() string

func (*LeaseGetResponse) Unmarshal 

func (m *LeaseGetResponse) Unmarshal(dAtA []byte) error

func (*LeaseGetResponse) XXX_DiscardUnknown 

func (m *LeaseGetResponse) XXX_DiscardUnknown()

func (*LeaseGetResponse) XXX_Marshal 

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

func (*LeaseGetResponse) XXX_Merge 

func (m *LeaseGetResponse) XXX_Merge(src proto.Message)

func (*LeaseGetResponse) XXX_Size 

func (m *LeaseGetResponse) XXX_Size() int

func (*LeaseGetResponse) XXX_Unmarshal 

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

type LeaseGrantRequest 

type LeaseGrantRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// TTL is the advisory time-to-live in seconds. Expired lease will return -1.
	TTL int64 `protobuf:"varint,2,opt,name=TTL,json=tTL,proto3" json:"TTL,omitempty"`
}

func (*LeaseGrantRequest) Descriptor 

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

func (*LeaseGrantRequest) Marshal 

func (m *LeaseGrantRequest) Marshal() (dAtA []byte, err error)

func (*LeaseGrantRequest) MarshalTo 

func (m *LeaseGrantRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGrantRequest) MarshalToSizedBuffer 

func (m *LeaseGrantRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseGrantRequest) ProtoMessage 

func (*LeaseGrantRequest) ProtoMessage()

func (*LeaseGrantRequest) Reset 

func (m *LeaseGrantRequest) Reset()

func (*LeaseGrantRequest) Size 

func (m *LeaseGrantRequest) Size() (n int)

func (*LeaseGrantRequest) String 

func (m *LeaseGrantRequest) String() string

func (*LeaseGrantRequest) Unmarshal 

func (m *LeaseGrantRequest) Unmarshal(dAtA []byte) error

func (*LeaseGrantRequest) XXX_DiscardUnknown 

func (m *LeaseGrantRequest) XXX_DiscardUnknown()

func (*LeaseGrantRequest) XXX_Marshal 

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

func (*LeaseGrantRequest) XXX_Merge 

func (m *LeaseGrantRequest) XXX_Merge(src proto.Message)

func (*LeaseGrantRequest) XXX_Size 

func (m *LeaseGrantRequest) XXX_Size() int

func (*LeaseGrantRequest) XXX_Unmarshal 

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

type LeaseGrantResponse 

type LeaseGrantResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Lease  Lease          `protobuf:"bytes,2,opt,name=lease,proto3" json:"lease"`
}

func (*LeaseGrantResponse) Descriptor 

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

func (*LeaseGrantResponse) Marshal 

func (m *LeaseGrantResponse) Marshal() (dAtA []byte, err error)

func (*LeaseGrantResponse) MarshalTo 

func (m *LeaseGrantResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseGrantResponse) MarshalToSizedBuffer 

func (m *LeaseGrantResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseGrantResponse) ProtoMessage 

func (*LeaseGrantResponse) ProtoMessage()

func (*LeaseGrantResponse) Reset 

func (m *LeaseGrantResponse) Reset()

func (*LeaseGrantResponse) Size 

func (m *LeaseGrantResponse) Size() (n int)

func (*LeaseGrantResponse) String 

func (m *LeaseGrantResponse) String() string

func (*LeaseGrantResponse) Unmarshal 

func (m *LeaseGrantResponse) Unmarshal(dAtA []byte) error

func (*LeaseGrantResponse) XXX_DiscardUnknown 

func (m *LeaseGrantResponse) XXX_DiscardUnknown()

func (*LeaseGrantResponse) XXX_Marshal 

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

func (*LeaseGrantResponse) XXX_Merge 

func (m *LeaseGrantResponse) XXX_Merge(src proto.Message)

func (*LeaseGrantResponse) XXX_Size 

func (m *LeaseGrantResponse) XXX_Size() int

func (*LeaseGrantResponse) XXX_Unmarshal 

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

type LeaseQueryRequest 

type LeaseQueryRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
}

func (*LeaseQueryRequest) Descriptor 

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

func (*LeaseQueryRequest) Marshal 

func (m *LeaseQueryRequest) Marshal() (dAtA []byte, err error)

func (*LeaseQueryRequest) MarshalTo 

func (m *LeaseQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseQueryRequest) MarshalToSizedBuffer 

func (m *LeaseQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseQueryRequest) ProtoMessage 

func (*LeaseQueryRequest) ProtoMessage()

func (*LeaseQueryRequest) Reset 

func (m *LeaseQueryRequest) Reset()

func (*LeaseQueryRequest) Size 

func (m *LeaseQueryRequest) Size() (n int)

func (*LeaseQueryRequest) String 

func (m *LeaseQueryRequest) String() string

func (*LeaseQueryRequest) Unmarshal 

func (m *LeaseQueryRequest) Unmarshal(dAtA []byte) error

func (*LeaseQueryRequest) XXX_DiscardUnknown 

func (m *LeaseQueryRequest) XXX_DiscardUnknown()

func (*LeaseQueryRequest) XXX_Marshal 

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

func (*LeaseQueryRequest) XXX_Merge 

func (m *LeaseQueryRequest) XXX_Merge(src proto.Message)

func (*LeaseQueryRequest) XXX_Size 

func (m *LeaseQueryRequest) XXX_Size() int

func (*LeaseQueryRequest) XXX_Unmarshal 

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

type LeaseQueryResponse 

type LeaseQueryResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Leases []Lease        `protobuf:"bytes,2,rep,name=leases,proto3" json:"leases"`
}

func (*LeaseQueryResponse) Descriptor 

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

func (*LeaseQueryResponse) Marshal 

func (m *LeaseQueryResponse) Marshal() (dAtA []byte, err error)

func (*LeaseQueryResponse) MarshalTo 

func (m *LeaseQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseQueryResponse) MarshalToSizedBuffer 

func (m *LeaseQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseQueryResponse) ProtoMessage 

func (*LeaseQueryResponse) ProtoMessage()

func (*LeaseQueryResponse) Reset 

func (m *LeaseQueryResponse) Reset()

func (*LeaseQueryResponse) Size 

func (m *LeaseQueryResponse) Size() (n int)

func (*LeaseQueryResponse) String 

func (m *LeaseQueryResponse) String() string

func (*LeaseQueryResponse) Unmarshal 

func (m *LeaseQueryResponse) Unmarshal(dAtA []byte) error

func (*LeaseQueryResponse) XXX_DiscardUnknown 

func (m *LeaseQueryResponse) XXX_DiscardUnknown()

func (*LeaseQueryResponse) XXX_Marshal 

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

func (*LeaseQueryResponse) XXX_Merge 

func (m *LeaseQueryResponse) XXX_Merge(src proto.Message)

func (*LeaseQueryResponse) XXX_Size 

func (m *LeaseQueryResponse) XXX_Size() int

func (*LeaseQueryResponse) XXX_Unmarshal 

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

type LeaseRenewRequest 

type LeaseRenewRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// ID is the lease ID for the lease to keep alive.
	ID int64 `protobuf:"varint,2,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
}

func (*LeaseRenewRequest) Descriptor 

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

func (*LeaseRenewRequest) Marshal 

func (m *LeaseRenewRequest) Marshal() (dAtA []byte, err error)

func (*LeaseRenewRequest) MarshalTo 

func (m *LeaseRenewRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRenewRequest) MarshalToSizedBuffer 

func (m *LeaseRenewRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseRenewRequest) ProtoMessage 

func (*LeaseRenewRequest) ProtoMessage()

func (*LeaseRenewRequest) Reset 

func (m *LeaseRenewRequest) Reset()

func (*LeaseRenewRequest) Size 

func (m *LeaseRenewRequest) Size() (n int)

func (*LeaseRenewRequest) String 

func (m *LeaseRenewRequest) String() string

func (*LeaseRenewRequest) Unmarshal 

func (m *LeaseRenewRequest) Unmarshal(dAtA []byte) error

func (*LeaseRenewRequest) XXX_DiscardUnknown 

func (m *LeaseRenewRequest) XXX_DiscardUnknown()

func (*LeaseRenewRequest) XXX_Marshal 

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

func (*LeaseRenewRequest) XXX_Merge 

func (m *LeaseRenewRequest) XXX_Merge(src proto.Message)

func (*LeaseRenewRequest) XXX_Size 

func (m *LeaseRenewRequest) XXX_Size() int

func (*LeaseRenewRequest) XXX_Unmarshal 

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

type LeaseRenewResponse 

type LeaseRenewResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Lease  Lease          `protobuf:"bytes,2,opt,name=lease,proto3" json:"lease"`
}

func (*LeaseRenewResponse) Descriptor 

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

func (*LeaseRenewResponse) Marshal 

func (m *LeaseRenewResponse) Marshal() (dAtA []byte, err error)

func (*LeaseRenewResponse) MarshalTo 

func (m *LeaseRenewResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRenewResponse) MarshalToSizedBuffer 

func (m *LeaseRenewResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseRenewResponse) ProtoMessage 

func (*LeaseRenewResponse) ProtoMessage()

func (*LeaseRenewResponse) Reset 

func (m *LeaseRenewResponse) Reset()

func (*LeaseRenewResponse) Size 

func (m *LeaseRenewResponse) Size() (n int)

func (*LeaseRenewResponse) String 

func (m *LeaseRenewResponse) String() string

func (*LeaseRenewResponse) Unmarshal 

func (m *LeaseRenewResponse) Unmarshal(dAtA []byte) error

func (*LeaseRenewResponse) XXX_DiscardUnknown 

func (m *LeaseRenewResponse) XXX_DiscardUnknown()

func (*LeaseRenewResponse) XXX_Marshal 

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

func (*LeaseRenewResponse) XXX_Merge 

func (m *LeaseRenewResponse) XXX_Merge(src proto.Message)

func (*LeaseRenewResponse) XXX_Size 

func (m *LeaseRenewResponse) XXX_Size() int

func (*LeaseRenewResponse) XXX_Unmarshal 

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

type LeaseRevokeRequest 

type LeaseRevokeRequest struct {
	Header PartitionRequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	// ID is the lease ID to revoke. When the ID is revoked, all associated keys will be deleted.
	ID int64 `protobuf:"varint,2,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
}

func (*LeaseRevokeRequest) Descriptor 

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

func (*LeaseRevokeRequest) Marshal 

func (m *LeaseRevokeRequest) Marshal() (dAtA []byte, err error)

func (*LeaseRevokeRequest) MarshalTo 

func (m *LeaseRevokeRequest) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRevokeRequest) MarshalToSizedBuffer 

func (m *LeaseRevokeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseRevokeRequest) ProtoMessage 

func (*LeaseRevokeRequest) ProtoMessage()

func (*LeaseRevokeRequest) Reset 

func (m *LeaseRevokeRequest) Reset()

func (*LeaseRevokeRequest) Size 

func (m *LeaseRevokeRequest) Size() (n int)

func (*LeaseRevokeRequest) String 

func (m *LeaseRevokeRequest) String() string

func (*LeaseRevokeRequest) Unmarshal 

func (m *LeaseRevokeRequest) Unmarshal(dAtA []byte) error

func (*LeaseRevokeRequest) XXX_DiscardUnknown 

func (m *LeaseRevokeRequest) XXX_DiscardUnknown()

func (*LeaseRevokeRequest) XXX_Marshal 

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

func (*LeaseRevokeRequest) XXX_Merge 

func (m *LeaseRevokeRequest) XXX_Merge(src proto.Message)

func (*LeaseRevokeRequest) XXX_Size 

func (m *LeaseRevokeRequest) XXX_Size() int

func (*LeaseRevokeRequest) XXX_Unmarshal 

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

type LeaseRevokeResponse 

type LeaseRevokeResponse struct {
	Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
}

func (*LeaseRevokeResponse) Descriptor 

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

func (*LeaseRevokeResponse) Marshal 

func (m *LeaseRevokeResponse) Marshal() (dAtA []byte, err error)

func (*LeaseRevokeResponse) MarshalTo 

func (m *LeaseRevokeResponse) MarshalTo(dAtA []byte) (int, error)

func (*LeaseRevokeResponse) MarshalToSizedBuffer 

func (m *LeaseRevokeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LeaseRevokeResponse) ProtoMessage 

func (*LeaseRevokeResponse) ProtoMessage()

func (*LeaseRevokeResponse) Reset 

func (m *LeaseRevokeResponse) Reset()

func (*LeaseRevokeResponse) Size 

func (m *LeaseRevokeResponse) Size() (n int)

func (*LeaseRevokeResponse) String 

func (m *LeaseRevokeResponse) String() string

func (*LeaseRevokeResponse) Unmarshal 

func (m *LeaseRevokeResponse) Unmarshal(dAtA []byte) error

func (*LeaseRevokeResponse) XXX_DiscardUnknown 

func (m *LeaseRevokeResponse) XXX_DiscardUnknown()

func (*LeaseRevokeResponse) XXX_Marshal 

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

func (*LeaseRevokeResponse) XXX_Merge 

func (m *LeaseRevokeResponse) XXX_Merge(src proto.Message)

func (*LeaseRevokeResponse) XXX_Size 

func (m *LeaseRevokeResponse) XXX_Size() int

func (*LeaseRevokeResponse) XXX_Unmarshal 

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

type LeasesClient 

type LeasesClient interface {
	// Grant creates a lease which expires if the server does not receive a renewal
	// within a given time to live period. All keys attached to the lease will be expired and
	// deleted if the lease expires. Each expired key generates a delete event in the event history.
	Grant(ctx context.Context, in *LeaseGrantRequest, opts ...grpc.CallOption) (*LeaseGrantResponse, error)
	Query(ctx context.Context, in *LeaseQueryRequest, opts ...grpc.CallOption) (*LeaseQueryResponse, error)
	// Get retrieves information on a lease.
	Get(ctx context.Context, in *LeaseGetRequest, opts ...grpc.CallOption) (*LeaseGetResponse, error)
	// Revoke revokes a lease. All keys attached to the lease will expire and be deleted.
	Revoke(ctx context.Context, in *LeaseRevokeRequest, opts ...grpc.CallOption) (*LeaseRevokeResponse, error)
	// Renew renews the lease so that it does not expire
	Renew(ctx context.Context, in *LeaseRenewRequest, opts ...grpc.CallOption) (*LeaseRenewResponse, error)
}

LeasesClient is the client API for Leases service.

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

func NewLeasesClient 

func NewLeasesClient(cc *grpc.ClientConn) LeasesClient

type LeasesServer 

type LeasesServer interface {
	// Grant creates a lease which expires if the server does not receive a renewal
	// within a given time to live period. All keys attached to the lease will be expired and
	// deleted if the lease expires. Each expired key generates a delete event in the event history.
	Grant(context.Context, *LeaseGrantRequest) (*LeaseGrantResponse, error)
	Query(context.Context, *LeaseQueryRequest) (*LeaseQueryResponse, error)
	// Get retrieves information on a lease.
	Get(context.Context, *LeaseGetRequest) (*LeaseGetResponse, error)
	// Revoke revokes a lease. All keys attached to the lease will expire and be deleted.
	Revoke(context.Context, *LeaseRevokeRequest) (*LeaseRevokeResponse, error)
	// Renew renews the lease so that it does not expire
	Renew(context.Context, *LeaseRenewRequest) (*LeaseRenewResponse, error)
}

LeasesServer is the server API for Leases service.

type PartitionRequestHeader 

type PartitionRequestHeader struct {
	Store     string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Replica   string `protobuf:"bytes,3,opt,name=replica,proto3" json:"replica,omitempty"`
}

func (*PartitionRequestHeader) Descriptor 

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

func (*PartitionRequestHeader) Marshal 

func (m *PartitionRequestHeader) Marshal() (dAtA []byte, err error)

func (*PartitionRequestHeader) MarshalTo 

func (m *PartitionRequestHeader) MarshalTo(dAtA []byte) (int, error)

func (*PartitionRequestHeader) MarshalToSizedBuffer 

func (m *PartitionRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PartitionRequestHeader) ProtoMessage 

func (*PartitionRequestHeader) ProtoMessage()

func (*PartitionRequestHeader) Reset 

func (m *PartitionRequestHeader) Reset()

func (*PartitionRequestHeader) Size 

func (m *PartitionRequestHeader) Size() (n int)

func (*PartitionRequestHeader) String 

func (m *PartitionRequestHeader) String() string

func (*PartitionRequestHeader) Unmarshal 

func (m *PartitionRequestHeader) Unmarshal(dAtA []byte) error

func (*PartitionRequestHeader) XXX_DiscardUnknown 

func (m *PartitionRequestHeader) XXX_DiscardUnknown()

func (*PartitionRequestHeader) XXX_Marshal 

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

func (*PartitionRequestHeader) XXX_Merge 

func (m *PartitionRequestHeader) XXX_Merge(src proto.Message)

func (*PartitionRequestHeader) XXX_Size 

func (m *PartitionRequestHeader) XXX_Size() int

func (*PartitionRequestHeader) XXX_Unmarshal 

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

type RaftRequest 

type RaftRequest struct {
	// Types that are valid to be assigned to Request:
	//	*RaftRequest_KvQueryRequest
	//	*RaftRequest_KvTxnRequest
	//	*RaftRequest_KvCompactionRequest
	//	*RaftRequest_LeaseGrantRequest
	//	*RaftRequest_LeaseQueryRequest
	//	*RaftRequest_LeaseGetRequest
	//	*RaftRequest_LeaseRevokeRequest
	//	*RaftRequest_LeaseRenewRequest
	Request isRaftRequest_Request `protobuf_oneof:"request"`
	ID      string                `protobuf:"bytes,64,opt,name=ID,json=iD,proto3" json:"ID,omitempty"`
}

func (*RaftRequest) Descriptor 

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

func (*RaftRequest) GetID 

func (m *RaftRequest) GetID() string

func (*RaftRequest) GetKvCompactionRequest 

func (m *RaftRequest) GetKvCompactionRequest() *KVCompactionRequest

func (*RaftRequest) GetKvQueryRequest 

func (m *RaftRequest) GetKvQueryRequest() *KVQueryRequest

func (*RaftRequest) GetKvTxnRequest 

func (m *RaftRequest) GetKvTxnRequest() *KVTxnRequest

func (*RaftRequest) GetLeaseGetRequest 

func (m *RaftRequest) GetLeaseGetRequest() *LeaseGetRequest

func (*RaftRequest) GetLeaseGrantRequest 

func (m *RaftRequest) GetLeaseGrantRequest() *LeaseGrantRequest

func (*RaftRequest) GetLeaseQueryRequest 

func (m *RaftRequest) GetLeaseQueryRequest() *LeaseQueryRequest

func (*RaftRequest) GetLeaseRenewRequest 

func (m *RaftRequest) GetLeaseRenewRequest() *LeaseRenewRequest

func (*RaftRequest) GetLeaseRevokeRequest 

func (m *RaftRequest) GetLeaseRevokeRequest() *LeaseRevokeRequest

func (*RaftRequest) GetRequest 

func (m *RaftRequest) GetRequest() isRaftRequest_Request

func (*RaftRequest) Marshal 

func (m *RaftRequest) Marshal() (dAtA []byte, err error)

func (*RaftRequest) MarshalTo 

func (m *RaftRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest) MarshalToSizedBuffer 

func (m *RaftRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest) ProtoMessage 

func (*RaftRequest) ProtoMessage()

func (*RaftRequest) Reset 

func (m *RaftRequest) Reset()

func (*RaftRequest) Size 

func (m *RaftRequest) Size() (n int)

func (*RaftRequest) String 

func (m *RaftRequest) String() string

func (*RaftRequest) Unmarshal 

func (m *RaftRequest) Unmarshal(dAtA []byte) error

func (*RaftRequest) XXX_DiscardUnknown 

func (m *RaftRequest) XXX_DiscardUnknown()

func (*RaftRequest) XXX_Marshal 

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

func (*RaftRequest) XXX_Merge 

func (m *RaftRequest) XXX_Merge(src proto.Message)

func (*RaftRequest) XXX_OneofWrappers 

func (*RaftRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RaftRequest) XXX_Size 

func (m *RaftRequest) XXX_Size() int

func (*RaftRequest) XXX_Unmarshal 

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

type RaftRequest_KvCompactionRequest 

type RaftRequest_KvCompactionRequest struct {
	KvCompactionRequest *KVCompactionRequest `` /* 126-byte string literal not displayed */
}

func (*RaftRequest_KvCompactionRequest) MarshalTo 

func (m *RaftRequest_KvCompactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_KvCompactionRequest) MarshalToSizedBuffer 

func (m *RaftRequest_KvCompactionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_KvCompactionRequest) Size 

func (m *RaftRequest_KvCompactionRequest) Size() (n int)

type RaftRequest_KvQueryRequest 

type RaftRequest_KvQueryRequest struct {
	KvQueryRequest *KVQueryRequest `protobuf:"bytes,1,opt,name=kv_query_request,json=kvQueryRequest,proto3,oneof" json:"kv_query_request,omitempty"`
}

func (*RaftRequest_KvQueryRequest) MarshalTo 

func (m *RaftRequest_KvQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_KvQueryRequest) MarshalToSizedBuffer 

func (m *RaftRequest_KvQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_KvQueryRequest) Size 

func (m *RaftRequest_KvQueryRequest) Size() (n int)

type RaftRequest_KvTxnRequest 

type RaftRequest_KvTxnRequest struct {
	KvTxnRequest *KVTxnRequest `protobuf:"bytes,2,opt,name=kv_txn_request,json=kvTxnRequest,proto3,oneof" json:"kv_txn_request,omitempty"`
}

func (*RaftRequest_KvTxnRequest) MarshalTo 

func (m *RaftRequest_KvTxnRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_KvTxnRequest) MarshalToSizedBuffer 

func (m *RaftRequest_KvTxnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_KvTxnRequest) Size 

func (m *RaftRequest_KvTxnRequest) Size() (n int)

type RaftRequest_LeaseGetRequest 

type RaftRequest_LeaseGetRequest struct {
	LeaseGetRequest *LeaseGetRequest `protobuf:"bytes,6,opt,name=lease_get_request,json=leaseGetRequest,proto3,oneof" json:"lease_get_request,omitempty"`
}

func (*RaftRequest_LeaseGetRequest) MarshalTo 

func (m *RaftRequest_LeaseGetRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_LeaseGetRequest) MarshalToSizedBuffer 

func (m *RaftRequest_LeaseGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_LeaseGetRequest) Size 

func (m *RaftRequest_LeaseGetRequest) Size() (n int)

type RaftRequest_LeaseGrantRequest 

type RaftRequest_LeaseGrantRequest struct {
	LeaseGrantRequest *LeaseGrantRequest `protobuf:"bytes,4,opt,name=lease_grant_request,json=leaseGrantRequest,proto3,oneof" json:"lease_grant_request,omitempty"`
}

func (*RaftRequest_LeaseGrantRequest) MarshalTo 

func (m *RaftRequest_LeaseGrantRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_LeaseGrantRequest) MarshalToSizedBuffer 

func (m *RaftRequest_LeaseGrantRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_LeaseGrantRequest) Size 

func (m *RaftRequest_LeaseGrantRequest) Size() (n int)

type RaftRequest_LeaseQueryRequest 

type RaftRequest_LeaseQueryRequest struct {
	LeaseQueryRequest *LeaseQueryRequest `protobuf:"bytes,5,opt,name=lease_query_request,json=leaseQueryRequest,proto3,oneof" json:"lease_query_request,omitempty"`
}

func (*RaftRequest_LeaseQueryRequest) MarshalTo 

func (m *RaftRequest_LeaseQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_LeaseQueryRequest) MarshalToSizedBuffer 

func (m *RaftRequest_LeaseQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_LeaseQueryRequest) Size 

func (m *RaftRequest_LeaseQueryRequest) Size() (n int)

type RaftRequest_LeaseRenewRequest 

type RaftRequest_LeaseRenewRequest struct {
	LeaseRenewRequest *LeaseRenewRequest `protobuf:"bytes,8,opt,name=lease_renew_request,json=leaseRenewRequest,proto3,oneof" json:"lease_renew_request,omitempty"`
}

func (*RaftRequest_LeaseRenewRequest) MarshalTo 

func (m *RaftRequest_LeaseRenewRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_LeaseRenewRequest) MarshalToSizedBuffer 

func (m *RaftRequest_LeaseRenewRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_LeaseRenewRequest) Size 

func (m *RaftRequest_LeaseRenewRequest) Size() (n int)

type RaftRequest_LeaseRevokeRequest 

type RaftRequest_LeaseRevokeRequest struct {
	LeaseRevokeRequest *LeaseRevokeRequest `protobuf:"bytes,7,opt,name=lease_revoke_request,json=leaseRevokeRequest,proto3,oneof" json:"lease_revoke_request,omitempty"`
}

func (*RaftRequest_LeaseRevokeRequest) MarshalTo 

func (m *RaftRequest_LeaseRevokeRequest) MarshalTo(dAtA []byte) (int, error)

func (*RaftRequest_LeaseRevokeRequest) MarshalToSizedBuffer 

func (m *RaftRequest_LeaseRevokeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RaftRequest_LeaseRevokeRequest) Size 

func (m *RaftRequest_LeaseRevokeRequest) Size() (n int)

type ResponseHeader 

type ResponseHeader struct {
	// member_id is the ID of the member which sent the response.
	MemberId uint64 `protobuf:"varint,1,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) Marshal 

func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseHeader) MarshalToSizedBuffer 

func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

func (m *ResponseHeader) Size() (n int)

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

func (m *ResponseHeader) Unmarshal(dAtA []byte) error

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

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

func (*ResponseHeader) XXX_Merge 

func (m *ResponseHeader) XXX_Merge(src proto.Message)

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

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

type UnimplementedKVServer 

type UnimplementedKVServer struct {
}

UnimplementedKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedKVServer) Compact 

func (*UnimplementedKVServer) Compact(ctx context.Context, req *KVCompactionRequest) (*KVCompactionResponse, error)

func (*UnimplementedKVServer) Query 

func (*UnimplementedKVServer) Query(ctx context.Context, req *KVQueryRequest) (*KVQueryResponse, error)

func (*UnimplementedKVServer) Txn 

func (*UnimplementedKVServer) Txn(ctx context.Context, req *KVTxnRequest) (*KVTxnResponse, error)

func (*UnimplementedKVServer) Watch 

func (*UnimplementedKVServer) Watch(req *KVWatchRequest, srv KV_WatchServer) error

type UnimplementedLeasesServer 

type UnimplementedLeasesServer struct {
}

UnimplementedLeasesServer can be embedded to have forward compatible implementations.

func (*UnimplementedLeasesServer) Get 

func (*UnimplementedLeasesServer) Get(ctx context.Context, req *LeaseGetRequest) (*LeaseGetResponse, error)

func (*UnimplementedLeasesServer) Grant 

func (*UnimplementedLeasesServer) Grant(ctx context.Context, req *LeaseGrantRequest) (*LeaseGrantResponse, error)

func (*UnimplementedLeasesServer) Query 

func (*UnimplementedLeasesServer) Query(ctx context.Context, req *LeaseQueryRequest) (*LeaseQueryResponse, error)

func (*UnimplementedLeasesServer) Renew 

func (*UnimplementedLeasesServer) Renew(ctx context.Context, req *LeaseRenewRequest) (*LeaseRenewResponse, error)

func (*UnimplementedLeasesServer) Revoke 

func (*UnimplementedLeasesServer) Revoke(ctx context.Context, req *LeaseRevokeRequest) (*LeaseRevokeResponse, 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.