protocol

package
v0.1.4-alpha.4 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2022 License: AGPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FastpathRequest_Op_name = map[int32]string{
		0: "INVALID",
		1: "COMMIT_TXN",
		2: "ABORT_TXN",
		3: "OPEN_TXN",
		4: "GET",
		5: "SET",
		6: "DELETE",
		7: "LIST",
	}
	FastpathRequest_Op_value = map[string]int32{
		"INVALID":    0,
		"COMMIT_TXN": 1,
		"ABORT_TXN":  2,
		"OPEN_TXN":   3,
		"GET":        4,
		"SET":        5,
		"DELETE":     6,
		"LIST":       7,
	}
)

Enum value maps for FastpathRequest_Op.

View Source 
var File_mds_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	Primary  *ClusterRegion   `protobuf:"bytes,1,opt,name=primary,proto3" json:"primary,omitempty"`
	Replicas []*ClusterRegion `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetPrimary 

func (x *Cluster) GetPrimary() *ClusterRegion

func (*Cluster) GetReplicas 

func (x *Cluster) GetReplicas() []*ClusterRegion

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterRegion 

type ClusterRegion struct {
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Config string `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterRegion) Descriptor deprecated 

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

Deprecated: Use ClusterRegion.ProtoReflect.Descriptor instead.

func (*ClusterRegion) GetConfig 

func (x *ClusterRegion) GetConfig() string

func (*ClusterRegion) GetRegion 

func (x *ClusterRegion) GetRegion() string

func (*ClusterRegion) ProtoMessage 

func (*ClusterRegion) ProtoMessage()

func (*ClusterRegion) ProtoReflect 

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

func (*ClusterRegion) Reset 

func (x *ClusterRegion) Reset()

func (*ClusterRegion) String 

func (x *ClusterRegion) String() string

type ErrorResponse 

type ErrorResponse struct {
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Retryable   bool   `protobuf:"varint,2,opt,name=retryable,proto3" json:"retryable,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorResponse) Descriptor deprecated 

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

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetDescription 

func (x *ErrorResponse) GetDescription() string

func (*ErrorResponse) GetRetryable 

func (x *ErrorResponse) GetRetryable() bool

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect 

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

func (*ErrorResponse) Reset 

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

type FastpathListOptions 

type FastpathListOptions struct {
	Limit     uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Reverse   bool   `protobuf:"varint,2,opt,name=reverse,proto3" json:"reverse,omitempty"`
	WantValue bool   `protobuf:"varint,3,opt,name=want_value,json=wantValue,proto3" json:"want_value,omitempty"`
	// contains filtered or unexported fields
}

func (*FastpathListOptions) Descriptor deprecated 

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

Deprecated: Use FastpathListOptions.ProtoReflect.Descriptor instead.

func (*FastpathListOptions) GetLimit 

func (x *FastpathListOptions) GetLimit() uint32

func (*FastpathListOptions) GetReverse 

func (x *FastpathListOptions) GetReverse() bool

func (*FastpathListOptions) GetWantValue 

func (x *FastpathListOptions) GetWantValue() bool

func (*FastpathListOptions) ProtoMessage 

func (*FastpathListOptions) ProtoMessage()

func (*FastpathListOptions) ProtoReflect 

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

func (*FastpathListOptions) Reset 

func (x *FastpathListOptions) Reset()

func (*FastpathListOptions) String 

func (x *FastpathListOptions) String() string

type FastpathRequest 

type FastpathRequest struct {
	Op          FastpathRequest_Op   `protobuf:"varint,1,opt,name=op,proto3,enum=mds.FastpathRequest_Op" json:"op,omitempty"`
	TxnId       uint64               `protobuf:"varint,2,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	IsPrimary   bool                 `protobuf:"varint,3,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	Kvp         []*KeyValuePair      `protobuf:"bytes,4,rep,name=kvp,proto3" json:"kvp,omitempty"`
	ListOptions *FastpathListOptions `protobuf:"bytes,5,opt,name=list_options,json=listOptions,proto3" json:"list_options,omitempty"`
	// contains filtered or unexported fields
}

func (*FastpathRequest) Descriptor deprecated 

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

Deprecated: Use FastpathRequest.ProtoReflect.Descriptor instead.

func (*FastpathRequest) GetIsPrimary 

func (x *FastpathRequest) GetIsPrimary() bool

func (*FastpathRequest) GetKvp 

func (x *FastpathRequest) GetKvp() []*KeyValuePair

func (*FastpathRequest) GetListOptions 

func (x *FastpathRequest) GetListOptions() *FastpathListOptions

func (*FastpathRequest) GetOp 

func (x *FastpathRequest) GetOp() FastpathRequest_Op

func (*FastpathRequest) GetTxnId 

func (x *FastpathRequest) GetTxnId() uint64

