distpebblev1

package
v0.0.0-...-8a81ed5 Latest Latest
Warning

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

 Go to latest Published: May 10, 2022 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TxnType_name = map[int32]string{
		0: "UNKNOWN",
		1: "SINGLE_HOME",
		2: "MULTI_HOME_OR_LOCK_ONLY",
	}
	TxnType_value = map[string]int32{
		"UNKNOWN":                 0,
		"SINGLE_HOME":             1,
		"MULTI_HOME_OR_LOCK_ONLY": 2,
	}
)

Enum value maps for TxnType.

View Source 
var File_distpebble_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_distpebble_v1_lookup_proto protoreflect.FileDescriptor
View Source 
var File_distpebble_v1_seq_proto protoreflect.FileDescriptor
View Source 
var File_distpebble_v1_txn_proto protoreflect.FileDescriptor
View Source 
var LookupService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "distpebble.v1.LookupService",
	HandlerType: (*LookupServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LookupMaster",
			Handler:    _LookupService_LookupMaster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "distpebble/v1/lookup.proto",
}

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

View Source 
var SequencerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "distpebble.v1.SequencerService",
	HandlerType: (*SequencerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTxn",
			Handler:    _SequencerService_CreateTxn_Handler,
		},
		{
			MethodName: "GetBatch",
			Handler:    _SequencerService_GetBatch_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "distpebble/v1/seq.proto",
}

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

Functions

func RegisterLookupServiceServer 

func RegisterLookupServiceServer(s grpc.ServiceRegistrar, srv LookupServiceServer)

func RegisterSequencerServiceServer 

func RegisterSequencerServiceServer(s grpc.ServiceRegistrar, srv SequencerServiceServer)

Types

type ClusterInfo 

type ClusterInfo struct {
	Machines []*MachineInfo `protobuf:"bytes,1,rep,name=machines,proto3" json:"machines,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterInfo) Descriptor deprecated 

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

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetMachines 

func (x *ClusterInfo) GetMachines() []*MachineInfo

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect 

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

func (*ClusterInfo) Reset 

func (x *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (x *ClusterInfo) String() string

func (*ClusterInfo) Validate 

func (m *ClusterInfo) Validate() error

Validate checks the field values on ClusterInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ClusterInfo) ValidateAll 

func (m *ClusterInfo) ValidateAll() error

ValidateAll checks the field values on ClusterInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClusterInfoMultiError, or nil if none found.

type ClusterInfoMultiError 

type ClusterInfoMultiError []error

ClusterInfoMultiError is an error wrapping multiple validation errors returned by ClusterInfo.ValidateAll() if the designated constraints aren't met.

func (ClusterInfoMultiError) AllErrors 

func (m ClusterInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClusterInfoMultiError) Error 

func (m ClusterInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClusterInfoValidationError 

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

ClusterInfoValidationError is the validation error returned by ClusterInfo.Validate if the designated constraints aren't met.

func (ClusterInfoValidationError) Cause 

func (e ClusterInfoValidationError) Cause() error

Cause function returns cause value.

func (ClusterInfoValidationError) Error 

func (e ClusterInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ClusterInfoValidationError) ErrorName 

func (e ClusterInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ClusterInfoValidationError) Field 

func (e ClusterInfoValidationError) Field() string

Field function returns field value.

func (ClusterInfoValidationError) Key 

func (e ClusterInfoValidationError) Key() bool

Key function returns key value.

func (ClusterInfoValidationError) Reason 

func (e ClusterInfoValidationError) Reason() string

Reason function returns reason value.

type CreateTxnRequest 

type CreateTxnRequest struct {
	Txn *Txn `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTxnRequest) Descriptor deprecated 

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

Deprecated: Use CreateTxnRequest.ProtoReflect.Descriptor instead.

func (*CreateTxnRequest) GetTxn 

func (x *CreateTxnRequest) GetTxn() *Txn

func (*CreateTxnRequest) ProtoMessage 

func (*CreateTxnRequest) ProtoMessage()

func (*CreateTxnRequest) ProtoReflect 

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

func (*CreateTxnRequest) Reset 

func (x *CreateTxnRequest) Reset()

func (*CreateTxnRequest) String 

func (x *CreateTxnRequest) String() string

func (*CreateTxnRequest) Validate 

func (m *CreateTxnRequest) Validate() error

Validate checks the field values on CreateTxnRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateTxnRequest) ValidateAll 

func (m *CreateTxnRequest) ValidateAll() error

ValidateAll checks the field values on CreateTxnRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateTxnRequestMultiError, or nil if none found.

type CreateTxnRequestMultiError 

type CreateTxnRequestMultiError []error

CreateTxnRequestMultiError is an error wrapping multiple validation errors returned by CreateTxnRequest.ValidateAll() if the designated constraints aren't met.

func (CreateTxnRequestMultiError) AllErrors 

func (m CreateTxnRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateTxnRequestMultiError) Error 

