shared

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_shared_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AccessDenied added in v0.9.0 

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

func (*AccessDenied) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use AccessDenied.ProtoReflect.Descriptor instead.

func (*AccessDenied) ProtoMessage added in v0.9.0 

func (*AccessDenied) ProtoMessage()

func (*AccessDenied) ProtoReflect added in v0.9.0 

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

func (*AccessDenied) Reset added in v0.9.0 

func (x *AccessDenied) Reset()

func (*AccessDenied) String added in v0.9.0 

func (x *AccessDenied) String() string

type AllStreamPosition added in v0.9.0 

type AllStreamPosition struct {
	CommitPosition  uint64 `protobuf:"varint,1,opt,name=commit_position,json=commitPosition,proto3" json:"commit_position,omitempty"`
	PreparePosition uint64 `protobuf:"varint,2,opt,name=prepare_position,json=preparePosition,proto3" json:"prepare_position,omitempty"`
	// contains filtered or unexported fields
}

func (*AllStreamPosition) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use AllStreamPosition.ProtoReflect.Descriptor instead.

func (*AllStreamPosition) GetCommitPosition added in v0.9.0 

func (x *AllStreamPosition) GetCommitPosition() uint64

func (*AllStreamPosition) GetPreparePosition added in v0.9.0 

func (x *AllStreamPosition) GetPreparePosition() uint64

func (*AllStreamPosition) ProtoMessage added in v0.9.0 

func (*AllStreamPosition) ProtoMessage()

func (*AllStreamPosition) ProtoReflect added in v0.9.0 

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

func (*AllStreamPosition) Reset added in v0.9.0 

func (x *AllStreamPosition) Reset()

func (*AllStreamPosition) String added in v0.9.0 

func (x *AllStreamPosition) String() string

type BadRequest added in v0.9.0 

type BadRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*BadRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use BadRequest.ProtoReflect.Descriptor instead.

func (*BadRequest) GetMessage added in v0.9.0 

func (x *BadRequest) GetMessage() string

func (*BadRequest) ProtoMessage added in v0.9.0 

func (*BadRequest) ProtoMessage()

func (*BadRequest) ProtoReflect added in v0.9.0 

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

func (*BadRequest) Reset added in v0.9.0 

func (x *BadRequest) Reset()

func (*BadRequest) String added in v0.9.0 

func (x *BadRequest) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type InvalidTransaction added in v0.9.0 

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

func (*InvalidTransaction) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use InvalidTransaction.ProtoReflect.Descriptor instead.

func (*InvalidTransaction) ProtoMessage added in v0.9.0 

func (*InvalidTransaction) ProtoMessage()

func (*InvalidTransaction) ProtoReflect added in v0.9.0 

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

func (*InvalidTransaction) Reset added in v0.9.0 

func (x *InvalidTransaction) Reset()

func (*InvalidTransaction) String added in v0.9.0 

func (x *InvalidTransaction) String() string

type MaximumAppendSizeExceeded added in v0.9.0 

type MaximumAppendSizeExceeded struct {
	MaxAppendSize uint32 `protobuf:"varint,1,opt,name=maxAppendSize,proto3" json:"maxAppendSize,omitempty"`
	// contains filtered or unexported fields
}

func (*MaximumAppendSizeExceeded) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use MaximumAppendSizeExceeded.ProtoReflect.Descriptor instead.

func (*MaximumAppendSizeExceeded) GetMaxAppendSize added in v0.9.0 

func (x *MaximumAppendSizeExceeded) GetMaxAppendSize() uint32

func (*MaximumAppendSizeExceeded) ProtoMessage added in v0.9.0 

func (*MaximumAppendSizeExceeded) ProtoMessage()

func (*MaximumAppendSizeExceeded) ProtoReflect added in v0.9.0 

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

func (*MaximumAppendSizeExceeded) Reset added in v0.9.0 

func (x *MaximumAppendSizeExceeded) Reset()

func (*MaximumAppendSizeExceeded) String added in v0.9.0 

func (x *MaximumAppendSizeExceeded) String() string

type StreamDeleted added in v0.9.0 

type StreamDeleted struct {
	StreamIdentifier *StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamDeleted) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StreamDeleted.ProtoReflect.Descriptor instead.

func (*StreamDeleted) GetStreamIdentifier added in v0.9.0 

func (x *StreamDeleted) GetStreamIdentifier() *StreamIdentifier

func (*StreamDeleted) ProtoMessage added in v0.9.0 

func (*StreamDeleted) ProtoMessage()

