pb

package
v1.6.2 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2022 License: MIT Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_trtl_v1_trtl_proto protoreflect.FileDescriptor
View Source 
var Trtl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "trtl.v1.Trtl",
	HandlerType: (*TrtlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Trtl_Get_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Trtl_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Trtl_Delete_Handler,
		},
		{
			MethodName: "Iter",
			Handler:    _Trtl_Iter_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Trtl_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Batch",
			Handler:       _Trtl_Batch_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Cursor",
			Handler:       _Trtl_Cursor_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Sync",
			Handler:       _Trtl_Sync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "trtl/v1/trtl.proto",
}

Trtl_ServiceDesc is the grpc.ServiceDesc for Trtl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTrtlServer 

func RegisterTrtlServer(s grpc.ServiceRegistrar, srv TrtlServer)

Types

type BatchReply 

type BatchReply struct {
	Operations int64               `protobuf:"varint,1,opt,name=operations,proto3" json:"operations,omitempty"`
	Successful int64               `protobuf:"varint,2,opt,name=successful,proto3" json:"successful,omitempty"`
	Failed     int64               `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"`
	Errors     []*BatchReply_Error `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchReply) Descriptor deprecated 

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

Deprecated: Use BatchReply.ProtoReflect.Descriptor instead.

func (*BatchReply) GetErrors 

func (x *BatchReply) GetErrors() []*BatchReply_Error

func (*BatchReply) GetFailed 

func (x *BatchReply) GetFailed() int64

func (*BatchReply) GetOperations 

func (x *BatchReply) GetOperations() int64

func (*BatchReply) GetSuccessful 

func (x *BatchReply) GetSuccessful() int64

func (*BatchReply) ProtoMessage 

func (*BatchReply) ProtoMessage()

func (*BatchReply) ProtoReflect 

func (x *BatchReply) ProtoReflect() protoreflect.Message

func (*BatchReply) Reset 

func (x *BatchReply) Reset()

func (*BatchReply) String 

func (x *BatchReply) String() string

type BatchReply_Error 

type BatchReply_Error struct {
	Id    int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchReply_Error) Descriptor deprecated 

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

Deprecated: Use BatchReply_Error.ProtoReflect.Descriptor instead.

func (*BatchReply_Error) GetError 

func (x *BatchReply_Error) GetError() string

func (*BatchReply_Error) GetId 

func (x *BatchReply_Error) GetId() int64

func (*BatchReply_Error) ProtoMessage 

func (*BatchReply_Error) ProtoMessage()

func (*BatchReply_Error) ProtoReflect 

func (x *BatchReply_Error) ProtoReflect() protoreflect.Message

func (*BatchReply_Error) Reset 

func (x *BatchReply_Error) Reset()

func (*BatchReply_Error) String 

func (x *BatchReply_Error) String() string

type BatchRequest 

type BatchRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*BatchRequest_Put
	//	*BatchRequest_Delete
	Request isBatchRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*BatchRequest) Descriptor deprecated 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetDelete 

func (x *BatchRequest) GetDelete() *DeleteRequest

func (*BatchRequest) GetId 

func (x *BatchRequest) GetId() int64

func (*BatchRequest) GetPut 

func (x *BatchRequest) GetPut() *PutRequest

func (*BatchRequest) GetRequest 

func (m *BatchRequest) GetRequest() isBatchRequest_Request

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect 

func (x *BatchRequest) ProtoReflect() protoreflect.Message

func (*BatchRequest) Reset 

func (x *BatchRequest) Reset()

func (*BatchRequest) String 

func (x *BatchRequest) String() string

type BatchRequest_Delete 

type BatchRequest_Delete struct {
	Delete *DeleteRequest `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type BatchRequest_Put 

type BatchRequest_Put struct {
	Put *PutRequest `protobuf:"bytes,2,opt,name=put,proto3,oneof"`
}

type CursorRequest 

type CursorRequest struct {
	Prefix    []byte   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`                  // the prefix to range over, if nil all objects are returned
	SeekKey   []byte   `protobuf:"bytes,2,opt,name=seek_key,json=seekKey,proto3" json:"seek_key,omitempty"` // a key to seekto within the prefix (optional)
	Namespace string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Options   *Options `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CursorRequest) Descriptor deprecated 

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

Deprecated: Use CursorRequest.ProtoReflect.Descriptor instead.

func (*CursorRequest) GetNamespace 

func (x *CursorRequest) GetNamespace() string

func (*CursorRequest) GetOptions 

func (x *CursorRequest) GetOptions() *Options

func (*CursorRequest) GetPrefix 

func (x *CursorRequest) GetPrefix() []byte

func (*CursorRequest) GetSeekKey 

func (x *CursorRequest) GetSeekKey() []byte

func (*CursorRequest) ProtoMessage 

func (*CursorRequest) ProtoMessage()

func (*CursorRequest) ProtoReflect 

func (x *CursorRequest) ProtoReflect() protoreflect.Message

func (*CursorRequest) Reset 

func (x *CursorRequest) Reset()

func (*CursorRequest) String 

func (x *CursorRequest) String() string

type DeleteReply 

type DeleteReply struct {
	Success bool  `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Meta    *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // will only be supplied if return_meta=true in options
	// contains filtered or unexported fields
}

func (*DeleteReply) Descriptor deprecated 

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

Deprecated: Use DeleteReply.ProtoReflect.Descriptor instead.

func (*DeleteReply) GetMeta 

func (x *DeleteReply) GetMeta() *Meta

func (*DeleteReply) GetSuccess 

func (x *DeleteReply) GetSuccess() bool

func (*DeleteReply) ProtoMessage 

func (*DeleteReply) ProtoMessage()

func (*DeleteReply) ProtoReflect 

func (x *DeleteReply) ProtoReflect() protoreflect.Message

func (*DeleteReply) Reset 

func (x *DeleteReply) Reset()

func (*DeleteReply) String 

func (x *DeleteReply) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key       []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Namespace string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Options   *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"` // if return_meta=true then the meta of the version deleted is returned
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() []byte

func (*DeleteRequest) GetNamespace 

func (x *DeleteRequest) GetNamespace() string

func (*DeleteRequest) GetOptions 

func (x *DeleteRequest) GetOptions() *Options

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

func (x *DeleteRequest) ProtoReflect() protoreflect.Message

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type GetReply 

type GetReply struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Meta  *Meta  `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // will only be supplied if return_meta=true in options
	// contains filtered or unexported fields
}

func (*GetReply) Descriptor deprecated 

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

Deprecated: Use GetReply.ProtoReflect.Descriptor instead.

func (*GetReply) GetMeta 

func (x *GetReply) GetMeta() *Meta

func (*GetReply) GetValue 

func (x *GetReply) GetValue() []byte

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) ProtoReflect 

func (x *GetReply) ProtoReflect() protoreflect.Message

func (*GetReply) Reset 

func (x *GetReply) Reset()

func (*GetReply) String 

func (x *GetReply) String() string

type GetRequest 

type GetRequest struct {
	Key       []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Namespace string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Options   *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) GetNamespace 

func (x *GetRequest) GetNamespace() string

func (*GetRequest) GetOptions 

func (x *GetRequest) GetOptions() *Options

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type HealthCheck added in v1.3.1 

type HealthCheck struct {
	// contains filtered or unexported fields
}

func (*HealthCheck) Descriptor deprecated added in v1.3.1 

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

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) ProtoMessage added in v1.3.1 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect added in v1.3.1 

func (x *HealthCheck) ProtoReflect() protoreflect.Message

func (*HealthCheck) Reset added in v1.3.1 

func (x *HealthCheck) Reset()

func (*HealthCheck) String added in v1.3.1 

func (x *HealthCheck) String() string

type IterReply 

type IterReply struct {
	Values        []*KVPair `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	NextPageToken string    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*IterReply) Descriptor deprecated 

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

Deprecated: Use IterReply.ProtoReflect.Descriptor instead.

func (*IterReply) GetNextPageToken 

func (x *IterReply) GetNextPageToken() string

func (*IterReply) GetValues 

func (x *IterReply) GetValues() []*KVPair

func (*IterReply) ProtoMessage 

func (*IterReply) ProtoMessage()

func (*IterReply) ProtoReflect 

func (x *IterReply) ProtoReflect() protoreflect.Message

func (*IterReply) Reset 

func (x *IterReply) Reset()

func (*IterReply) String 

func (x *IterReply) String() string

type IterRequest 

type IterRequest struct {
	Prefix    []byte   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` // the prefix to range over, if nil all objects are returned
	Namespace string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Options   *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*IterRequest) Descriptor deprecated 

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

Deprecated: Use IterRequest.ProtoReflect.Descriptor instead.

func (*IterRequest) GetNamespace 

func (x *IterRequest) GetNamespace() string

func (*IterRequest) GetOptions 

func (x *IterRequest) GetOptions() *Options

func (*IterRequest) GetPrefix 

func (x *IterRequest) GetPrefix() []byte

func (*IterRequest) ProtoMessage 

func (*IterRequest) ProtoMessage()

func (*IterRequest) ProtoReflect 

func (x *IterRequest) ProtoReflect() protoreflect.Message

func (*IterRequest) Reset 

func (x *IterRequest) Reset()

func (*IterRequest) String 

func (x *IterRequest) String() string

type KVPair 

type KVPair struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Meta      *Meta  `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

A key/value pair that is returned in Iter and Cursor requests

func (*KVPair) Descriptor deprecated 

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

Deprecated: Use KVPair.ProtoReflect.Descriptor instead.

func (*KVPair) GetKey 

func (x *KVPair) GetKey() []byte

func (*KVPair) GetMeta 

func (x *KVPair) GetMeta() *Meta

func (*KVPair) GetNamespace 

func (x *KVPair) GetNamespace() string

func (*KVPair) GetValue 

func (x *KVPair) GetValue() []byte

func (*KVPair) ProtoMessage 

func (*KVPair) ProtoMessage()

func (*KVPair) ProtoReflect 

func (x *KVPair) ProtoReflect() protoreflect.Message

func (*KVPair) Reset 

func (x *KVPair) Reset()

func (*KVPair) String 

func (x *KVPair) String() string

type Meta 

type Meta struct {
	Key       []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`             // the key that the metadata describes
	Namespace string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // a unique namespace of the key, usually a prefix
	Region    string   `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`       // the region in which the data originated
	Owner     string   `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`         // the name of the replica where the data originated
	Version   *Version `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`     // the current conflict-free version of the data
	Parent    *Version `protobuf:"bytes,6,opt,name=parent,proto3" json:"parent,omitempty"`       // the version the current data was was derived from
	// contains filtered or unexported fields
}

Meta is a simplified representation of the honu.object.v1.Object metadata that trtl actually stores. The simplification is intended to return non-nested data version information to the user in a read-only fashion.

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetKey 

func (x *Meta) GetKey() []byte

func (*Meta) GetNamespace 

func (x *Meta) GetNamespace() string

func (*Meta) GetOwner 

func (x *Meta) GetOwner() string

func (*Meta) GetParent 

func (x *Meta) GetParent() *Version

func (*Meta) GetRegion 

func (x *Meta) GetRegion() string

func (*Meta) GetVersion 

func (x *Meta) GetVersion() *Version

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type Options 

type Options struct {
	ReturnMeta   bool   `protobuf:"varint,1,opt,name=return_meta,json=returnMeta,proto3" json:"return_meta,omitempty"`         // generally, return the version information for the object in the response
	IterNoKeys   bool   `protobuf:"varint,2,opt,name=iter_no_keys,json=iterNoKeys,proto3" json:"iter_no_keys,omitempty"`       // do not include keys in an Iter or Cursor response, to reduce data transfer load
	IterNoValues bool   `protobuf:"varint,3,opt,name=iter_no_values,json=iterNoValues,proto3" json:"iter_no_values,omitempty"` // do not include values in an Iter or Cursor response, to reduce data transfer load
	PageToken    string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`             // specify the page token to fetch the next page of results
	PageSize     int32  `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`               // specify the number of results per page, cannot change between page requests
	// contains filtered or unexported fields
}

Options conditions all accesses to trtl, e.g. there are not different structs for Get vs Put options. The semantics of each option depends on the type of request.

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetIterNoKeys 

func (x *Options) GetIterNoKeys() bool

func (*Options) GetIterNoValues 

func (x *Options) GetIterNoValues() bool

func (*Options) GetPageSize 

func (x *Options) GetPageSize() int32

func (*Options) GetPageToken 

func (x *Options) GetPageToken() string

func (*Options) GetReturnMeta 

func (x *Options) GetReturnMeta() bool

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect 

func (x *Options) ProtoReflect() protoreflect.Message

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type PutReply 

type PutReply struct {
	Success bool  `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Meta    *Meta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // will only be supplied if return_meta=true in options
	// contains filtered or unexported fields
}

func (*PutReply) Descriptor deprecated 

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

Deprecated: Use PutReply.ProtoReflect.Descriptor instead.

func (*PutReply) GetMeta 

func (x *PutReply) GetMeta() *Meta

func (*PutReply) GetSuccess 

func (x *PutReply) GetSuccess() bool

func (*PutReply) ProtoMessage 

func (*PutReply) ProtoMessage()

func (*PutReply) ProtoReflect 

func (x *PutReply) ProtoReflect() protoreflect.Message

func (*PutReply) Reset 

func (x *PutReply) Reset()

func (*PutReply) String 

func (x *PutReply) String() string

type PutRequest 

type PutRequest struct {
	Key       []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Namespace string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Options   *Options `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetNamespace 

func (x *PutRequest) GetNamespace() string

func (*PutRequest) GetOptions 

func (x *PutRequest) GetOptions() *Options

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

func (x *PutRequest) ProtoReflect() protoreflect.Message

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type ReplicaStatus added in v1.3.1 

type ReplicaStatus struct {
	Enabled  bool   `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Pid      uint64 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Region   string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	Name     string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Interval string `protobuf:"bytes,5,opt,name=interval,proto3" json:"interval,omitempty"`
	Sigma    string `protobuf:"bytes,6,opt,name=sigma,proto3" json:"sigma,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaStatus) Descriptor deprecated added in v1.3.1 

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

Deprecated: Use ReplicaStatus.ProtoReflect.Descriptor instead.

func (*ReplicaStatus) GetEnabled added in v1.3.1 

func (x *ReplicaStatus) GetEnabled() bool

func (*ReplicaStatus) GetInterval added in v1.3.1 

func (x *ReplicaStatus) GetInterval() string

func (*ReplicaStatus) GetName added in v1.3.1 

func (x *ReplicaStatus) GetName() string

func (*ReplicaStatus) GetPid added in v1.3.1 

func (x *ReplicaStatus) GetPid() uint64

func (*ReplicaStatus) GetRegion added in v1.3.1 

func (x *ReplicaStatus) GetRegion() string

func (*ReplicaStatus) GetSigma added in v1.3.1 

func (x *ReplicaStatus) GetSigma() string

func (*ReplicaStatus) ProtoMessage added in v1.3.1 

func (*ReplicaStatus) ProtoMessage()

func (*ReplicaStatus) ProtoReflect added in v1.3.1 

func (x *ReplicaStatus) ProtoReflect() protoreflect.Message

func (*ReplicaStatus) Reset added in v1.3.1 

func (x *ReplicaStatus) Reset()

func (*ReplicaStatus) String added in v1.3.1 

func (x *ReplicaStatus) String() string

type ServerStatus added in v1.3.1 

type ServerStatus struct {
	Status  string         `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Version string         `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Uptime  string         `protobuf:"bytes,3,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Replica *ReplicaStatus `protobuf:"bytes,15,opt,name=replica,proto3" json:"replica,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerStatus) Descriptor deprecated added in v1.3.1 

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

Deprecated: Use ServerStatus.ProtoReflect.Descriptor instead.

func (*ServerStatus) GetReplica added in v1.3.1 

func (x *ServerStatus) GetReplica() *ReplicaStatus

func (*ServerStatus) GetStatus added in v1.3.1 

func (x *ServerStatus) GetStatus() string

func (*ServerStatus) GetUptime added in v1.3.1 

func (x *ServerStatus) GetUptime() string

func (*ServerStatus) GetVersion added in v1.3.1 

func (x *ServerStatus) GetVersion() string

func (*ServerStatus) ProtoMessage added in v1.3.1 

func (*ServerStatus) ProtoMessage()

func (*ServerStatus) ProtoReflect added in v1.3.1 

func (x *ServerStatus) ProtoReflect() protoreflect.Message

func (*ServerStatus) Reset added in v1.3.1 

func (x *ServerStatus) Reset()

func (*ServerStatus) String added in v1.3.1 

func (x *ServerStatus) String() string

type SyncReply 

type SyncReply struct {
	Id      int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// Types that are assignable to Reply:
	//
	//	*SyncReply_Get
	//	*SyncReply_Put
	//	*SyncReply_Delete
	//	*SyncReply_Iter
	Reply isSyncReply_Reply `protobuf_oneof:"reply"`
	// contains filtered or unexported fields
}

func (*SyncReply) Descriptor deprecated 

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

Deprecated: Use SyncReply.ProtoReflect.Descriptor instead.

func (*SyncReply) GetDelete 

func (x *SyncReply) GetDelete() *DeleteReply

func (*SyncReply) GetError 

func (x *SyncReply) GetError() string

func (*SyncReply) GetGet 

func (x *SyncReply) GetGet() *GetReply

func (*SyncReply) GetId 

func (x *SyncReply) GetId() int64

func (*SyncReply) GetIter 

func (x *SyncReply) GetIter() *IterReply

func (*SyncReply) GetPut 

func (x *SyncReply) GetPut() *PutReply

func (*SyncReply) GetReply 

func (m *SyncReply) GetReply() isSyncReply_Reply

func (*SyncReply) GetSuccess 

func (x *SyncReply) GetSuccess() bool

func (*SyncReply) ProtoMessage 

func (*SyncReply) ProtoMessage()

func (*SyncReply) ProtoReflect 

func (x *SyncReply) ProtoReflect() protoreflect.Message

func (*SyncReply) Reset 

func (x *SyncReply) Reset()

func (*SyncReply) String 

func (x *SyncReply) String() string

type SyncReply_Delete 

type SyncReply_Delete struct {
	Delete *DeleteReply `protobuf:"bytes,6,opt,name=delete,proto3,oneof"`
}

type SyncReply_Get 

type SyncReply_Get struct {
	Get *GetReply `protobuf:"bytes,4,opt,name=get,proto3,oneof"`
}

type SyncReply_Iter 

type SyncReply_Iter struct {
	Iter *IterReply `protobuf:"bytes,7,opt,name=iter,proto3,oneof"`
}

type SyncReply_Put 

type SyncReply_Put struct {
	Put *PutReply `protobuf:"bytes,5,opt,name=put,proto3,oneof"`
}

type SyncRequest 

type SyncRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//
	//	*SyncRequest_Get
	//	*SyncRequest_Put
	//	*SyncRequest_Delete
	//	*SyncRequest_Iter
	Request isSyncRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetDelete 

func (x *SyncRequest) GetDelete() *DeleteRequest

func (*SyncRequest) GetGet 

func (x *SyncRequest) GetGet() *GetRequest

func (*SyncRequest) GetId 

func (x *SyncRequest) GetId() int64

func (*SyncRequest) GetIter 

func (x *SyncRequest) GetIter() *IterRequest

func (*SyncRequest) GetPut 

func (x *SyncRequest) GetPut() *PutRequest

func (*SyncRequest) GetRequest 

func (m *SyncRequest) GetRequest() isSyncRequest_Request

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

func (x *SyncRequest) ProtoReflect() protoreflect.Message

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncRequest_Delete 

type SyncRequest_Delete struct {
	Delete *DeleteRequest `protobuf:"bytes,4,opt,name=delete,proto3,oneof"`
}

type SyncRequest_Get 

type SyncRequest_Get struct {
	Get *GetRequest `protobuf:"bytes,2,opt,name=get,proto3,oneof"`
}

type SyncRequest_Iter 

type SyncRequest_Iter struct {
	Iter *IterRequest `protobuf:"bytes,5,opt,name=iter,proto3,oneof"`
}

type SyncRequest_Put 

type SyncRequest_Put struct {
	Put *PutRequest `protobuf:"bytes,3,opt,name=put,proto3,oneof"`
}

type TrtlClient 

type TrtlClient interface {
	// Get is a unary request to retrieve a value for a key.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	// Put is a unary request to store a value for a key.
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error)
	// Delete is a unary request to remove a value and key.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error)
	// Iter is a unary request that returns a completely materialized list of key value pairs.
	Iter(ctx context.Context, in *IterRequest, opts ...grpc.CallOption) (*IterReply, error)
	// Batch is a client-side streaming request to issue multiple commands, usually Put and Delete.
	Batch(ctx context.Context, opts ...grpc.CallOption) (Trtl_BatchClient, error)
	// Cursor is a server-side streaming request to iterate in a memory safe fashion.
	Cursor(ctx context.Context, in *CursorRequest, opts ...grpc.CallOption) (Trtl_CursorClient, error)
	// Sync is a bi-directional streaming mechanism to issue access requests synchronously.
	Sync(ctx context.Context, opts ...grpc.CallOption) (Trtl_SyncClient, error)
	// This RPC servers as a health check for clients to make sure the server is online.
	Status(ctx context.Context, in *HealthCheck, opts ...grpc.CallOption) (*ServerStatus, error)
}

TrtlClient is the client API for Trtl service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTrtlClient 

func NewTrtlClient(cc grpc.ClientConnInterface) TrtlClient

type TrtlServer 

type TrtlServer interface {
	// Get is a unary request to retrieve a value for a key.
	Get(context.Context, *GetRequest) (*GetReply, error)
	// Put is a unary request to store a value for a key.
	Put(context.Context, *PutRequest) (*PutReply, error)
	// Delete is a unary request to remove a value and key.
	Delete(context.Context, *DeleteRequest) (*DeleteReply, error)
	// Iter is a unary request that returns a completely materialized list of key value pairs.
	Iter(context.Context, *IterRequest) (*IterReply, error)
	// Batch is a client-side streaming request to issue multiple commands, usually Put and Delete.
	Batch(Trtl_BatchServer) error
	// Cursor is a server-side streaming request to iterate in a memory safe fashion.
	Cursor(*CursorRequest, Trtl_CursorServer) error
	// Sync is a bi-directional streaming mechanism to issue access requests synchronously.
	Sync(Trtl_SyncServer) error
	// This RPC servers as a health check for clients to make sure the server is online.
	Status(context.Context, *HealthCheck) (*ServerStatus, error)
	// contains filtered or unexported methods
}

TrtlServer is the server API for Trtl service. All implementations must embed UnimplementedTrtlServer for forward compatibility

type Trtl_BatchClient 

type Trtl_BatchClient interface {
	Send(*BatchRequest) error
	CloseAndRecv() (*BatchReply, error)
	grpc.ClientStream
}

type Trtl_BatchServer 

type Trtl_BatchServer interface {
	SendAndClose(*BatchReply) error
	Recv() (*BatchRequest, error)
	grpc.ServerStream
}

type Trtl_CursorClient 

type Trtl_CursorClient interface {
	Recv() (*KVPair, error)
	grpc.ClientStream
}

type Trtl_CursorServer 

type Trtl_CursorServer interface {
	Send(*KVPair) error
	grpc.ServerStream
}

type Trtl_SyncClient 

type Trtl_SyncClient interface {
	Send(*SyncRequest) error
	Recv() (*SyncReply, error)
	grpc.ClientStream
}

type Trtl_SyncServer 

type Trtl_SyncServer interface {
	Send(*SyncReply) error
	Recv() (*SyncRequest, error)
	grpc.ServerStream
}

type UnimplementedTrtlServer 

type UnimplementedTrtlServer struct {
}

UnimplementedTrtlServer must be embedded to have forward compatible implementations.

func (UnimplementedTrtlServer) Batch 

func (UnimplementedTrtlServer) Batch(Trtl_BatchServer) error

func (UnimplementedTrtlServer) Cursor 

func (UnimplementedTrtlServer) Cursor(*CursorRequest, Trtl_CursorServer) error

func (UnimplementedTrtlServer) Delete 

func (UnimplementedTrtlServer) Delete(context.Context, *DeleteRequest) (*DeleteReply, error)

func (UnimplementedTrtlServer) Get 

func (UnimplementedTrtlServer) Get(context.Context, *GetRequest) (*GetReply, error)

func (UnimplementedTrtlServer) Iter 

func (UnimplementedTrtlServer) Iter(context.Context, *IterRequest) (*IterReply, error)

func (UnimplementedTrtlServer) Put 

func (UnimplementedTrtlServer) Put(context.Context, *PutRequest) (*PutReply, error)

func (UnimplementedTrtlServer) Status added in v1.3.1 

func (UnimplementedTrtlServer) Status(context.Context, *HealthCheck) (*ServerStatus, error)

func (UnimplementedTrtlServer) Sync 

func (UnimplementedTrtlServer) Sync(Trtl_SyncServer) error

type UnsafeTrtlServer 

type UnsafeTrtlServer interface {
	// contains filtered or unexported methods
}

UnsafeTrtlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TrtlServer will result in compilation errors.

type Version 

type Version struct {
	Pid     uint64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`         // process id, used for conflict-free version comparisons
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // a monotonically increasing scalar that describes changes in the record
	Region  string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`    // the region where the version originated
	// contains filtered or unexported fields
}

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetPid 

func (x *Version) GetPid() uint64

func (*Version) GetRegion 

func (x *Version) GetRegion() string

func (*Version) GetVersion 

func (x *Version) GetVersion() uint64

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

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.