func (m CreateTxnRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateTxnRequestValidationError 

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

CreateTxnRequestValidationError is the validation error returned by CreateTxnRequest.Validate if the designated constraints aren't met.

func (CreateTxnRequestValidationError) Cause 

func (e CreateTxnRequestValidationError) Cause() error

Cause function returns cause value.

func (CreateTxnRequestValidationError) Error 

func (e CreateTxnRequestValidationError) Error() string

Error satisfies the builtin error interface

func (CreateTxnRequestValidationError) ErrorName 

func (e CreateTxnRequestValidationError) ErrorName() string

ErrorName returns error name.

func (CreateTxnRequestValidationError) Field 

func (e CreateTxnRequestValidationError) Field() string

Field function returns field value.

func (CreateTxnRequestValidationError) Key 

func (e CreateTxnRequestValidationError) Key() bool

Key function returns key value.

func (CreateTxnRequestValidationError) Reason 

func (e CreateTxnRequestValidationError) Reason() string

Reason function returns reason value.

type CreateTxnResponse 

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

func (*CreateTxnResponse) Descriptor deprecated 

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

Deprecated: Use CreateTxnResponse.ProtoReflect.Descriptor instead.

func (*CreateTxnResponse) ProtoMessage 

func (*CreateTxnResponse) ProtoMessage()

func (*CreateTxnResponse) ProtoReflect 

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

func (*CreateTxnResponse) Reset 

func (x *CreateTxnResponse) Reset()

func (*CreateTxnResponse) String 

func (x *CreateTxnResponse) String() string

func (*CreateTxnResponse) Validate 

func (m *CreateTxnResponse) Validate() error

Validate checks the field values on CreateTxnResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CreateTxnResponse) ValidateAll 

func (m *CreateTxnResponse) ValidateAll() error

ValidateAll checks the field values on CreateTxnResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateTxnResponseMultiError, or nil if none found.

type CreateTxnResponseMultiError 

type CreateTxnResponseMultiError []error

CreateTxnResponseMultiError is an error wrapping multiple validation errors returned by CreateTxnResponse.ValidateAll() if the designated constraints aren't met.

func (CreateTxnResponseMultiError) AllErrors 

func (m CreateTxnResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CreateTxnResponseMultiError) Error 

func (m CreateTxnResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CreateTxnResponseValidationError 

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

CreateTxnResponseValidationError is the validation error returned by CreateTxnResponse.Validate if the designated constraints aren't met.

func (CreateTxnResponseValidationError) Cause 

func (e CreateTxnResponseValidationError) Cause() error

Cause function returns cause value.

func (CreateTxnResponseValidationError) Error 

func (e CreateTxnResponseValidationError) Error() string

Error satisfies the builtin error interface

func (CreateTxnResponseValidationError) ErrorName 

func (e CreateTxnResponseValidationError) ErrorName() string

ErrorName returns error name.

func (CreateTxnResponseValidationError) Field 

func (e CreateTxnResponseValidationError) Field() string

Field function returns field value.

func (CreateTxnResponseValidationError) Key 

func (e CreateTxnResponseValidationError) Key() bool

Key function returns key value.

func (CreateTxnResponseValidationError) Reason 

func (e CreateTxnResponseValidationError) Reason() string

Reason function returns reason value.

type Delete 

type Delete struct {
	Key *KeyEntry `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*Delete) Descriptor deprecated 

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

Deprecated: Use Delete.ProtoReflect.Descriptor instead.

func (*Delete) GetKey 

func (x *Delete) GetKey() *KeyEntry

func (*Delete) ProtoMessage 

func (*Delete) ProtoMessage()

func (*Delete) ProtoReflect 

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

func (*Delete) Reset 

func (x *Delete) Reset()

func (*Delete) String 

func (x *Delete) String() string

func (*Delete) Validate 

func (m *Delete) Validate() error

Validate checks the field values on Delete with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Delete) ValidateAll 

func (m *Delete) ValidateAll() error

ValidateAll checks the field values on Delete with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteMultiError, or nil if none found.

type DeleteMultiError 

type DeleteMultiError []error

DeleteMultiError is an error wrapping multiple validation errors returned by Delete.ValidateAll() if the designated constraints aren't met.

func (DeleteMultiError) AllErrors 

func (m DeleteMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteMultiError) Error 

func (m DeleteMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type DeleteValidationError 

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

DeleteValidationError is the validation error returned by Delete.Validate if the designated constraints aren't met.

func (DeleteValidationError) Cause 

func (e DeleteValidationError) Cause() error

Cause function returns cause value.

func (DeleteValidationError) Error 

func (e DeleteValidationError) Error() string

Error satisfies the builtin error interface

func (DeleteValidationError) ErrorName 

func (e DeleteValidationError) ErrorName() string

ErrorName returns error name.

func (DeleteValidationError) Field 

func (e DeleteValidationError) Field() string

Field function returns field value.

func (DeleteValidationError) Key 

func (e DeleteValidationError) Key() bool

Key function returns key value.

func (DeleteValidationError) Reason 

func (e DeleteValidationError) Reason() string

Reason function returns reason value.

type Get 

type Get struct {
	Key *KeyEntry `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Basic statement

func (*Get) Descriptor deprecated 

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

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) GetKey 

func (x *Get) GetKey() *KeyEntry

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) ProtoReflect 

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

func (*Get) Reset 

func (x *Get) Reset()

func (*Get) String 

func (x *Get) String() string

func (*Get) Validate 

func (m *Get) Validate() error

Validate checks the field values on Get with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Get) ValidateAll 

func (m *Get) ValidateAll() error

ValidateAll checks the field values on Get with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetMultiError, or nil if none found.

type GetBatchRequest 

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

func (*GetBatchRequest) Descriptor deprecated 

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