func (*StreamDeleted) ProtoReflect added in v0.9.0 

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

func (*StreamDeleted) Reset added in v0.9.0 

func (x *StreamDeleted) Reset()

func (*StreamDeleted) String added in v0.9.0 

func (x *StreamDeleted) String() string

type StreamIdentifier 

type StreamIdentifier struct {
	StreamName []byte `protobuf:"bytes,3,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamIdentifier) Descriptor deprecated 

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

Deprecated: Use StreamIdentifier.ProtoReflect.Descriptor instead.

func (*StreamIdentifier) GetStreamName 

func (x *StreamIdentifier) GetStreamName() []byte

func (*StreamIdentifier) ProtoMessage 

func (*StreamIdentifier) ProtoMessage()

func (*StreamIdentifier) ProtoReflect 

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

func (*StreamIdentifier) Reset 

func (x *StreamIdentifier) Reset()

func (*StreamIdentifier) String 

func (x *StreamIdentifier) String() string

type Timeout added in v0.9.0 

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

func (*Timeout) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Timeout.ProtoReflect.Descriptor instead.

func (*Timeout) ProtoMessage added in v0.9.0 

func (*Timeout) ProtoMessage()

func (*Timeout) ProtoReflect added in v0.9.0 

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

func (*Timeout) Reset added in v0.9.0 

func (x *Timeout) Reset()

func (*Timeout) String added in v0.9.0 

func (x *Timeout) String() string

type UUID 

type UUID struct {

	// Types that are assignable to Value:
	//	*UUID_Structured_
	//	*UUID_String_
	Value isUUID_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*UUID) Descriptor deprecated 

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

Deprecated: Use UUID.ProtoReflect.Descriptor instead.

func (*UUID) GetString_ 

func (x *UUID) GetString_() string

func (*UUID) GetStructured 

func (x *UUID) GetStructured() *UUID_Structured

func (*UUID) GetValue 

func (m *UUID) GetValue() isUUID_Value

func (*UUID) ProtoMessage 

func (*UUID) ProtoMessage()

func (*UUID) ProtoReflect 

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

func (*UUID) Reset 

func (x *UUID) Reset()

func (*UUID) String 

func (x *UUID) String() string

type UUID_String_ 

type UUID_String_ struct {
	String_ string `protobuf:"bytes,2,opt,name=string,proto3,oneof"`
}

type UUID_Structured 

type UUID_Structured struct {
	MostSignificantBits  int64 `protobuf:"varint,1,opt,name=most_significant_bits,json=mostSignificantBits,proto3" json:"most_significant_bits,omitempty"`
	LeastSignificantBits int64 `protobuf:"varint,2,opt,name=least_significant_bits,json=leastSignificantBits,proto3" json:"least_significant_bits,omitempty"`
	// contains filtered or unexported fields
}

func (*UUID_Structured) Descriptor deprecated 

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

Deprecated: Use UUID_Structured.ProtoReflect.Descriptor instead.

func (*UUID_Structured) GetLeastSignificantBits 

func (x *UUID_Structured) GetLeastSignificantBits() int64

func (*UUID_Structured) GetMostSignificantBits 

func (x *UUID_Structured) GetMostSignificantBits() int64

func (*UUID_Structured) ProtoMessage 

func (*UUID_Structured) ProtoMessage()

func (*UUID_Structured) ProtoReflect 

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

func (*UUID_Structured) Reset 

func (x *UUID_Structured) Reset()

func (*UUID_Structured) String 

func (x *UUID_Structured) String() string

type UUID_Structured_ 

type UUID_Structured_ struct {
	Structured *UUID_Structured `protobuf:"bytes,1,opt,name=structured,proto3,oneof"`
}

type Unknown added in v0.9.0 

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

func (*Unknown) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Unknown.ProtoReflect.Descriptor instead.

func (*Unknown) ProtoMessage added in v0.9.0 

func (*Unknown) ProtoMessage()

func (*Unknown) ProtoReflect added in v0.9.0 

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

func (*Unknown) Reset added in v0.9.0 

func (x *Unknown) Reset()

func (*Unknown) String added in v0.9.0 

func (x *Unknown) String() string

type WrongExpectedVersion added in v0.9.0 

type WrongExpectedVersion struct {

	// Types that are assignable to CurrentStreamRevisionOption:
	//	*WrongExpectedVersion_CurrentStreamRevision
	//	*WrongExpectedVersion_CurrentNoStream
	CurrentStreamRevisionOption isWrongExpectedVersion_CurrentStreamRevisionOption `protobuf_oneof:"current_stream_revision_option"`
	// Types that are assignable to ExpectedStreamPositionOption:
	//	*WrongExpectedVersion_ExpectedStreamPosition
	//	*WrongExpectedVersion_ExpectedAny
	//	*WrongExpectedVersion_ExpectedStreamExists
	//	*WrongExpectedVersion_ExpectedNoStream
	ExpectedStreamPositionOption isWrongExpectedVersion_ExpectedStreamPositionOption `protobuf_oneof:"expected_stream_position_option"`
	// contains filtered or unexported fields
}

func (*WrongExpectedVersion) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use WrongExpectedVersion.ProtoReflect.Descriptor instead.

func (*WrongExpectedVersion) GetCurrentNoStream added in v0.9.0 

func (x *WrongExpectedVersion) GetCurrentNoStream() *emptypb.Empty

func (*WrongExpectedVersion) GetCurrentStreamRevision added in v0.9.0 

func (x *WrongExpectedVersion) GetCurrentStreamRevision() uint64

func (*WrongExpectedVersion) GetCurrentStreamRevisionOption added in v0.9.0 

func (m *WrongExpectedVersion) GetCurrentStreamRevisionOption() isWrongExpectedVersion_CurrentStreamRevisionOption

func (*WrongExpectedVersion) GetExpectedAny added in v0.9.0 

func (x *WrongExpectedVersion) GetExpectedAny() *emptypb.Empty

func (*WrongExpectedVersion) GetExpectedNoStream added in v0.9.0 

func (x *WrongExpectedVersion) GetExpectedNoStream() *emptypb.Empty

func (*WrongExpectedVersion) GetExpectedStreamExists added in v0.9.0 

func (x *WrongExpectedVersion) GetExpectedStreamExists() *emptypb.Empty

func (*WrongExpectedVersion) GetExpectedStreamPosition added in v0.9.0 

func (x *WrongExpectedVersion) GetExpectedStreamPosition() uint64

func (*WrongExpectedVersion) GetExpectedStreamPositionOption added in v0.9.0 

func (m *WrongExpectedVersion) GetExpectedStreamPositionOption() isWrongExpectedVersion_ExpectedStreamPositionOption

func (*WrongExpectedVersion) ProtoMessage added in v0.9.0 

func (*WrongExpectedVersion) ProtoMessage()

func (*WrongExpectedVersion) ProtoReflect added in v0.9.0 

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

func (*WrongExpectedVersion) Reset added in v0.9.0 

func (x *WrongExpectedVersion) Reset()

func (*WrongExpectedVersion) String added in v0.9.0 

func (x *WrongExpectedVersion) String() string

type WrongExpectedVersion_CurrentNoStream added in v0.9.0 

type WrongExpectedVersion_CurrentNoStream struct {
	CurrentNoStream *emptypb.Empty `protobuf:"bytes,2,opt,name=current_no_stream,json=currentNoStream,proto3,oneof"`
}

type WrongExpectedVersion_CurrentStreamRevision added in v0.9.0 

type WrongExpectedVersion_CurrentStreamRevision struct {
	CurrentStreamRevision uint64 `protobuf:"varint,1,opt,name=current_stream_revision,json=currentStreamRevision,proto3,oneof"`
}

type WrongExpectedVersion_ExpectedAny added in v0.9.0 

type WrongExpectedVersion_ExpectedAny struct {
	ExpectedAny *emptypb.Empty `protobuf:"bytes,4,opt,name=expected_any,json=expectedAny,proto3,oneof"`
}

type WrongExpectedVersion_ExpectedNoStream added in v0.9.0 

type WrongExpectedVersion_ExpectedNoStream struct {
	ExpectedNoStream *emptypb.Empty `protobuf:"bytes,6,opt,name=expected_no_stream,json=expectedNoStream,proto3,oneof"`
}

type WrongExpectedVersion_ExpectedStreamExists added in v0.9.0 

type WrongExpectedVersion_ExpectedStreamExists struct {
	ExpectedStreamExists *emptypb.Empty `protobuf:"bytes,5,opt,name=expected_stream_exists,json=expectedStreamExists,proto3,oneof"`
}

type WrongExpectedVersion_ExpectedStreamPosition added in v0.9.0 

type WrongExpectedVersion_ExpectedStreamPosition struct {
	ExpectedStreamPosition uint64 `protobuf:"varint,3,opt,name=expected_stream_position,json=expectedStreamPosition,proto3,oneof"`
}

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.