func (*FastpathRequest) ProtoMessage 

func (*FastpathRequest) ProtoMessage()

func (*FastpathRequest) ProtoReflect 

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

func (*FastpathRequest) Reset 

func (x *FastpathRequest) Reset()

func (*FastpathRequest) String 

func (x *FastpathRequest) String() string

type FastpathRequest_Op 

type FastpathRequest_Op int32
const (
	FastpathRequest_INVALID    FastpathRequest_Op = 0
	FastpathRequest_COMMIT_TXN FastpathRequest_Op = 1
	FastpathRequest_ABORT_TXN  FastpathRequest_Op = 2
	FastpathRequest_OPEN_TXN   FastpathRequest_Op = 3
	FastpathRequest_GET        FastpathRequest_Op = 4
	FastpathRequest_SET        FastpathRequest_Op = 5
	FastpathRequest_DELETE     FastpathRequest_Op = 6
	FastpathRequest_LIST       FastpathRequest_Op = 7
)

func (FastpathRequest_Op) Descriptor 

func (FastpathRequest_Op) Descriptor() protoreflect.EnumDescriptor

func (FastpathRequest_Op) Enum 

func (x FastpathRequest_Op) Enum() *FastpathRequest_Op

func (FastpathRequest_Op) EnumDescriptor deprecated 

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

Deprecated: Use FastpathRequest_Op.Descriptor instead.

func (FastpathRequest_Op) Number 

func (x FastpathRequest_Op) Number() protoreflect.EnumNumber

func (FastpathRequest_Op) String 

func (x FastpathRequest_Op) String() string

func (FastpathRequest_Op) Type 

func (FastpathRequest_Op) Type() protoreflect.EnumType

type FastpathResponse 

type FastpathResponse struct {
	TxnId uint64          `protobuf:"varint,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	Error *ErrorResponse  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Kvp   []*KeyValuePair `protobuf:"bytes,3,rep,name=kvp,proto3" json:"kvp,omitempty"`
	// contains filtered or unexported fields
}

func (*FastpathResponse) Descriptor deprecated 

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

Deprecated: Use FastpathResponse.ProtoReflect.Descriptor instead.

func (*FastpathResponse) GetError 

func (x *FastpathResponse) GetError() *ErrorResponse

func (*FastpathResponse) GetKvp 

func (x *FastpathResponse) GetKvp() []*KeyValuePair

func (*FastpathResponse) GetTxnId 

func (x *FastpathResponse) GetTxnId() uint64

func (*FastpathResponse) ProtoMessage 

func (*FastpathResponse) ProtoMessage()

func (*FastpathResponse) ProtoReflect 

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

func (*FastpathResponse) Reset 

func (x *FastpathResponse) Reset()

func (*FastpathResponse) String 

func (x *FastpathResponse) String() string

type KeyValuePair 

type KeyValuePair 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"`
	// contains filtered or unexported fields
}

func (*KeyValuePair) Descriptor deprecated 

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

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

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

func (*KeyValuePair) GetValue 

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

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect 

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

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type Login 

type Login struct {
	Store     string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	MuxWidth  uint32 `protobuf:"varint,4,opt,name=mux_width,json=muxWidth,proto3" json:"mux_width,omitempty"`
	// contains filtered or unexported fields
}

func (*Login) Descriptor deprecated 

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

Deprecated: Use Login.ProtoReflect.Descriptor instead.

func (*Login) GetMuxWidth 

func (x *Login) GetMuxWidth() uint32

func (*Login) GetPublicKey 

func (x *Login) GetPublicKey() []byte

func (*Login) GetSignature 

func (x *Login) GetSignature() []byte

func (*Login) GetStore 

func (x *Login) GetStore() string

func (*Login) ProtoMessage 

func (*Login) ProtoMessage()

func (*Login) ProtoReflect 

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

func (*Login) Reset 

func (x *Login) Reset()

func (*Login) String 

func (x *Login) String() string

type LoginChallenge 