Deprecated: Use GetBatchRequest.ProtoReflect.Descriptor instead.

func (*GetBatchRequest) ProtoMessage 

func (*GetBatchRequest) ProtoMessage()

func (*GetBatchRequest) ProtoReflect 

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

func (*GetBatchRequest) Reset 

func (x *GetBatchRequest) Reset()

func (*GetBatchRequest) String 

func (x *GetBatchRequest) String() string

func (*GetBatchRequest) Validate 

func (m *GetBatchRequest) Validate() error

Validate checks the field values on GetBatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetBatchRequest) ValidateAll 

func (m *GetBatchRequest) ValidateAll() error

ValidateAll checks the field values on GetBatchRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetBatchRequestMultiError, or nil if none found.

type GetBatchRequestMultiError 

type GetBatchRequestMultiError []error

GetBatchRequestMultiError is an error wrapping multiple validation errors returned by GetBatchRequest.ValidateAll() if the designated constraints aren't met.

func (GetBatchRequestMultiError) AllErrors 

func (m GetBatchRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetBatchRequestMultiError) Error 

func (m GetBatchRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetBatchRequestValidationError 

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

GetBatchRequestValidationError is the validation error returned by GetBatchRequest.Validate if the designated constraints aren't met.

func (GetBatchRequestValidationError) Cause 

func (e GetBatchRequestValidationError) Cause() error

Cause function returns cause value.

func (GetBatchRequestValidationError) Error 

func (e GetBatchRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetBatchRequestValidationError) ErrorName 

func (e GetBatchRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetBatchRequestValidationError) Field 

func (e GetBatchRequestValidationError) Field() string

Field function returns field value.

func (GetBatchRequestValidationError) Key 

func (e GetBatchRequestValidationError) Key() bool

Key function returns key value.

func (GetBatchRequestValidationError) Reason 

func (e GetBatchRequestValidationError) Reason() string

Reason function returns reason value.

type GetBatchResponse 

type GetBatchResponse struct {
	Txns []*Txn `protobuf:"bytes,1,rep,name=txns,proto3" json:"txns,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBatchResponse) Descriptor deprecated 

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

Deprecated: Use GetBatchResponse.ProtoReflect.Descriptor instead.

func (*GetBatchResponse) GetTxns 

func (x *GetBatchResponse) GetTxns() []*Txn

func (*GetBatchResponse) ProtoMessage 

func (*GetBatchResponse) ProtoMessage()

func (*GetBatchResponse) ProtoReflect 

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

func (*GetBatchResponse) Reset 

func (x *GetBatchResponse) Reset()

func (*GetBatchResponse) String 

func (x *GetBatchResponse) String() string

func (*GetBatchResponse) Validate 

func (m *GetBatchResponse) Validate() error

Validate checks the field values on GetBatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetBatchResponse) ValidateAll 

func (m *GetBatchResponse) ValidateAll() error

ValidateAll checks the field values on GetBatchResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetBatchResponseMultiError, or nil if none found.

type GetBatchResponseMultiError 

type GetBatchResponseMultiError []error

GetBatchResponseMultiError is an error wrapping multiple validation errors returned by GetBatchResponse.ValidateAll() if the designated constraints aren't met.

func (GetBatchResponseMultiError) AllErrors 

func (m GetBatchResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetBatchResponseMultiError) Error 

func (m GetBatchResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetBatchResponseValidationError 

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

GetBatchResponseValidationError is the validation error returned by GetBatchResponse.Validate if the designated constraints aren't met.

func (GetBatchResponseValidationError) Cause 

func (e GetBatchResponseValidationError) Cause() error

Cause function returns cause value.

func (GetBatchResponseValidationError) Error 

func (e GetBatchResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetBatchResponseValidationError) ErrorName 

func (e GetBatchResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetBatchResponseValidationError) Field 

func (e GetBatchResponseValidationError) Field() string

Field function returns field value.

func (GetBatchResponseValidationError) Key 

func (e GetBatchResponseValidationError) Key() bool

Key function returns key value.

func (GetBatchResponseValidationError) Reason 

func (e GetBatchResponseValidationError) Reason() string

Reason function returns reason value.

type GetGlobalOrderedTxnRequest 

type GetGlobalOrderedTxnRequest struct {
	Txn *Txn `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

Sequencer

func (*GetGlobalOrderedTxnRequest) Descriptor deprecated 

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

Deprecated: Use GetGlobalOrderedTxnRequest.ProtoReflect.Descriptor instead.

func (*GetGlobalOrderedTxnRequest) GetTxn 

func (x *GetGlobalOrderedTxnRequest) GetTxn() *Txn

func (*GetGlobalOrderedTxnRequest) ProtoMessage 

func (*GetGlobalOrderedTxnRequest) ProtoMessage()

func (*GetGlobalOrderedTxnRequest) ProtoReflect 

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

func (*GetGlobalOrderedTxnRequest) Reset 

func (x *GetGlobalOrderedTxnRequest) Reset()

func (*GetGlobalOrderedTxnRequest) String 

func (x *GetGlobalOrderedTxnRequest) String() string

func (*GetGlobalOrderedTxnRequest) Validate 

func (m *GetGlobalOrderedTxnRequest) Validate() error

Validate checks the field values on GetGlobalOrderedTxnRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetGlobalOrderedTxnRequest) ValidateAll 

func (m *GetGlobalOrderedTxnRequest) ValidateAll() error

ValidateAll checks the field values on GetGlobalOrderedTxnRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetGlobalOrderedTxnRequestMultiError, or nil if none found.

type GetGlobalOrderedTxnRequestMultiError 

type GetGlobalOrderedTxnRequestMultiError []error

GetGlobalOrderedTxnRequestMultiError is an error wrapping multiple validation errors returned by GetGlobalOrderedTxnRequest.ValidateAll() if the designated constraints aren't met.

func (GetGlobalOrderedTxnRequestMultiError) AllErrors 

func (m GetGlobalOrderedTxnRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetGlobalOrderedTxnRequestMultiError) Error 

func (m GetGlobalOrderedTxnRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetGlobalOrderedTxnRequestValidationError 

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

GetGlobalOrderedTxnRequestValidationError is the validation error returned by GetGlobalOrderedTxnRequest.Validate if the designated constraints aren't met.

func (GetGlobalOrderedTxnRequestValidationError) Cause 

func (e GetGlobalOrderedTxnRequestValidationError) Cause() error

Cause function returns cause value.

func (GetGlobalOrderedTxnRequestValidationError) Error 

func (e GetGlobalOrderedTxnRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetGlobalOrderedTxnRequestValidationError) ErrorName 

func (e GetGlobalOrderedTxnRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetGlobalOrderedTxnRequestValidationError) Field 

func (e GetGlobalOrderedTxnRequestValidationError) Field() string

Field function returns field value.

func (GetGlobalOrderedTxnRequestValidationError) Key 

func (e GetGlobalOrderedTxnRequestValidationError) Key() bool

Key function returns key value.

func (GetGlobalOrderedTxnRequestValidationError) Reason 

func (e GetGlobalOrderedTxnRequestValidationError) Reason() string

Reason function returns reason value.

type GetGlobalOrderedTxnResponse 

type GetGlobalOrderedTxnResponse struct {
	Txn *Txn `protobuf:"bytes,1,opt,name=txn,proto3" json:"txn,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGlobalOrderedTxnResponse) Descriptor deprecated 

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

Deprecated: Use GetGlobalOrderedTxnResponse.ProtoReflect.Descriptor instead.

func (*GetGlobalOrderedTxnResponse) GetTxn 

func (x *GetGlobalOrderedTxnResponse) GetTxn() *Txn

func (*GetGlobalOrderedTxnResponse) ProtoMessage 

func (*GetGlobalOrderedTxnResponse) ProtoMessage()

func (*GetGlobalOrderedTxnResponse) ProtoReflect 

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

func (*GetGlobalOrderedTxnResponse) Reset 

func (x *GetGlobalOrderedTxnResponse) Reset()

func (*GetGlobalOrderedTxnResponse) String 

func (x *GetGlobalOrderedTxnResponse) String() string

func (*GetGlobalOrderedTxnResponse) Validate 

func (m *GetGlobalOrderedTxnResponse) Validate() error

Validate checks the field values on GetGlobalOrderedTxnResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetGlobalOrderedTxnResponse) ValidateAll 

func (m *GetGlobalOrderedTxnResponse) ValidateAll() error

ValidateAll checks the field values on GetGlobalOrderedTxnResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetGlobalOrderedTxnResponseMultiError, or nil if none found.

type GetGlobalOrderedTxnResponseMultiError 

type GetGlobalOrderedTxnResponseMultiError []error

GetGlobalOrderedTxnResponseMultiError is an error wrapping multiple validation errors returned by GetGlobalOrderedTxnResponse.ValidateAll() if the designated constraints aren't met.

func (GetGlobalOrderedTxnResponseMultiError) AllErrors 

func (m GetGlobalOrderedTxnResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetGlobalOrderedTxnResponseMultiError) Error 

func (m GetGlobalOrderedTxnResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetGlobalOrderedTxnResponseValidationError 

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

GetGlobalOrderedTxnResponseValidationError is the validation error returned by GetGlobalOrderedTxnResponse.Validate if the designated constraints aren't met.

func (GetGlobalOrderedTxnResponseValidationError) Cause 

func (e GetGlobalOrderedTxnResponseValidationError) Cause() error

Cause function returns cause value.

func (GetGlobalOrderedTxnResponseValidationError) Error 

func (e GetGlobalOrderedTxnResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GetGlobalOrderedTxnResponseValidationError) ErrorName 

func (e GetGlobalOrderedTxnResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GetGlobalOrderedTxnResponseValidationError) Field 

func (e GetGlobalOrderedTxnResponseValidationError) Field() string

Field function returns field value.

func (GetGlobalOrderedTxnResponseValidationError) Key 

func (e GetGlobalOrderedTxnResponseValidationError) Key() bool

Key function returns key value.

func (GetGlobalOrderedTxnResponseValidationError) Reason 

func (e GetGlobalOrderedTxnResponseValidationError) Reason() string

Reason function returns reason value.

type GetMultiError 

type GetMultiError []error

GetMultiError is an error wrapping multiple validation errors returned by Get.ValidateAll() if the designated constraints aren't met.

func (GetMultiError) AllErrors 

func (m GetMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetMultiError) Error 

func (m GetMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetValidationError 

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

GetValidationError is the validation error returned by Get.Validate if the designated constraints aren't met.

func (GetValidationError) Cause 

func (e GetValidationError) Cause() error

Cause function returns cause value.

func (GetValidationError) Error 

func (e GetValidationError) Error() string

Error satisfies the builtin error interface

func (GetValidationError) ErrorName 

func (e GetValidationError) ErrorName() string

ErrorName returns error name.

func (GetValidationError) Field 

func (e GetValidationError) Field() string

Field function returns field value.

func (GetValidationError) Key 

func (e GetValidationError) Key() bool

Key function returns key value.

func (GetValidationError) Reason 

func (e GetValidationError) Reason() string

Reason function returns reason value.

type KeyEntry 

type KeyEntry struct {
	Key     []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Master  uint32 `protobuf:"varint,2,opt,name=master,proto3" json:"master,omitempty"`
	Counter uint64 `protobuf:"varint,3,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyEntry) Descriptor deprecated 

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

Deprecated: Use KeyEntry.ProtoReflect.Descriptor instead.

func (*KeyEntry) GetCounter 

func (x *KeyEntry) GetCounter() uint64

func (*KeyEntry) GetKey 

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

func (*KeyEntry) GetMaster 

func (x *KeyEntry) GetMaster() uint32

func (*KeyEntry) ProtoMessage 

func (*KeyEntry) ProtoMessage()

func (*KeyEntry) ProtoReflect 

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

func (*KeyEntry) Reset 

func (x *KeyEntry) Reset()

func (*KeyEntry) String 

func (x *KeyEntry) String() string

func (*KeyEntry) Validate 

func (m *KeyEntry) Validate() error

Validate checks the field values on KeyEntry with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*KeyEntry) ValidateAll 

func (m *KeyEntry) ValidateAll() error

ValidateAll checks the field values on KeyEntry with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in KeyEntryMultiError, or nil if none found.

type KeyEntryMultiError 

type KeyEntryMultiError []error

KeyEntryMultiError is an error wrapping multiple validation errors returned by KeyEntry.ValidateAll() if the designated constraints aren't met.

func (KeyEntryMultiError) AllErrors 

func (m KeyEntryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (KeyEntryMultiError) Error 

func (m KeyEntryMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type KeyEntryValidationError 

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

KeyEntryValidationError is the validation error returned by KeyEntry.Validate if the designated constraints aren't met.

func (KeyEntryValidationError) Cause 

func (e KeyEntryValidationError) Cause() error

Cause function returns cause value.

func (KeyEntryValidationError) Error 

func (e KeyEntryValidationError) Error() string

Error satisfies the builtin error interface

func (KeyEntryValidationError) ErrorName 

func (e KeyEntryValidationError) ErrorName() string

ErrorName returns error name.

func (KeyEntryValidationError) Field 

func (e KeyEntryValidationError) Field() string

Field function returns field value.

func (KeyEntryValidationError) Key 

func (e KeyEntryValidationError) Key() bool

Key function returns key value.

func (KeyEntryValidationError) Reason 

func (e KeyEntryValidationError) Reason() string

Reason function returns reason value.

type LookupMasterRequest 

type LookupMasterRequest struct {
	TxnId uint64   `protobuf:"varint,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	Keys  [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupMasterRequest) Descriptor deprecated 

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

Deprecated: Use LookupMasterRequest.ProtoReflect.Descriptor instead.

func (*LookupMasterRequest) GetKeys 

func (x *LookupMasterRequest) GetKeys() [][]byte

func (*LookupMasterRequest) GetTxnId 

func (x *LookupMasterRequest) GetTxnId() uint64

func (*LookupMasterRequest) ProtoMessage 

func (*LookupMasterRequest) ProtoMessage()

func (*LookupMasterRequest) ProtoReflect 

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

func (*LookupMasterRequest) Reset 

func (x *LookupMasterRequest) Reset()

func (*LookupMasterRequest) String 

func (x *LookupMasterRequest) String() string

func (*LookupMasterRequest) Validate 

func (m *LookupMasterRequest) Validate() error

Validate checks the field values on LookupMasterRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LookupMasterRequest) ValidateAll 

func (m *LookupMasterRequest) ValidateAll() error

ValidateAll checks the field values on LookupMasterRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LookupMasterRequestMultiError, or nil if none found.

type LookupMasterRequestMultiError 

type LookupMasterRequestMultiError []error

LookupMasterRequestMultiError is an error wrapping multiple validation errors returned by LookupMasterRequest.ValidateAll() if the designated constraints aren't met.

func (LookupMasterRequestMultiError) AllErrors 

func (m LookupMasterRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LookupMasterRequestMultiError) Error 

func (m LookupMasterRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LookupMasterRequestValidationError 

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

LookupMasterRequestValidationError is the validation error returned by LookupMasterRequest.Validate if the designated constraints aren't met.

func (LookupMasterRequestValidationError) Cause 

func (e LookupMasterRequestValidationError) Cause() error

Cause function returns cause value.

func (LookupMasterRequestValidationError) Error 

func (e LookupMasterRequestValidationError) Error() string

Error satisfies the builtin error interface

func (LookupMasterRequestValidationError) ErrorName 

func (e LookupMasterRequestValidationError) ErrorName() string

ErrorName returns error name.

func (LookupMasterRequestValidationError) Field 

func (e LookupMasterRequestValidationError) Field() string

Field function returns field value.

func (LookupMasterRequestValidationError) Key 

func (e LookupMasterRequestValidationError) Key() bool

Key function returns key value.

func (LookupMasterRequestValidationError) Reason 

func (e LookupMasterRequestValidationError) Reason() string

Reason function returns reason value.

type LookupMasterResponse 

type LookupMasterResponse struct {
	TxnId      uint64      `protobuf:"varint,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	KeyEntries []*KeyEntry `protobuf:"bytes,2,rep,name=key_entries,json=keyEntries,proto3" json:"key_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupMasterResponse) Descriptor deprecated 

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

Deprecated: Use LookupMasterResponse.ProtoReflect.Descriptor instead.

func (*LookupMasterResponse) GetKeyEntries 

func (x *LookupMasterResponse) GetKeyEntries() []*KeyEntry

func (*LookupMasterResponse) GetTxnId 

func (x *LookupMasterResponse) GetTxnId() uint64

func (*LookupMasterResponse) ProtoMessage 

func (*LookupMasterResponse) ProtoMessage()

func (*LookupMasterResponse) ProtoReflect 

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

func (*LookupMasterResponse) Reset 

func (x *LookupMasterResponse) Reset()

func (*LookupMasterResponse) String 

func (x *LookupMasterResponse) String() string

func (*LookupMasterResponse) Validate 

func (m *LookupMasterResponse) Validate() error

Validate checks the field values on LookupMasterResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LookupMasterResponse) ValidateAll 

func (m *LookupMasterResponse) ValidateAll() error

ValidateAll checks the field values on LookupMasterResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LookupMasterResponseMultiError, or nil if none found.

type LookupMasterResponseMultiError 

type LookupMasterResponseMultiError []error

LookupMasterResponseMultiError is an error wrapping multiple validation errors returned by LookupMasterResponse.ValidateAll() if the designated constraints aren't met.

func (LookupMasterResponseMultiError) AllErrors 

func (m LookupMasterResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LookupMasterResponseMultiError) Error 

func (m LookupMasterResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LookupMasterResponseValidationError 

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

LookupMasterResponseValidationError is the validation error returned by LookupMasterResponse.Validate if the designated constraints aren't met.

func (LookupMasterResponseValidationError) Cause 

func (e LookupMasterResponseValidationError) Cause() error

Cause function returns cause value.

func (LookupMasterResponseValidationError) Error 

func (e LookupMasterResponseValidationError) Error() string

Error satisfies the builtin error interface

func (LookupMasterResponseValidationError) ErrorName 

func (e LookupMasterResponseValidationError) ErrorName() string

ErrorName returns error name.

func (LookupMasterResponseValidationError) Field 

func (e LookupMasterResponseValidationError) Field() string

Field function returns field value.

func (LookupMasterResponseValidationError) Key 

func (e LookupMasterResponseValidationError) Key() bool

Key function returns key value.

func (LookupMasterResponseValidationError) Reason 

func (e LookupMasterResponseValidationError) Reason() string

Reason function returns reason value.

type LookupServiceClient 

type LookupServiceClient interface {
	LookupMaster(ctx context.Context, in *LookupMasterRequest, opts ...grpc.CallOption) (*LookupMasterResponse, error)
}

LookupServiceClient is the client API for LookupService 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 NewLookupServiceClient 

func NewLookupServiceClient(cc grpc.ClientConnInterface) LookupServiceClient

type LookupServiceServer 

type LookupServiceServer interface {
	LookupMaster(context.Context, *LookupMasterRequest) (*LookupMasterResponse, error)
	// contains filtered or unexported methods
}

LookupServiceServer is the server API for LookupService service. All implementations must embed UnimplementedLookupServiceServer for forward compatibility

type MachineInfo 

type MachineInfo struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Replica uint64 `protobuf:"varint,2,opt,name=replica,proto3" json:"replica,omitempty"`
	Host    string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Port    uint64 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

Cluster manage

func (*MachineInfo) Descriptor deprecated 

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

Deprecated: Use MachineInfo.ProtoReflect.Descriptor instead.

func (*MachineInfo) GetHost 

func (x *MachineInfo) GetHost() string

func (*MachineInfo) GetId 

func (x *MachineInfo) GetId() uint64

func (*MachineInfo) GetPort 

func (x *MachineInfo) GetPort() uint64

func (*MachineInfo) GetReplica 

func (x *MachineInfo) GetReplica() uint64

func (*MachineInfo) ProtoMessage 

func (*MachineInfo) ProtoMessage()

func (*MachineInfo) ProtoReflect 

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

func (*MachineInfo) Reset 

func (x *MachineInfo) Reset()

func (*MachineInfo) String 

func (x *MachineInfo) String() string

func (*MachineInfo) Validate 

func (m *MachineInfo) Validate() error

Validate checks the field values on MachineInfo with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*MachineInfo) ValidateAll 

func (m *MachineInfo) ValidateAll() error

ValidateAll checks the field values on MachineInfo with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in MachineInfoMultiError, or nil if none found.

type MachineInfoMultiError 

type MachineInfoMultiError []error

MachineInfoMultiError is an error wrapping multiple validation errors returned by MachineInfo.ValidateAll() if the designated constraints aren't met.

func (MachineInfoMultiError) AllErrors 

func (m MachineInfoMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MachineInfoMultiError) Error 

func (m MachineInfoMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type MachineInfoValidationError 

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

MachineInfoValidationError is the validation error returned by MachineInfo.Validate if the designated constraints aren't met.

func (MachineInfoValidationError) Cause 

func (e MachineInfoValidationError) Cause() error

Cause function returns cause value.

func (MachineInfoValidationError) Error 

func (e MachineInfoValidationError) Error() string

Error satisfies the builtin error interface

func (MachineInfoValidationError) ErrorName 

func (e MachineInfoValidationError) ErrorName() string

ErrorName returns error name.

func (MachineInfoValidationError) Field 

func (e MachineInfoValidationError) Field() string

Field function returns field value.

func (MachineInfoValidationError) Key 

func (e MachineInfoValidationError) Key() bool

Key function returns key value.

func (MachineInfoValidationError) Reason 

func (e MachineInfoValidationError) Reason() string

Reason function returns reason value.

type Scan 

type Scan struct {
	StartKey *KeyEntry `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   *KeyEntry `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Scan) Descriptor deprecated 

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

Deprecated: Use Scan.ProtoReflect.Descriptor instead.

func (*Scan) GetEndKey 

func (x *Scan) GetEndKey() *KeyEntry

func (*Scan) GetStartKey 

func (x *Scan) GetStartKey() *KeyEntry

func (*Scan) ProtoMessage 

func (*Scan) ProtoMessage()

func (*Scan) ProtoReflect 

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

func (*Scan) Reset 

func (x *Scan) Reset()

func (*Scan) String 

func (x *Scan) String() string

func (*Scan) Validate 

func (m *Scan) Validate() error

Validate checks the field values on Scan with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Scan) ValidateAll 

func (m *Scan) ValidateAll() error

ValidateAll checks the field values on Scan with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ScanMultiError, or nil if none found.

type ScanMultiError 

type ScanMultiError []error

ScanMultiError is an error wrapping multiple validation errors returned by Scan.ValidateAll() if the designated constraints aren't met.

func (ScanMultiError) AllErrors 

func (m ScanMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ScanMultiError) Error 

func (m ScanMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ScanValidationError 

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

ScanValidationError is the validation error returned by Scan.Validate if the designated constraints aren't met.

func (ScanValidationError) Cause 

func (e ScanValidationError) Cause() error

Cause function returns cause value.

func (ScanValidationError) Error 

func (e ScanValidationError) Error() string

Error satisfies the builtin error interface

func (ScanValidationError) ErrorName 

func (e ScanValidationError) ErrorName() string

ErrorName returns error name.

func (ScanValidationError) Field 

func (e ScanValidationError) Field() string

Field function returns field value.

func (ScanValidationError) Key 

func (e ScanValidationError) Key() bool

Key function returns key value.

func (ScanValidationError) Reason 

func (e ScanValidationError) Reason() string

Reason function returns reason value.

type SequencerServiceClient 

type SequencerServiceClient interface {
	// Entry point
	CreateTxn(ctx context.Context, in *CreateTxnRequest, opts ...grpc.CallOption) (*CreateTxnResponse, error)
	// Sequencer interal use
	GetBatch(ctx context.Context, in *GetBatchRequest, opts ...grpc.CallOption) (*GetBatchResponse, error)
}

SequencerServiceClient is the client API for SequencerService 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 NewSequencerServiceClient 

func NewSequencerServiceClient(cc grpc.ClientConnInterface) SequencerServiceClient

type SequencerServiceServer 

type SequencerServiceServer interface {
	// Entry point
	CreateTxn(context.Context, *CreateTxnRequest) (*CreateTxnResponse, error)
	// Sequencer interal use
	GetBatch(context.Context, *GetBatchRequest) (*GetBatchResponse, error)
	// contains filtered or unexported methods
}

SequencerServiceServer is the server API for SequencerService service. All implementations must embed UnimplementedSequencerServiceServer for forward compatibility

type Set 

type Set struct {
	Key   *KeyEntry `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Valie []byte    `protobuf:"bytes,2,opt,name=valie,proto3" json:"valie,omitempty"`
	// contains filtered or unexported fields
}

func (*Set) Descriptor deprecated 

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

Deprecated: Use Set.ProtoReflect.Descriptor instead.

func (*Set) GetKey 

func (x *Set) GetKey() *KeyEntry

func (*Set) GetValie 

func (x *Set) GetValie() []byte

func (*Set) ProtoMessage 

func (*Set) ProtoMessage()

func (*Set) ProtoReflect 

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

func (*Set) Reset 

func (x *Set) Reset()

func (*Set) String 

func (x *Set) String() string

func (*Set) Validate 

func (m *Set) Validate() error

Validate checks the field values on Set with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Set) ValidateAll 

func (m *Set) ValidateAll() error

ValidateAll checks the field values on Set with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SetMultiError, or nil if none found.

type SetMultiError 

type SetMultiError []error

SetMultiError is an error wrapping multiple validation errors returned by Set.ValidateAll() if the designated constraints aren't met.

func (SetMultiError) AllErrors 

func (m SetMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SetMultiError) Error 

func (m SetMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SetValidationError 

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

SetValidationError is the validation error returned by Set.Validate if the designated constraints aren't met.

func (SetValidationError) Cause 

func (e SetValidationError) Cause() error

Cause function returns cause value.

func (SetValidationError) Error 

func (e SetValidationError) Error() string

Error satisfies the builtin error interface

func (SetValidationError) ErrorName 

func (e SetValidationError) ErrorName() string

ErrorName returns error name.

func (SetValidationError) Field 

func (e SetValidationError) Field() string

Field function returns field value.

func (SetValidationError) Key 

func (e SetValidationError) Key() bool

Key function returns key value.

func (SetValidationError) Reason 

func (e SetValidationError) Reason() string

Reason function returns reason value.

type Txn 

type Txn struct {

	// Global order
	TxnId   uint64  `protobuf:"varint,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	TxnType TxnType `protobuf:"varint,2,opt,name=txn_type,json=txnType,proto3,enum=distpebble.v1.TxnType" json:"txn_type,omitempty"`
	// Key sets
	ReadSet      []*KeyEntry `protobuf:"bytes,20,rep,name=read_set,json=readSet,proto3" json:"read_set,omitempty"`
	WriteSet     []*KeyEntry `protobuf:"bytes,21,rep,name=write_set,json=writeSet,proto3" json:"write_set,omitempty"`
	ReadWriteSet []*KeyEntry `protobuf:"bytes,22,rep,name=read_write_set,json=readWriteSet,proto3" json:"read_write_set,omitempty"`
	// Reader and writer
	Readers []uint64 `protobuf:"varint,31,rep,packed,name=readers,proto3" json:"readers,omitempty"`
	Writers []uint64 `protobuf:"varint,32,rep,packed,name=writers,proto3" json:"writers,omitempty"`
	// contains filtered or unexported fields
}

func (*Txn) Descriptor deprecated 

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

Deprecated: Use Txn.ProtoReflect.Descriptor instead.

func (*Txn) GetReadSet 

func (x *Txn) GetReadSet() []*KeyEntry

func (*Txn) GetReadWriteSet 

func (x *Txn) GetReadWriteSet() []*KeyEntry

func (*Txn) GetReaders 

func (x *Txn) GetReaders() []uint64

func (*Txn) GetTxnId 

func (x *Txn) GetTxnId() uint64

func (*Txn) GetTxnType 

func (x *Txn) GetTxnType() TxnType

func (*Txn) GetWriteSet 

func (x *Txn) GetWriteSet() []*KeyEntry

func (*Txn) GetWriters 

func (x *Txn) GetWriters() []uint64

func (*Txn) ProtoMessage 

func (*Txn) ProtoMessage()

func (*Txn) ProtoReflect 

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

func (*Txn) Reset 

func (x *Txn) Reset()

func (*Txn) String 

func (x *Txn) String() string

func (*Txn) Validate 

func (m *Txn) Validate() error

Validate checks the field values on Txn with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Txn) ValidateAll 

func (m *Txn) ValidateAll() error

ValidateAll checks the field values on Txn with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TxnMultiError, or nil if none found.

type TxnMultiError 

type TxnMultiError []error

TxnMultiError is an error wrapping multiple validation errors returned by Txn.ValidateAll() if the designated constraints aren't met.

func (TxnMultiError) AllErrors 

func (m TxnMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TxnMultiError) Error 

func (m TxnMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TxnType 

type TxnType int32
const (
	TxnType_UNKNOWN                 TxnType = 0
	TxnType_SINGLE_HOME             TxnType = 1
	TxnType_MULTI_HOME_OR_LOCK_ONLY TxnType = 2
)

func (TxnType) Descriptor 

func (TxnType) Descriptor() protoreflect.EnumDescriptor

func (TxnType) Enum 

func (x TxnType) Enum() *TxnType

func (TxnType) EnumDescriptor deprecated 

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

Deprecated: Use TxnType.Descriptor instead.

func (TxnType) Number 

func (x TxnType) Number() protoreflect.EnumNumber

func (TxnType) String 

func (x TxnType) String() string

func (TxnType) Type 

func (TxnType) Type() protoreflect.EnumType

type TxnValidationError 

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

TxnValidationError is the validation error returned by Txn.Validate if the designated constraints aren't met.

func (TxnValidationError) Cause 

func (e TxnValidationError) Cause() error

Cause function returns cause value.

func (TxnValidationError) Error 

func (e TxnValidationError) Error() string

Error satisfies the builtin error interface

func (TxnValidationError) ErrorName 

func (e TxnValidationError) ErrorName() string

ErrorName returns error name.

func (TxnValidationError) Field 

func (e TxnValidationError) Field() string

Field function returns field value.

func (TxnValidationError) Key 

func (e TxnValidationError) Key() bool

Key function returns key value.

func (TxnValidationError) Reason 

func (e TxnValidationError) Reason() string

Reason function returns reason value.

type UnimplementedLookupServiceServer 

type UnimplementedLookupServiceServer struct {
}

UnimplementedLookupServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLookupServiceServer) LookupMaster 

func (UnimplementedLookupServiceServer) LookupMaster(context.Context, *LookupMasterRequest) (*LookupMasterResponse, error)

type UnimplementedSequencerServiceServer 

type UnimplementedSequencerServiceServer struct {
}

UnimplementedSequencerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerServiceServer) CreateTxn 

func (UnimplementedSequencerServiceServer) CreateTxn(context.Context, *CreateTxnRequest) (*CreateTxnResponse, error)

func (UnimplementedSequencerServiceServer) GetBatch 

func (UnimplementedSequencerServiceServer) GetBatch(context.Context, *GetBatchRequest) (*GetBatchResponse, error)

type UnsafeLookupServiceServer 

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

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

type UnsafeSequencerServiceServer 

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

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

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.