type LoginChallenge struct {
	Challenge []byte `protobuf:"bytes,1,opt,name=challenge,proto3" json:"challenge,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginChallenge) Descriptor deprecated 

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

Deprecated: Use LoginChallenge.ProtoReflect.Descriptor instead.

func (*LoginChallenge) GetChallenge 

func (x *LoginChallenge) GetChallenge() []byte

func (*LoginChallenge) GetVersion 

func (x *LoginChallenge) GetVersion() string

func (*LoginChallenge) ProtoMessage 

func (*LoginChallenge) ProtoMessage()

func (*LoginChallenge) ProtoReflect 

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

func (*LoginChallenge) Reset 

func (x *LoginChallenge) Reset()

func (*LoginChallenge) String 

func (x *LoginChallenge) String() string

type LoginResponse 

type LoginResponse struct {
	Ok             bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Region         string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Error          string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	PingIntervalMs uint64 `protobuf:"varint,4,opt,name=ping_interval_ms,json=pingIntervalMs,proto3" json:"ping_interval_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated 

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

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetError 

func (x *LoginResponse) GetError() string

func (*LoginResponse) GetOk 

func (x *LoginResponse) GetOk() bool

func (*LoginResponse) GetPingIntervalMs 

func (x *LoginResponse) GetPingIntervalMs() uint64

func (*LoginResponse) GetRegion 

func (x *LoginResponse) GetRegion() string

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect 

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

func (*LoginResponse) Reset 

func (x *LoginResponse) Reset()

func (*LoginResponse) String 

func (x *LoginResponse) String() string

type Request 

type Request struct {
	Lane          uint32             `protobuf:"varint,1,opt,name=lane,proto3" json:"lane,omitempty"`
	Program       string             `protobuf:"bytes,2,opt,name=program,proto3" json:"program,omitempty"`
	Data          string             `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	FastpathBatch []*FastpathRequest `protobuf:"bytes,4,rep,name=fastpath_batch,json=fastpathBatch,proto3" json:"fastpath_batch,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetData 

func (x *Request) GetData() string

func (*Request) GetFastpathBatch 

func (x *Request) GetFastpathBatch() []*FastpathRequest

func (*Request) GetLane 

func (x *Request) GetLane() uint32

func (*Request) GetProgram 

func (x *Request) GetProgram() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

type Response struct {
	Lane uint32 `protobuf:"varint,1,opt,name=lane,proto3" json:"lane,omitempty"`
	// Types that are assignable to Body:
	//	*Response_Error
	//	*Response_Output
	Body          isResponse_Body     `protobuf_oneof:"body"`
	FastpathBatch []*FastpathResponse `protobuf:"bytes,4,rep,name=fastpath_batch,json=fastpathBatch,proto3" json:"fastpath_batch,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetBody 

func (m *Response) GetBody() isResponse_Body

func (*Response) GetError 

func (x *Response) GetError() *ErrorResponse

func (*Response) GetFastpathBatch 

func (x *Response) GetFastpathBatch() []*FastpathResponse

func (*Response) GetLane 

func (x *Response) GetLane() uint32

func (*Response) GetOutput 

func (x *Response) GetOutput() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_Error 

type Response_Error struct {
	Error *ErrorResponse `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type Response_Output 

type Response_Output struct {
	Output string `protobuf:"bytes,3,opt,name=output,proto3,oneof"`
}

type StoreInfo 

type StoreInfo struct {
	Cluster  string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Subspace string `protobuf:"bytes,2,opt,name=subspace,proto3" json:"subspace,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreInfo) Descriptor deprecated 

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

Deprecated: Use StoreInfo.ProtoReflect.Descriptor instead.

func (*StoreInfo) GetCluster 

func (x *StoreInfo) GetCluster() string

func (*StoreInfo) GetSubspace 

func (x *StoreInfo) GetSubspace() string

func (*StoreInfo) ProtoMessage 

func (*StoreInfo) ProtoMessage()

func (*StoreInfo) ProtoReflect 

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

func (*StoreInfo) Reset 

func (x *StoreInfo) Reset()

func (*StoreInfo) String 

func (x *StoreInfo) String() string

type StoreRoleList 

type StoreRoleList struct {
	Roles         []string `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	ReadonlyRoles []string `protobuf:"bytes,2,rep,name=readonly_roles,json=readonlyRoles,proto3" json:"readonly_roles,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreRoleList) Descriptor deprecated 

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

Deprecated: Use StoreRoleList.ProtoReflect.Descriptor instead.

func (*StoreRoleList) GetReadonlyRoles 

func (x *StoreRoleList) GetReadonlyRoles() []string

func (*StoreRoleList) GetRoles 

func (x *StoreRoleList) GetRoles() []string

func (*StoreRoleList) ProtoMessage 

func (*StoreRoleList) ProtoMessage()

func (*StoreRoleList) ProtoReflect 

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

func (*StoreRoleList) Reset 

func (x *StoreRoleList) Reset()

func (*StoreRoleList) String 

func (x *StoreRoleList) String() string

type UserRoleList 

type UserRoleList struct {
	Roles []string `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	// contains filtered or unexported fields
}

func (*UserRoleList) Descriptor deprecated 

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

Deprecated: Use UserRoleList.ProtoReflect.Descriptor instead.

func (*UserRoleList) GetRoles 

func (x *UserRoleList) GetRoles() []string

func (*UserRoleList) ProtoMessage 

func (*UserRoleList) ProtoMessage()

func (*UserRoleList) ProtoReflect 

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

func (*UserRoleList) Reset 

func (x *UserRoleList) Reset()

func (*UserRoleList) String 

func (x *UserRoleList) 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.