streams

package
v2.1.1 Latest Latest
Warning

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

 Go to latest Published: May 24, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ReadReq_Options_ReadDirection_name = map[int32]string{
		0: "Forwards",
		1: "Backwards",
	}
	ReadReq_Options_ReadDirection_value = map[string]int32{
		"Forwards":  0,
		"Backwards": 1,
	}
)

Enum value maps for ReadReq_Options_ReadDirection.

View Source 
var File_streams_proto protoreflect.FileDescriptor
View Source 
var Streams_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "event_store.client.streams.Streams",
	HandlerType: (*StreamsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Delete",
			Handler:    _Streams_Delete_Handler,
		},
		{
			MethodName: "Tombstone",
			Handler:    _Streams_Tombstone_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Read",
			Handler:       _Streams_Read_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Append",
			Handler:       _Streams_Append_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "BatchAppend",
			Handler:       _Streams_BatchAppend_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "streams.proto",
}

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

Functions

func RegisterStreamsServer 

func RegisterStreamsServer(s grpc.ServiceRegistrar, srv StreamsServer)

Types

type AppendReq 

type AppendReq struct {

	// Types that are assignable to Content:
	//	*AppendReq_Options_
	//	*AppendReq_ProposedMessage_
	Content isAppendReq_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*AppendReq) Descriptor deprecated 

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

Deprecated: Use AppendReq.ProtoReflect.Descriptor instead.

func (*AppendReq) GetContent 

func (m *AppendReq) GetContent() isAppendReq_Content

func (*AppendReq) GetOptions 

func (x *AppendReq) GetOptions() *AppendReq_Options

func (*AppendReq) GetProposedMessage 

func (x *AppendReq) GetProposedMessage() *AppendReq_ProposedMessage

func (*AppendReq) ProtoMessage 

func (*AppendReq) ProtoMessage()

func (*AppendReq) ProtoReflect 

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

func (*AppendReq) Reset 

func (x *AppendReq) Reset()

func (*AppendReq) String 

func (x *AppendReq) String() string

type AppendReq_Options 

type AppendReq_Options struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to ExpectedStreamRevision:
	//	*AppendReq_Options_Revision
	//	*AppendReq_Options_NoStream
	//	*AppendReq_Options_Any
	//	*AppendReq_Options_StreamExists
	ExpectedStreamRevision isAppendReq_Options_ExpectedStreamRevision `protobuf_oneof:"expected_stream_revision"`
	// contains filtered or unexported fields
}

func (*AppendReq_Options) Descriptor deprecated 

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

Deprecated: Use AppendReq_Options.ProtoReflect.Descriptor instead.

func (*AppendReq_Options) GetAny 

func (x *AppendReq_Options) GetAny() *shared.Empty

func (*AppendReq_Options) GetExpectedStreamRevision 

func (m *AppendReq_Options) GetExpectedStreamRevision() isAppendReq_Options_ExpectedStreamRevision

func (*AppendReq_Options) GetNoStream 

func (x *AppendReq_Options) GetNoStream() *shared.Empty

func (*AppendReq_Options) GetRevision 

func (x *AppendReq_Options) GetRevision() uint64

func (*AppendReq_Options) GetStreamExists 

func (x *AppendReq_Options) GetStreamExists() *shared.Empty

func (*AppendReq_Options) GetStreamIdentifier 

func (x *AppendReq_Options) GetStreamIdentifier() *shared.StreamIdentifier

func (*AppendReq_Options) ProtoMessage 

func (*AppendReq_Options) ProtoMessage()

func (*AppendReq_Options) ProtoReflect 

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

func (*AppendReq_Options) Reset 

func (x *AppendReq_Options) Reset()

func (*AppendReq_Options) String 

func (x *AppendReq_Options) String() string

type AppendReq_Options_ 

type AppendReq_Options_ struct {
	Options *AppendReq_Options `protobuf:"bytes,1,opt,name=options,proto3,oneof"`
}

type AppendReq_Options_Any 

type AppendReq_Options_Any struct {
	Any *shared.Empty `protobuf:"bytes,4,opt,name=any,proto3,oneof"`
}

type AppendReq_Options_NoStream 

type AppendReq_Options_NoStream struct {
	NoStream *shared.Empty `protobuf:"bytes,3,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type AppendReq_Options_Revision 

type AppendReq_Options_Revision struct {
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3,oneof"`
}

type AppendReq_Options_StreamExists 

type AppendReq_Options_StreamExists struct {
	StreamExists *shared.Empty `protobuf:"bytes,5,opt,name=stream_exists,json=streamExists,proto3,oneof"`
}

type AppendReq_ProposedMessage 

type AppendReq_ProposedMessage struct {
	Id             *shared.UUID      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata       map[string]string `` /* 157-byte string literal not displayed */
	CustomMetadata []byte            `protobuf:"bytes,3,opt,name=custom_metadata,json=customMetadata,proto3" json:"custom_metadata,omitempty"`
	Data           []byte            `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendReq_ProposedMessage) Descriptor deprecated 

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

Deprecated: Use AppendReq_ProposedMessage.ProtoReflect.Descriptor instead.

func (*AppendReq_ProposedMessage) GetCustomMetadata 

func (x *AppendReq_ProposedMessage) GetCustomMetadata() []byte

func (*AppendReq_ProposedMessage) GetData 

func (x *AppendReq_ProposedMessage) GetData() []byte

func (*AppendReq_ProposedMessage) GetId 

func (x *AppendReq_ProposedMessage) GetId() *shared.UUID

func (*AppendReq_ProposedMessage) GetMetadata 

func (x *AppendReq_ProposedMessage) GetMetadata() map[string]string

func (*AppendReq_ProposedMessage) ProtoMessage 

func (*AppendReq_ProposedMessage) ProtoMessage()

func (*AppendReq_ProposedMessage) ProtoReflect 

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

func (*AppendReq_ProposedMessage) Reset 

func (x *AppendReq_ProposedMessage) Reset()

func (*AppendReq_ProposedMessage) String 

func (x *AppendReq_ProposedMessage) String() string

type AppendReq_ProposedMessage_ 

type AppendReq_ProposedMessage_ struct {
	ProposedMessage *AppendReq_ProposedMessage `protobuf:"bytes,2,opt,name=proposed_message,json=proposedMessage,proto3,oneof"`
}

type AppendResp 

type AppendResp struct {

	// Types that are assignable to Result:
	//	*AppendResp_Success_
	//	*AppendResp_WrongExpectedVersion_
	Result isAppendResp_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*AppendResp) Descriptor deprecated 

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

Deprecated: Use AppendResp.ProtoReflect.Descriptor instead.

func (*AppendResp) GetResult 

func (m *AppendResp) GetResult() isAppendResp_Result

func (*AppendResp) GetSuccess 

func (x *AppendResp) GetSuccess() *AppendResp_Success

func (*AppendResp) GetWrongExpectedVersion 

func (x *AppendResp) GetWrongExpectedVersion() *AppendResp_WrongExpectedVersion

func (*AppendResp) ProtoMessage 

func (*AppendResp) ProtoMessage()

func (*AppendResp) ProtoReflect 

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

func (*AppendResp) Reset 

func (x *AppendResp) Reset()

func (*AppendResp) String 

func (x *AppendResp) String() string

type AppendResp_Position 

type AppendResp_Position 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 (*AppendResp_Position) Descriptor deprecated 

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

Deprecated: Use AppendResp_Position.ProtoReflect.Descriptor instead.

func (*AppendResp_Position) GetCommitPosition 

func (x *AppendResp_Position) GetCommitPosition() uint64

func (*AppendResp_Position) GetPreparePosition 

func (x *AppendResp_Position) GetPreparePosition() uint64

func (*AppendResp_Position) ProtoMessage 

func (*AppendResp_Position) ProtoMessage()

func (*AppendResp_Position) ProtoReflect 

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

func (*AppendResp_Position) Reset 

func (x *AppendResp_Position) Reset()

func (*AppendResp_Position) String 

func (x *AppendResp_Position) String() string

type AppendResp_Success 

type AppendResp_Success struct {

	// Types that are assignable to CurrentRevisionOption:
	//	*AppendResp_Success_CurrentRevision
	//	*AppendResp_Success_NoStream
	CurrentRevisionOption isAppendResp_Success_CurrentRevisionOption `protobuf_oneof:"current_revision_option"`
	// Types that are assignable to PositionOption:
	//	*AppendResp_Success_Position
	//	*AppendResp_Success_NoPosition
	PositionOption isAppendResp_Success_PositionOption `protobuf_oneof:"position_option"`
	// contains filtered or unexported fields
}

func (*AppendResp_Success) Descriptor deprecated 

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

Deprecated: Use AppendResp_Success.ProtoReflect.Descriptor instead.

func (*AppendResp_Success) GetCurrentRevision 

func (x *AppendResp_Success) GetCurrentRevision() uint64

func (*AppendResp_Success) GetCurrentRevisionOption 

func (m *AppendResp_Success) GetCurrentRevisionOption() isAppendResp_Success_CurrentRevisionOption

func (*AppendResp_Success) GetNoPosition 

func (x *AppendResp_Success) GetNoPosition() *shared.Empty

func (*AppendResp_Success) GetNoStream 

func (x *AppendResp_Success) GetNoStream() *shared.Empty

func (*AppendResp_Success) GetPosition 

func (x *AppendResp_Success) GetPosition() *AppendResp_Position

func (*AppendResp_Success) GetPositionOption 

func (m *AppendResp_Success) GetPositionOption() isAppendResp_Success_PositionOption

func (*AppendResp_Success) ProtoMessage 

func (*AppendResp_Success) ProtoMessage()

func (*AppendResp_Success) ProtoReflect 

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

func (*AppendResp_Success) Reset 

func (x *AppendResp_Success) Reset()

func (*AppendResp_Success) String 

func (x *AppendResp_Success) String() string

type AppendResp_Success_ 

type AppendResp_Success_ struct {
	Success *AppendResp_Success `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type AppendResp_Success_CurrentRevision 

type AppendResp_Success_CurrentRevision struct {
	CurrentRevision uint64 `protobuf:"varint,1,opt,name=current_revision,json=currentRevision,proto3,oneof"`
}

type AppendResp_Success_NoPosition 

type AppendResp_Success_NoPosition struct {
	NoPosition *shared.Empty `protobuf:"bytes,4,opt,name=no_position,json=noPosition,proto3,oneof"`
}

type AppendResp_Success_NoStream 

type AppendResp_Success_NoStream struct {
	NoStream *shared.Empty `protobuf:"bytes,2,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type AppendResp_Success_Position 

type AppendResp_Success_Position struct {
	Position *AppendResp_Position `protobuf:"bytes,3,opt,name=position,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion 

type AppendResp_WrongExpectedVersion struct {

	// Types that are assignable to CurrentRevisionOption_20_6_0:
	//	*AppendResp_WrongExpectedVersion_CurrentRevision_20_6_0
	//	*AppendResp_WrongExpectedVersion_NoStream_20_6_0
	CurrentRevisionOption_20_6_0 isAppendResp_WrongExpectedVersion_CurrentRevisionOption_20_6_0 `protobuf_oneof:"current_revision_option_20_6_0"`
	// Types that are assignable to ExpectedRevisionOption_20_6_0:
	//	*AppendResp_WrongExpectedVersion_ExpectedRevision_20_6_0
	//	*AppendResp_WrongExpectedVersion_Any_20_6_0
	//	*AppendResp_WrongExpectedVersion_StreamExists_20_6_0
	ExpectedRevisionOption_20_6_0 isAppendResp_WrongExpectedVersion_ExpectedRevisionOption_20_6_0 `protobuf_oneof:"expected_revision_option_20_6_0"`
	// Types that are assignable to CurrentRevisionOption:
	//	*AppendResp_WrongExpectedVersion_CurrentRevision
	//	*AppendResp_WrongExpectedVersion_CurrentNoStream
	CurrentRevisionOption isAppendResp_WrongExpectedVersion_CurrentRevisionOption `protobuf_oneof:"current_revision_option"`
	// Types that are assignable to ExpectedRevisionOption:
	//	*AppendResp_WrongExpectedVersion_ExpectedRevision
	//	*AppendResp_WrongExpectedVersion_ExpectedAny
	//	*AppendResp_WrongExpectedVersion_ExpectedStreamExists
	//	*AppendResp_WrongExpectedVersion_ExpectedNoStream
	ExpectedRevisionOption isAppendResp_WrongExpectedVersion_ExpectedRevisionOption `protobuf_oneof:"expected_revision_option"`
	// contains filtered or unexported fields
}

func (*AppendResp_WrongExpectedVersion) Descriptor deprecated 

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

Deprecated: Use AppendResp_WrongExpectedVersion.ProtoReflect.Descriptor instead.

func (*AppendResp_WrongExpectedVersion) GetAny_20_6_0 

func (x *AppendResp_WrongExpectedVersion) GetAny_20_6_0() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetCurrentNoStream 

func (x *AppendResp_WrongExpectedVersion) GetCurrentNoStream() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetCurrentRevision 

func (x *AppendResp_WrongExpectedVersion) GetCurrentRevision() uint64

func (*AppendResp_WrongExpectedVersion) GetCurrentRevisionOption 

func (m *AppendResp_WrongExpectedVersion) GetCurrentRevisionOption() isAppendResp_WrongExpectedVersion_CurrentRevisionOption

func (*AppendResp_WrongExpectedVersion) GetCurrentRevisionOption_20_6_0 

func (m *AppendResp_WrongExpectedVersion) GetCurrentRevisionOption_20_6_0() isAppendResp_WrongExpectedVersion_CurrentRevisionOption_20_6_0

func (*AppendResp_WrongExpectedVersion) GetCurrentRevision_20_6_0 

func (x *AppendResp_WrongExpectedVersion) GetCurrentRevision_20_6_0() uint64

func (*AppendResp_WrongExpectedVersion) GetExpectedAny 

func (x *AppendResp_WrongExpectedVersion) GetExpectedAny() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetExpectedNoStream 

func (x *AppendResp_WrongExpectedVersion) GetExpectedNoStream() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetExpectedRevision 

func (x *AppendResp_WrongExpectedVersion) GetExpectedRevision() uint64

func (*AppendResp_WrongExpectedVersion) GetExpectedRevisionOption 

func (m *AppendResp_WrongExpectedVersion) GetExpectedRevisionOption() isAppendResp_WrongExpectedVersion_ExpectedRevisionOption

func (*AppendResp_WrongExpectedVersion) GetExpectedRevisionOption_20_6_0 

func (m *AppendResp_WrongExpectedVersion) GetExpectedRevisionOption_20_6_0() isAppendResp_WrongExpectedVersion_ExpectedRevisionOption_20_6_0

func (*AppendResp_WrongExpectedVersion) GetExpectedRevision_20_6_0 

func (x *AppendResp_WrongExpectedVersion) GetExpectedRevision_20_6_0() uint64

func (*AppendResp_WrongExpectedVersion) GetExpectedStreamExists 

func (x *AppendResp_WrongExpectedVersion) GetExpectedStreamExists() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetNoStream_20_6_0 

func (x *AppendResp_WrongExpectedVersion) GetNoStream_20_6_0() *shared.Empty

func (*AppendResp_WrongExpectedVersion) GetStreamExists_20_6_0 

func (x *AppendResp_WrongExpectedVersion) GetStreamExists_20_6_0() *shared.Empty

func (*AppendResp_WrongExpectedVersion) ProtoMessage 

func (*AppendResp_WrongExpectedVersion) ProtoMessage()

func (*AppendResp_WrongExpectedVersion) ProtoReflect 

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

func (*AppendResp_WrongExpectedVersion) Reset 

func (x *AppendResp_WrongExpectedVersion) Reset()

func (*AppendResp_WrongExpectedVersion) String 

func (x *AppendResp_WrongExpectedVersion) String() string

type AppendResp_WrongExpectedVersion_ 

type AppendResp_WrongExpectedVersion_ struct {
	WrongExpectedVersion *AppendResp_WrongExpectedVersion `protobuf:"bytes,2,opt,name=wrong_expected_version,json=wrongExpectedVersion,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_Any_20_6_0 

type AppendResp_WrongExpectedVersion_Any_20_6_0 struct {
	Any_20_6_0 *shared.Empty `protobuf:"bytes,4,opt,name=any_20_6_0,json=any2060,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_CurrentNoStream 

type AppendResp_WrongExpectedVersion_CurrentNoStream struct {
	CurrentNoStream *shared.Empty `protobuf:"bytes,7,opt,name=current_no_stream,json=currentNoStream,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_CurrentRevision 

type AppendResp_WrongExpectedVersion_CurrentRevision struct {
	CurrentRevision uint64 `protobuf:"varint,6,opt,name=current_revision,json=currentRevision,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_CurrentRevision_20_6_0 

type AppendResp_WrongExpectedVersion_CurrentRevision_20_6_0 struct {
	CurrentRevision_20_6_0 uint64 `protobuf:"varint,1,opt,name=current_revision_20_6_0,json=currentRevision2060,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_ExpectedAny 

type AppendResp_WrongExpectedVersion_ExpectedAny struct {
	ExpectedAny *shared.Empty `protobuf:"bytes,9,opt,name=expected_any,json=expectedAny,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_ExpectedNoStream 

type AppendResp_WrongExpectedVersion_ExpectedNoStream struct {
	ExpectedNoStream *shared.Empty `protobuf:"bytes,11,opt,name=expected_no_stream,json=expectedNoStream,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_ExpectedRevision 

type AppendResp_WrongExpectedVersion_ExpectedRevision struct {
	ExpectedRevision uint64 `protobuf:"varint,8,opt,name=expected_revision,json=expectedRevision,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_ExpectedRevision_20_6_0 

type AppendResp_WrongExpectedVersion_ExpectedRevision_20_6_0 struct {
	ExpectedRevision_20_6_0 uint64 `protobuf:"varint,3,opt,name=expected_revision_20_6_0,json=expectedRevision2060,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_ExpectedStreamExists 

type AppendResp_WrongExpectedVersion_ExpectedStreamExists struct {
	ExpectedStreamExists *shared.Empty `protobuf:"bytes,10,opt,name=expected_stream_exists,json=expectedStreamExists,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_NoStream_20_6_0 

type AppendResp_WrongExpectedVersion_NoStream_20_6_0 struct {
	NoStream_20_6_0 *shared.Empty `protobuf:"bytes,2,opt,name=no_stream_20_6_0,json=noStream2060,proto3,oneof"`
}

type AppendResp_WrongExpectedVersion_StreamExists_20_6_0 

type AppendResp_WrongExpectedVersion_StreamExists_20_6_0 struct {
	StreamExists_20_6_0 *shared.Empty `protobuf:"bytes,5,opt,name=stream_exists_20_6_0,json=streamExists2060,proto3,oneof"`
}

type BatchAppendReq 

type BatchAppendReq struct {
	CorrelationId    *shared.UUID                      `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Options          *BatchAppendReq_Options           `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	ProposedMessages []*BatchAppendReq_ProposedMessage `protobuf:"bytes,3,rep,name=proposed_messages,json=proposedMessages,proto3" json:"proposed_messages,omitempty"`
	IsFinal          bool                              `protobuf:"varint,4,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchAppendReq) Descriptor deprecated 

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

Deprecated: Use BatchAppendReq.ProtoReflect.Descriptor instead.

func (*BatchAppendReq) GetCorrelationId 

func (x *BatchAppendReq) GetCorrelationId() *shared.UUID

func (*BatchAppendReq) GetIsFinal 

func (x *BatchAppendReq) GetIsFinal() bool

func (*BatchAppendReq) GetOptions 

func (x *BatchAppendReq) GetOptions() *BatchAppendReq_Options

func (*BatchAppendReq) GetProposedMessages 

func (x *BatchAppendReq) GetProposedMessages() []*BatchAppendReq_ProposedMessage

func (*BatchAppendReq) ProtoMessage 

func (*BatchAppendReq) ProtoMessage()

func (*BatchAppendReq) ProtoReflect 

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

func (*BatchAppendReq) Reset 

func (x *BatchAppendReq) Reset()

func (*BatchAppendReq) String 

func (x *BatchAppendReq) String() string

type BatchAppendReq_Options 

type BatchAppendReq_Options struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to ExpectedStreamPosition:
	//	*BatchAppendReq_Options_StreamPosition
	//	*BatchAppendReq_Options_NoStream
	//	*BatchAppendReq_Options_Any
	//	*BatchAppendReq_Options_StreamExists
	ExpectedStreamPosition isBatchAppendReq_Options_ExpectedStreamPosition `protobuf_oneof:"expected_stream_position"`
	Deadline               *timestamppb.Timestamp                          `protobuf:"bytes,6,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchAppendReq_Options) Descriptor deprecated 

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

Deprecated: Use BatchAppendReq_Options.ProtoReflect.Descriptor instead.

func (*BatchAppendReq_Options) GetAny 

func (x *BatchAppendReq_Options) GetAny() *emptypb.Empty

func (*BatchAppendReq_Options) GetDeadline 

func (x *BatchAppendReq_Options) GetDeadline() *timestamppb.Timestamp

func (*BatchAppendReq_Options) GetExpectedStreamPosition 

func (m *BatchAppendReq_Options) GetExpectedStreamPosition() isBatchAppendReq_Options_ExpectedStreamPosition

func (*BatchAppendReq_Options) GetNoStream 

func (x *BatchAppendReq_Options) GetNoStream() *emptypb.Empty

func (*BatchAppendReq_Options) GetStreamExists 

func (x *BatchAppendReq_Options) GetStreamExists() *emptypb.Empty

func (*BatchAppendReq_Options) GetStreamIdentifier 

func (x *BatchAppendReq_Options) GetStreamIdentifier() *shared.StreamIdentifier

func (*BatchAppendReq_Options) GetStreamPosition 

func (x *BatchAppendReq_Options) GetStreamPosition() uint64

func (*BatchAppendReq_Options) ProtoMessage 

func (*BatchAppendReq_Options) ProtoMessage()

func (*BatchAppendReq_Options) ProtoReflect 

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

func (*BatchAppendReq_Options) Reset 

func (x *BatchAppendReq_Options) Reset()

func (*BatchAppendReq_Options) String 

func (x *BatchAppendReq_Options) String() string

type BatchAppendReq_Options_Any 

type BatchAppendReq_Options_Any struct {
	Any *emptypb.Empty `protobuf:"bytes,4,opt,name=any,proto3,oneof"`
}

type BatchAppendReq_Options_NoStream 

type BatchAppendReq_Options_NoStream struct {
	NoStream *emptypb.Empty `protobuf:"bytes,3,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type BatchAppendReq_Options_StreamExists 

type BatchAppendReq_Options_StreamExists struct {
	StreamExists *emptypb.Empty `protobuf:"bytes,5,opt,name=stream_exists,json=streamExists,proto3,oneof"`
}

type BatchAppendReq_Options_StreamPosition 

type BatchAppendReq_Options_StreamPosition struct {
	StreamPosition uint64 `protobuf:"varint,2,opt,name=stream_position,json=streamPosition,proto3,oneof"`
}

type BatchAppendReq_ProposedMessage 

type BatchAppendReq_ProposedMessage struct {
	Id             *shared.UUID      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata       map[string]string `` /* 157-byte string literal not displayed */
	CustomMetadata []byte            `protobuf:"bytes,3,opt,name=custom_metadata,json=customMetadata,proto3" json:"custom_metadata,omitempty"`
	Data           []byte            `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchAppendReq_ProposedMessage) Descriptor deprecated 

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

Deprecated: Use BatchAppendReq_ProposedMessage.ProtoReflect.Descriptor instead.

func (*BatchAppendReq_ProposedMessage) GetCustomMetadata 

func (x *BatchAppendReq_ProposedMessage) GetCustomMetadata() []byte

func (*BatchAppendReq_ProposedMessage) GetData 

func (x *BatchAppendReq_ProposedMessage) GetData() []byte

func (*BatchAppendReq_ProposedMessage) GetId 

func (x *BatchAppendReq_ProposedMessage) GetId() *shared.UUID

func (*BatchAppendReq_ProposedMessage) GetMetadata 

func (x *BatchAppendReq_ProposedMessage) GetMetadata() map[string]string

func (*BatchAppendReq_ProposedMessage) ProtoMessage 

func (*BatchAppendReq_ProposedMessage) ProtoMessage()

func (*BatchAppendReq_ProposedMessage) ProtoReflect 

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

func (*BatchAppendReq_ProposedMessage) Reset 

func (x *BatchAppendReq_ProposedMessage) Reset()

func (*BatchAppendReq_ProposedMessage) String 

func (x *BatchAppendReq_ProposedMessage) String() string

type BatchAppendResp 

type BatchAppendResp struct {
	CorrelationId *shared.UUID `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// Types that are assignable to Result:
	//	*BatchAppendResp_Error
	//	*BatchAppendResp_Success_
	Result           isBatchAppendResp_Result `protobuf_oneof:"result"`
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,4,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to ExpectedStreamPosition:
	//	*BatchAppendResp_StreamPosition
	//	*BatchAppendResp_NoStream
	//	*BatchAppendResp_Any
	//	*BatchAppendResp_StreamExists
	ExpectedStreamPosition isBatchAppendResp_ExpectedStreamPosition `protobuf_oneof:"expected_stream_position"`
	// contains filtered or unexported fields
}

func (*BatchAppendResp) Descriptor deprecated 

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

Deprecated: Use BatchAppendResp.ProtoReflect.Descriptor instead.

func (*BatchAppendResp) GetAny 

func (x *BatchAppendResp) GetAny() *emptypb.Empty

func (*BatchAppendResp) GetCorrelationId 

func (x *BatchAppendResp) GetCorrelationId() *shared.UUID

func (*BatchAppendResp) GetError 

func (x *BatchAppendResp) GetError() *status.Status

func (*BatchAppendResp) GetExpectedStreamPosition 

func (m *BatchAppendResp) GetExpectedStreamPosition() isBatchAppendResp_ExpectedStreamPosition

func (*BatchAppendResp) GetNoStream 

func (x *BatchAppendResp) GetNoStream() *emptypb.Empty

func (*BatchAppendResp) GetResult 

func (m *BatchAppendResp) GetResult() isBatchAppendResp_Result

func (*BatchAppendResp) GetStreamExists 

func (x *BatchAppendResp) GetStreamExists() *emptypb.Empty

func (*BatchAppendResp) GetStreamIdentifier 

func (x *BatchAppendResp) GetStreamIdentifier() *shared.StreamIdentifier

func (*BatchAppendResp) GetStreamPosition 

func (x *BatchAppendResp) GetStreamPosition() uint64

func (*BatchAppendResp) GetSuccess 

func (x *BatchAppendResp) GetSuccess() *BatchAppendResp_Success

func (*BatchAppendResp) ProtoMessage 

func (*BatchAppendResp) ProtoMessage()

func (*BatchAppendResp) ProtoReflect 

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

func (*BatchAppendResp) Reset 

func (x *BatchAppendResp) Reset()

func (*BatchAppendResp) String 

func (x *BatchAppendResp) String() string

type BatchAppendResp_Any 

type BatchAppendResp_Any struct {
	Any *emptypb.Empty `protobuf:"bytes,7,opt,name=any,proto3,oneof"`
}

type BatchAppendResp_Error 

type BatchAppendResp_Error struct {
	Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type BatchAppendResp_NoStream 

type BatchAppendResp_NoStream struct {
	NoStream *emptypb.Empty `protobuf:"bytes,6,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type BatchAppendResp_StreamExists 

type BatchAppendResp_StreamExists struct {
	StreamExists *emptypb.Empty `protobuf:"bytes,8,opt,name=stream_exists,json=streamExists,proto3,oneof"`
}

type BatchAppendResp_StreamPosition 

type BatchAppendResp_StreamPosition struct {
	StreamPosition uint64 `protobuf:"varint,5,opt,name=stream_position,json=streamPosition,proto3,oneof"`
}

type BatchAppendResp_Success 

type BatchAppendResp_Success struct {

	// Types that are assignable to CurrentRevisionOption:
	//	*BatchAppendResp_Success_CurrentRevision
	//	*BatchAppendResp_Success_NoStream
	CurrentRevisionOption isBatchAppendResp_Success_CurrentRevisionOption `protobuf_oneof:"current_revision_option"`
	// Types that are assignable to PositionOption:
	//	*BatchAppendResp_Success_Position
	//	*BatchAppendResp_Success_NoPosition
	PositionOption isBatchAppendResp_Success_PositionOption `protobuf_oneof:"position_option"`
	// contains filtered or unexported fields
}

func (*BatchAppendResp_Success) Descriptor deprecated 

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

Deprecated: Use BatchAppendResp_Success.ProtoReflect.Descriptor instead.

func (*BatchAppendResp_Success) GetCurrentRevision 

func (x *BatchAppendResp_Success) GetCurrentRevision() uint64

func (*BatchAppendResp_Success) GetCurrentRevisionOption 

func (m *BatchAppendResp_Success) GetCurrentRevisionOption() isBatchAppendResp_Success_CurrentRevisionOption

func (*BatchAppendResp_Success) GetNoPosition 

func (x *BatchAppendResp_Success) GetNoPosition() *emptypb.Empty

func (*BatchAppendResp_Success) GetNoStream 

func (x *BatchAppendResp_Success) GetNoStream() *emptypb.Empty

func (*BatchAppendResp_Success) GetPosition 

func (x *BatchAppendResp_Success) GetPosition() *shared.AllStreamPosition

func (*BatchAppendResp_Success) GetPositionOption 

func (m *BatchAppendResp_Success) GetPositionOption() isBatchAppendResp_Success_PositionOption

func (*BatchAppendResp_Success) ProtoMessage 

func (*BatchAppendResp_Success) ProtoMessage()

func (*BatchAppendResp_Success) ProtoReflect 

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

func (*BatchAppendResp_Success) Reset 

func (x *BatchAppendResp_Success) Reset()

func (*BatchAppendResp_Success) String 

func (x *BatchAppendResp_Success) String() string

type BatchAppendResp_Success_ 

type BatchAppendResp_Success_ struct {
	Success *BatchAppendResp_Success `protobuf:"bytes,3,opt,name=success,proto3,oneof"`
}

type BatchAppendResp_Success_CurrentRevision 

type BatchAppendResp_Success_CurrentRevision struct {
	CurrentRevision uint64 `protobuf:"varint,1,opt,name=current_revision,json=currentRevision,proto3,oneof"`
}

type BatchAppendResp_Success_NoPosition 

type BatchAppendResp_Success_NoPosition struct {
	NoPosition *emptypb.Empty `protobuf:"bytes,4,opt,name=no_position,json=noPosition,proto3,oneof"`
}

type BatchAppendResp_Success_NoStream 

type BatchAppendResp_Success_NoStream struct {
	NoStream *emptypb.Empty `protobuf:"bytes,2,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type BatchAppendResp_Success_Position 

type BatchAppendResp_Success_Position struct {
	Position *shared.AllStreamPosition `protobuf:"bytes,3,opt,name=position,proto3,oneof"`
}

type DeleteReq 

type DeleteReq struct {
	Options *DeleteReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteReq) Descriptor deprecated 

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

Deprecated: Use DeleteReq.ProtoReflect.Descriptor instead.

func (*DeleteReq) GetOptions 

func (x *DeleteReq) GetOptions() *DeleteReq_Options

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) ProtoReflect 

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

func (*DeleteReq) Reset 

func (x *DeleteReq) Reset()

func (*DeleteReq) String 

func (x *DeleteReq) String() string

type DeleteReq_Options 

type DeleteReq_Options struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to ExpectedStreamRevision:
	//	*DeleteReq_Options_Revision
	//	*DeleteReq_Options_NoStream
	//	*DeleteReq_Options_Any
	//	*DeleteReq_Options_StreamExists
	ExpectedStreamRevision isDeleteReq_Options_ExpectedStreamRevision `protobuf_oneof:"expected_stream_revision"`
	// contains filtered or unexported fields
}

func (*DeleteReq_Options) Descriptor deprecated 

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

Deprecated: Use DeleteReq_Options.ProtoReflect.Descriptor instead.

func (*DeleteReq_Options) GetAny 

func (x *DeleteReq_Options) GetAny() *shared.Empty

func (*DeleteReq_Options) GetExpectedStreamRevision 

func (m *DeleteReq_Options) GetExpectedStreamRevision() isDeleteReq_Options_ExpectedStreamRevision

func (*DeleteReq_Options) GetNoStream 

func (x *DeleteReq_Options) GetNoStream() *shared.Empty

func (*DeleteReq_Options) GetRevision 

func (x *DeleteReq_Options) GetRevision() uint64

func (*DeleteReq_Options) GetStreamExists 

func (x *DeleteReq_Options) GetStreamExists() *shared.Empty

func (*DeleteReq_Options) GetStreamIdentifier 

func (x *DeleteReq_Options) GetStreamIdentifier() *shared.StreamIdentifier

func (*DeleteReq_Options) ProtoMessage 

func (*DeleteReq_Options) ProtoMessage()

func (*DeleteReq_Options) ProtoReflect 

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

func (*DeleteReq_Options) Reset 

func (x *DeleteReq_Options) Reset()

func (*DeleteReq_Options) String 

func (x *DeleteReq_Options) String() string

type DeleteReq_Options_Any 

type DeleteReq_Options_Any struct {
	Any *shared.Empty `protobuf:"bytes,4,opt,name=any,proto3,oneof"`
}

type DeleteReq_Options_NoStream 

type DeleteReq_Options_NoStream struct {
	NoStream *shared.Empty `protobuf:"bytes,3,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type DeleteReq_Options_Revision 

type DeleteReq_Options_Revision struct {
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3,oneof"`
}

type DeleteReq_Options_StreamExists 

type DeleteReq_Options_StreamExists struct {
	StreamExists *shared.Empty `protobuf:"bytes,5,opt,name=stream_exists,json=streamExists,proto3,oneof"`
}

type DeleteResp 

type DeleteResp struct {

	// Types that are assignable to PositionOption:
	//	*DeleteResp_Position_
	//	*DeleteResp_NoPosition
	PositionOption isDeleteResp_PositionOption `protobuf_oneof:"position_option"`
	// contains filtered or unexported fields
}

func (*DeleteResp) Descriptor deprecated 

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

Deprecated: Use DeleteResp.ProtoReflect.Descriptor instead.

func (*DeleteResp) GetNoPosition 

func (x *DeleteResp) GetNoPosition() *shared.Empty

func (*DeleteResp) GetPosition 

func (x *DeleteResp) GetPosition() *DeleteResp_Position

func (*DeleteResp) GetPositionOption 

func (m *DeleteResp) GetPositionOption() isDeleteResp_PositionOption

func (*DeleteResp) ProtoMessage 

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) ProtoReflect 

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

func (*DeleteResp) Reset 

func (x *DeleteResp) Reset()

func (*DeleteResp) String 

func (x *DeleteResp) String() string

type DeleteResp_NoPosition 

type DeleteResp_NoPosition struct {
	NoPosition *shared.Empty `protobuf:"bytes,2,opt,name=no_position,json=noPosition,proto3,oneof"`
}

type DeleteResp_Position 

type DeleteResp_Position 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 (*DeleteResp_Position) Descriptor deprecated 

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

Deprecated: Use DeleteResp_Position.ProtoReflect.Descriptor instead.

func (*DeleteResp_Position) GetCommitPosition 

func (x *DeleteResp_Position) GetCommitPosition() uint64

func (*DeleteResp_Position) GetPreparePosition 

func (x *DeleteResp_Position) GetPreparePosition() uint64

func (*DeleteResp_Position) ProtoMessage 

func (*DeleteResp_Position) ProtoMessage()

func (*DeleteResp_Position) ProtoReflect 

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

func (*DeleteResp_Position) Reset 

func (x *DeleteResp_Position) Reset()

func (*DeleteResp_Position) String 

func (x *DeleteResp_Position) String() string

type DeleteResp_Position_ 

type DeleteResp_Position_ struct {
	Position *DeleteResp_Position `protobuf:"bytes,1,opt,name=position,proto3,oneof"`
}

type ReadReq 

type ReadReq struct {
	Options *ReadReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq) Descriptor deprecated 

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

Deprecated: Use ReadReq.ProtoReflect.Descriptor instead.

func (*ReadReq) GetOptions 

func (x *ReadReq) GetOptions() *ReadReq_Options

func (*ReadReq) ProtoMessage 

func (*ReadReq) ProtoMessage()

func (*ReadReq) ProtoReflect 

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

func (*ReadReq) Reset 

func (x *ReadReq) Reset()

func (*ReadReq) String 

func (x *ReadReq) String() string

type ReadReq_Options 

type ReadReq_Options struct {

	// Types that are assignable to StreamOption:
	//	*ReadReq_Options_Stream
	//	*ReadReq_Options_All
	StreamOption  isReadReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	ReadDirection ReadReq_Options_ReadDirection  `` /* 163-byte string literal not displayed */
	ResolveLinks  bool                           `protobuf:"varint,4,opt,name=resolve_links,json=resolveLinks,proto3" json:"resolve_links,omitempty"`
	// Types that are assignable to CountOption:
	//	*ReadReq_Options_Count
	//	*ReadReq_Options_Subscription
	CountOption isReadReq_Options_CountOption `protobuf_oneof:"count_option"`
	// Types that are assignable to FilterOption:
	//	*ReadReq_Options_Filter
	//	*ReadReq_Options_NoFilter
	FilterOption  isReadReq_Options_FilterOption `protobuf_oneof:"filter_option"`
	UuidOption    *ReadReq_Options_UUIDOption    `protobuf:"bytes,9,opt,name=uuid_option,json=uuidOption,proto3" json:"uuid_option,omitempty"`
	ControlOption *ReadReq_Options_ControlOption `protobuf:"bytes,10,opt,name=control_option,json=controlOption,proto3" json:"control_option,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options.ProtoReflect.Descriptor instead.

func (*ReadReq_Options) GetAll 

func (x *ReadReq_Options) GetAll() *ReadReq_Options_AllOptions

func (*ReadReq_Options) GetControlOption 

func (x *ReadReq_Options) GetControlOption() *ReadReq_Options_ControlOption

func (*ReadReq_Options) GetCount 

func (x *ReadReq_Options) GetCount() uint64

func (*ReadReq_Options) GetCountOption 

func (m *ReadReq_Options) GetCountOption() isReadReq_Options_CountOption

func (*ReadReq_Options) GetFilter 

func (x *ReadReq_Options) GetFilter() *ReadReq_Options_FilterOptions

func (*ReadReq_Options) GetFilterOption 

func (m *ReadReq_Options) GetFilterOption() isReadReq_Options_FilterOption

func (*ReadReq_Options) GetNoFilter 

func (x *ReadReq_Options) GetNoFilter() *shared.Empty

func (*ReadReq_Options) GetReadDirection 

func (x *ReadReq_Options) GetReadDirection() ReadReq_Options_ReadDirection
func (x *ReadReq_Options) GetResolveLinks() bool

func (*ReadReq_Options) GetStream 

func (x *ReadReq_Options) GetStream() *ReadReq_Options_StreamOptions

func (*ReadReq_Options) GetStreamOption 

func (m *ReadReq_Options) GetStreamOption() isReadReq_Options_StreamOption

func (*ReadReq_Options) GetSubscription 

func (x *ReadReq_Options) GetSubscription() *ReadReq_Options_SubscriptionOptions

func (*ReadReq_Options) GetUuidOption 

func (x *ReadReq_Options) GetUuidOption() *ReadReq_Options_UUIDOption

func (*ReadReq_Options) ProtoMessage 

func (*ReadReq_Options) ProtoMessage()

func (*ReadReq_Options) ProtoReflect 

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

func (*ReadReq_Options) Reset 

func (x *ReadReq_Options) Reset()

func (*ReadReq_Options) String 

func (x *ReadReq_Options) String() string

type ReadReq_Options_All 

type ReadReq_Options_All struct {
	All *ReadReq_Options_AllOptions `protobuf:"bytes,2,opt,name=all,proto3,oneof"`
}

type ReadReq_Options_AllOptions 

type ReadReq_Options_AllOptions struct {

	// Types that are assignable to AllOption:
	//	*ReadReq_Options_AllOptions_Position
	//	*ReadReq_Options_AllOptions_Start
	//	*ReadReq_Options_AllOptions_End
	AllOption isReadReq_Options_AllOptions_AllOption `protobuf_oneof:"all_option"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options_AllOptions) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_AllOptions.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_AllOptions) GetAllOption 

func (m *ReadReq_Options_AllOptions) GetAllOption() isReadReq_Options_AllOptions_AllOption

func (*ReadReq_Options_AllOptions) GetEnd 

func (x *ReadReq_Options_AllOptions) GetEnd() *shared.Empty

func (*ReadReq_Options_AllOptions) GetPosition 

func (x *ReadReq_Options_AllOptions) GetPosition() *ReadReq_Options_Position

func (*ReadReq_Options_AllOptions) GetStart 

func (x *ReadReq_Options_AllOptions) GetStart() *shared.Empty

func (*ReadReq_Options_AllOptions) ProtoMessage 

func (*ReadReq_Options_AllOptions) ProtoMessage()

func (*ReadReq_Options_AllOptions) ProtoReflect 

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

func (*ReadReq_Options_AllOptions) Reset 

func (x *ReadReq_Options_AllOptions) Reset()

func (*ReadReq_Options_AllOptions) String 

func (x *ReadReq_Options_AllOptions) String() string

type ReadReq_Options_AllOptions_End 

type ReadReq_Options_AllOptions_End struct {
	End *shared.Empty `protobuf:"bytes,3,opt,name=end,proto3,oneof"`
}

type ReadReq_Options_AllOptions_Position 

type ReadReq_Options_AllOptions_Position struct {
	Position *ReadReq_Options_Position `protobuf:"bytes,1,opt,name=position,proto3,oneof"`
}

type ReadReq_Options_AllOptions_Start 

type ReadReq_Options_AllOptions_Start struct {
	Start *shared.Empty `protobuf:"bytes,2,opt,name=start,proto3,oneof"`
}

type ReadReq_Options_ControlOption 

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

func (*ReadReq_Options_ControlOption) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_ControlOption.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_ControlOption) GetCompatibility 

func (x *ReadReq_Options_ControlOption) GetCompatibility() uint32

func (*ReadReq_Options_ControlOption) ProtoMessage 

func (*ReadReq_Options_ControlOption) ProtoMessage()

func (*ReadReq_Options_ControlOption) ProtoReflect 

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

func (*ReadReq_Options_ControlOption) Reset 

func (x *ReadReq_Options_ControlOption) Reset()

func (*ReadReq_Options_ControlOption) String 

func (x *ReadReq_Options_ControlOption) String() string

type ReadReq_Options_Count 

type ReadReq_Options_Count struct {
	Count uint64 `protobuf:"varint,5,opt,name=count,proto3,oneof"`
}

type ReadReq_Options_Filter 

type ReadReq_Options_Filter struct {
	Filter *ReadReq_Options_FilterOptions `protobuf:"bytes,7,opt,name=filter,proto3,oneof"`
}

type ReadReq_Options_FilterOptions 

type ReadReq_Options_FilterOptions struct {

	// Types that are assignable to Filter:
	//	*ReadReq_Options_FilterOptions_StreamIdentifier
	//	*ReadReq_Options_FilterOptions_EventType
	Filter isReadReq_Options_FilterOptions_Filter `protobuf_oneof:"filter"`
	// Types that are assignable to Window:
	//	*ReadReq_Options_FilterOptions_Max
	//	*ReadReq_Options_FilterOptions_Count
	Window                       isReadReq_Options_FilterOptions_Window `protobuf_oneof:"window"`
	CheckpointIntervalMultiplier uint32                                 `protobuf:"varint,5,opt,name=checkpointIntervalMultiplier,proto3" json:"checkpointIntervalMultiplier,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options_FilterOptions) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_FilterOptions.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_FilterOptions) GetCheckpointIntervalMultiplier 

func (x *ReadReq_Options_FilterOptions) GetCheckpointIntervalMultiplier() uint32

func (*ReadReq_Options_FilterOptions) GetCount 

func (x *ReadReq_Options_FilterOptions) GetCount() *shared.Empty

func (*ReadReq_Options_FilterOptions) GetEventType 

func (x *ReadReq_Options_FilterOptions) GetEventType() *ReadReq_Options_FilterOptions_Expression

func (*ReadReq_Options_FilterOptions) GetFilter 

func (m *ReadReq_Options_FilterOptions) GetFilter() isReadReq_Options_FilterOptions_Filter

func (*ReadReq_Options_FilterOptions) GetMax 

func (x *ReadReq_Options_FilterOptions) GetMax() uint32

func (*ReadReq_Options_FilterOptions) GetStreamIdentifier 

func (x *ReadReq_Options_FilterOptions) GetStreamIdentifier() *ReadReq_Options_FilterOptions_Expression

func (*ReadReq_Options_FilterOptions) GetWindow 

func (m *ReadReq_Options_FilterOptions) GetWindow() isReadReq_Options_FilterOptions_Window

func (*ReadReq_Options_FilterOptions) ProtoMessage 

func (*ReadReq_Options_FilterOptions) ProtoMessage()

func (*ReadReq_Options_FilterOptions) ProtoReflect 

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

func (*ReadReq_Options_FilterOptions) Reset 

func (x *ReadReq_Options_FilterOptions) Reset()

func (*ReadReq_Options_FilterOptions) String 

func (x *ReadReq_Options_FilterOptions) String() string

type ReadReq_Options_FilterOptions_Count 

type ReadReq_Options_FilterOptions_Count struct {
	Count *shared.Empty `protobuf:"bytes,4,opt,name=count,proto3,oneof"`
}

type ReadReq_Options_FilterOptions_EventType 

type ReadReq_Options_FilterOptions_EventType struct {
	EventType *ReadReq_Options_FilterOptions_Expression `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3,oneof"`
}

type ReadReq_Options_FilterOptions_Expression 

type ReadReq_Options_FilterOptions_Expression struct {
	Regex  string   `protobuf:"bytes,1,opt,name=regex,proto3" json:"regex,omitempty"`
	Prefix []string `protobuf:"bytes,2,rep,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options_FilterOptions_Expression) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_FilterOptions_Expression.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_FilterOptions_Expression) GetPrefix 

func (x *ReadReq_Options_FilterOptions_Expression) GetPrefix() []string

func (*ReadReq_Options_FilterOptions_Expression) GetRegex 

func (x *ReadReq_Options_FilterOptions_Expression) GetRegex() string

func (*ReadReq_Options_FilterOptions_Expression) ProtoMessage 

func (*ReadReq_Options_FilterOptions_Expression) ProtoMessage()

func (*ReadReq_Options_FilterOptions_Expression) ProtoReflect 

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

func (*ReadReq_Options_FilterOptions_Expression) Reset 

func (x *ReadReq_Options_FilterOptions_Expression) Reset()

func (*ReadReq_Options_FilterOptions_Expression) String 

func (x *ReadReq_Options_FilterOptions_Expression) String() string

type ReadReq_Options_FilterOptions_Max 

type ReadReq_Options_FilterOptions_Max struct {
	Max uint32 `protobuf:"varint,3,opt,name=max,proto3,oneof"`
}

type ReadReq_Options_FilterOptions_StreamIdentifier 

type ReadReq_Options_FilterOptions_StreamIdentifier struct {
	StreamIdentifier *ReadReq_Options_FilterOptions_Expression `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3,oneof"`
}

type ReadReq_Options_NoFilter 

type ReadReq_Options_NoFilter struct {
	NoFilter *shared.Empty `protobuf:"bytes,8,opt,name=no_filter,json=noFilter,proto3,oneof"`
}

type ReadReq_Options_Position 

type ReadReq_Options_Position 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 (*ReadReq_Options_Position) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_Position.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_Position) GetCommitPosition 

func (x *ReadReq_Options_Position) GetCommitPosition() uint64

func (*ReadReq_Options_Position) GetPreparePosition 

func (x *ReadReq_Options_Position) GetPreparePosition() uint64

func (*ReadReq_Options_Position) ProtoMessage 

func (*ReadReq_Options_Position) ProtoMessage()

func (*ReadReq_Options_Position) ProtoReflect 

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

func (*ReadReq_Options_Position) Reset 

func (x *ReadReq_Options_Position) Reset()

func (*ReadReq_Options_Position) String 

func (x *ReadReq_Options_Position) String() string

type ReadReq_Options_ReadDirection 

type ReadReq_Options_ReadDirection int32
const (
	ReadReq_Options_Forwards  ReadReq_Options_ReadDirection = 0
	ReadReq_Options_Backwards ReadReq_Options_ReadDirection = 1
)

func (ReadReq_Options_ReadDirection) Descriptor 

func (ReadReq_Options_ReadDirection) Descriptor() protoreflect.EnumDescriptor

func (ReadReq_Options_ReadDirection) Enum 

func (x ReadReq_Options_ReadDirection) Enum() *ReadReq_Options_ReadDirection

func (ReadReq_Options_ReadDirection) EnumDescriptor deprecated 

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

Deprecated: Use ReadReq_Options_ReadDirection.Descriptor instead.

func (ReadReq_Options_ReadDirection) Number 

func (x ReadReq_Options_ReadDirection) Number() protoreflect.EnumNumber

func (ReadReq_Options_ReadDirection) String 

func (x ReadReq_Options_ReadDirection) String() string

func (ReadReq_Options_ReadDirection) Type 

func (ReadReq_Options_ReadDirection) Type() protoreflect.EnumType

type ReadReq_Options_Stream 

type ReadReq_Options_Stream struct {
	Stream *ReadReq_Options_StreamOptions `protobuf:"bytes,1,opt,name=stream,proto3,oneof"`
}

type ReadReq_Options_StreamOptions 

type ReadReq_Options_StreamOptions struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to RevisionOption:
	//	*ReadReq_Options_StreamOptions_Revision
	//	*ReadReq_Options_StreamOptions_Start
	//	*ReadReq_Options_StreamOptions_End
	RevisionOption isReadReq_Options_StreamOptions_RevisionOption `protobuf_oneof:"revision_option"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options_StreamOptions) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_StreamOptions.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_StreamOptions) GetEnd 

func (x *ReadReq_Options_StreamOptions) GetEnd() *shared.Empty

func (*ReadReq_Options_StreamOptions) GetRevision 

func (x *ReadReq_Options_StreamOptions) GetRevision() uint64

func (*ReadReq_Options_StreamOptions) GetRevisionOption 

func (m *ReadReq_Options_StreamOptions) GetRevisionOption() isReadReq_Options_StreamOptions_RevisionOption

func (*ReadReq_Options_StreamOptions) GetStart 

func (x *ReadReq_Options_StreamOptions) GetStart() *shared.Empty

func (*ReadReq_Options_StreamOptions) GetStreamIdentifier 

func (x *ReadReq_Options_StreamOptions) GetStreamIdentifier() *shared.StreamIdentifier

func (*ReadReq_Options_StreamOptions) ProtoMessage 

func (*ReadReq_Options_StreamOptions) ProtoMessage()

func (*ReadReq_Options_StreamOptions) ProtoReflect 

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

func (*ReadReq_Options_StreamOptions) Reset 

func (x *ReadReq_Options_StreamOptions) Reset()

func (*ReadReq_Options_StreamOptions) String 

func (x *ReadReq_Options_StreamOptions) String() string

type ReadReq_Options_StreamOptions_End 

type ReadReq_Options_StreamOptions_End struct {
	End *shared.Empty `protobuf:"bytes,4,opt,name=end,proto3,oneof"`
}

type ReadReq_Options_StreamOptions_Revision 

type ReadReq_Options_StreamOptions_Revision struct {
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3,oneof"`
}

type ReadReq_Options_StreamOptions_Start 

type ReadReq_Options_StreamOptions_Start struct {
	Start *shared.Empty `protobuf:"bytes,3,opt,name=start,proto3,oneof"`
}

type ReadReq_Options_Subscription 

type ReadReq_Options_Subscription struct {
	Subscription *ReadReq_Options_SubscriptionOptions `protobuf:"bytes,6,opt,name=subscription,proto3,oneof"`
}

type ReadReq_Options_SubscriptionOptions 

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

func (*ReadReq_Options_SubscriptionOptions) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_SubscriptionOptions.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_SubscriptionOptions) ProtoMessage 

func (*ReadReq_Options_SubscriptionOptions) ProtoMessage()

func (*ReadReq_Options_SubscriptionOptions) ProtoReflect 

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

func (*ReadReq_Options_SubscriptionOptions) Reset 

func (x *ReadReq_Options_SubscriptionOptions) Reset()

func (*ReadReq_Options_SubscriptionOptions) String 

func (x *ReadReq_Options_SubscriptionOptions) String() string

type ReadReq_Options_UUIDOption 

type ReadReq_Options_UUIDOption struct {

	// Types that are assignable to Content:
	//	*ReadReq_Options_UUIDOption_Structured
	//	*ReadReq_Options_UUIDOption_String_
	Content isReadReq_Options_UUIDOption_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options_UUIDOption) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_UUIDOption.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_UUIDOption) GetContent 

func (m *ReadReq_Options_UUIDOption) GetContent() isReadReq_Options_UUIDOption_Content

func (*ReadReq_Options_UUIDOption) GetString_ 

func (x *ReadReq_Options_UUIDOption) GetString_() *shared.Empty

func (*ReadReq_Options_UUIDOption) GetStructured 

func (x *ReadReq_Options_UUIDOption) GetStructured() *shared.Empty

func (*ReadReq_Options_UUIDOption) ProtoMessage 

func (*ReadReq_Options_UUIDOption) ProtoMessage()

func (*ReadReq_Options_UUIDOption) ProtoReflect 

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

func (*ReadReq_Options_UUIDOption) Reset 

func (x *ReadReq_Options_UUIDOption) Reset()

func (*ReadReq_Options_UUIDOption) String 

func (x *ReadReq_Options_UUIDOption) String() string

type ReadReq_Options_UUIDOption_String_ 

type ReadReq_Options_UUIDOption_String_ struct {
	String_ *shared.Empty `protobuf:"bytes,2,opt,name=string,proto3,oneof"`
}

type ReadReq_Options_UUIDOption_Structured 

type ReadReq_Options_UUIDOption_Structured struct {
	Structured *shared.Empty `protobuf:"bytes,1,opt,name=structured,proto3,oneof"`
}

type ReadResp 

type ReadResp struct {

	// Types that are assignable to Content:
	//	*ReadResp_Event
	//	*ReadResp_Confirmation
	//	*ReadResp_Checkpoint_
	//	*ReadResp_StreamNotFound_
	//	*ReadResp_FirstStreamPosition
	//	*ReadResp_LastStreamPosition
	//	*ReadResp_LastAllStreamPosition
	Content isReadResp_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ReadResp) Descriptor deprecated 

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

Deprecated: Use ReadResp.ProtoReflect.Descriptor instead.

func (*ReadResp) GetCheckpoint 

func (x *ReadResp) GetCheckpoint() *ReadResp_Checkpoint

func (*ReadResp) GetConfirmation 

func (x *ReadResp) GetConfirmation() *ReadResp_SubscriptionConfirmation

func (*ReadResp) GetContent 

func (m *ReadResp) GetContent() isReadResp_Content

func (*ReadResp) GetEvent 

func (x *ReadResp) GetEvent() *ReadResp_ReadEvent

func (*ReadResp) GetFirstStreamPosition 

func (x *ReadResp) GetFirstStreamPosition() uint64

func (*ReadResp) GetLastAllStreamPosition 

func (x *ReadResp) GetLastAllStreamPosition() *shared.AllStreamPosition

func (*ReadResp) GetLastStreamPosition 

func (x *ReadResp) GetLastStreamPosition() uint64

func (*ReadResp) GetStreamNotFound 

func (x *ReadResp) GetStreamNotFound() *ReadResp_StreamNotFound

func (*ReadResp) ProtoMessage 

func (*ReadResp) ProtoMessage()

func (*ReadResp) ProtoReflect 

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

func (*ReadResp) Reset 

func (x *ReadResp) Reset()

func (*ReadResp) String 

func (x *ReadResp) String() string

type ReadResp_Checkpoint 

type ReadResp_Checkpoint 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 (*ReadResp_Checkpoint) Descriptor deprecated 

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

Deprecated: Use ReadResp_Checkpoint.ProtoReflect.Descriptor instead.

func (*ReadResp_Checkpoint) GetCommitPosition 

func (x *ReadResp_Checkpoint) GetCommitPosition() uint64

func (*ReadResp_Checkpoint) GetPreparePosition 

func (x *ReadResp_Checkpoint) GetPreparePosition() uint64

func (*ReadResp_Checkpoint) ProtoMessage 

func (*ReadResp_Checkpoint) ProtoMessage()

func (*ReadResp_Checkpoint) ProtoReflect 

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

func (*ReadResp_Checkpoint) Reset 

func (x *ReadResp_Checkpoint) Reset()

func (*ReadResp_Checkpoint) String 

func (x *ReadResp_Checkpoint) String() string

type ReadResp_Checkpoint_ 

type ReadResp_Checkpoint_ struct {
	Checkpoint *ReadResp_Checkpoint `protobuf:"bytes,3,opt,name=checkpoint,proto3,oneof"`
}

type ReadResp_Confirmation 

type ReadResp_Confirmation struct {
	Confirmation *ReadResp_SubscriptionConfirmation `protobuf:"bytes,2,opt,name=confirmation,proto3,oneof"`
}

type ReadResp_Event 

type ReadResp_Event struct {
	Event *ReadResp_ReadEvent `protobuf:"bytes,1,opt,name=event,proto3,oneof"`
}

type ReadResp_FirstStreamPosition 

type ReadResp_FirstStreamPosition struct {
	FirstStreamPosition uint64 `protobuf:"varint,5,opt,name=first_stream_position,json=firstStreamPosition,proto3,oneof"`
}

type ReadResp_LastAllStreamPosition 

type ReadResp_LastAllStreamPosition struct {
	LastAllStreamPosition *shared.AllStreamPosition `protobuf:"bytes,7,opt,name=last_all_stream_position,json=lastAllStreamPosition,proto3,oneof"`
}

type ReadResp_LastStreamPosition 

type ReadResp_LastStreamPosition struct {
	LastStreamPosition uint64 `protobuf:"varint,6,opt,name=last_stream_position,json=lastStreamPosition,proto3,oneof"`
}

type ReadResp_ReadEvent 

type ReadResp_ReadEvent struct {
	Event *ReadResp_ReadEvent_RecordedEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	Link  *ReadResp_ReadEvent_RecordedEvent `protobuf:"bytes,2,opt,name=link,proto3" json:"link,omitempty"`
	// Types that are assignable to Position:
	//	*ReadResp_ReadEvent_CommitPosition
	//	*ReadResp_ReadEvent_NoPosition
	Position isReadResp_ReadEvent_Position `protobuf_oneof:"position"`
	// contains filtered or unexported fields
}

func (*ReadResp_ReadEvent) Descriptor deprecated 

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

Deprecated: Use ReadResp_ReadEvent.ProtoReflect.Descriptor instead.

func (*ReadResp_ReadEvent) GetCommitPosition 

func (x *ReadResp_ReadEvent) GetCommitPosition() uint64

func (*ReadResp_ReadEvent) GetEvent 

func (x *ReadResp_ReadEvent) GetEvent() *ReadResp_ReadEvent_RecordedEvent
func (x *ReadResp_ReadEvent) GetLink() *ReadResp_ReadEvent_RecordedEvent

func (*ReadResp_ReadEvent) GetNoPosition 

func (x *ReadResp_ReadEvent) GetNoPosition() *shared.Empty

func (*ReadResp_ReadEvent) GetPosition 

func (m *ReadResp_ReadEvent) GetPosition() isReadResp_ReadEvent_Position

func (*ReadResp_ReadEvent) ProtoMessage 

func (*ReadResp_ReadEvent) ProtoMessage()

func (*ReadResp_ReadEvent) ProtoReflect 

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

func (*ReadResp_ReadEvent) Reset 

func (x *ReadResp_ReadEvent) Reset()

func (*ReadResp_ReadEvent) String 

func (x *ReadResp_ReadEvent) String() string

type ReadResp_ReadEvent_CommitPosition 

type ReadResp_ReadEvent_CommitPosition struct {
	CommitPosition uint64 `protobuf:"varint,3,opt,name=commit_position,json=commitPosition,proto3,oneof"`
}

type ReadResp_ReadEvent_NoPosition 

type ReadResp_ReadEvent_NoPosition struct {
	NoPosition *shared.Empty `protobuf:"bytes,4,opt,name=no_position,json=noPosition,proto3,oneof"`
}

type ReadResp_ReadEvent_RecordedEvent 

type ReadResp_ReadEvent_RecordedEvent struct {
	Id               *shared.UUID             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,2,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	StreamRevision   uint64                   `protobuf:"varint,3,opt,name=stream_revision,json=streamRevision,proto3" json:"stream_revision,omitempty"`
	PreparePosition  uint64                   `protobuf:"varint,4,opt,name=prepare_position,json=preparePosition,proto3" json:"prepare_position,omitempty"`
	CommitPosition   uint64                   `protobuf:"varint,5,opt,name=commit_position,json=commitPosition,proto3" json:"commit_position,omitempty"`
	Metadata         map[string]string        `` /* 157-byte string literal not displayed */
	CustomMetadata   []byte                   `protobuf:"bytes,7,opt,name=custom_metadata,json=customMetadata,proto3" json:"custom_metadata,omitempty"`
	Data             []byte                   `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResp_ReadEvent_RecordedEvent) Descriptor deprecated 

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

Deprecated: Use ReadResp_ReadEvent_RecordedEvent.ProtoReflect.Descriptor instead.

func (*ReadResp_ReadEvent_RecordedEvent) GetCommitPosition 

func (x *ReadResp_ReadEvent_RecordedEvent) GetCommitPosition() uint64

func (*ReadResp_ReadEvent_RecordedEvent) GetCustomMetadata 

func (x *ReadResp_ReadEvent_RecordedEvent) GetCustomMetadata() []byte

func (*ReadResp_ReadEvent_RecordedEvent) GetData 

func (x *ReadResp_ReadEvent_RecordedEvent) GetData() []byte

func (*ReadResp_ReadEvent_RecordedEvent) GetId 

func (x *ReadResp_ReadEvent_RecordedEvent) GetId() *shared.UUID

func (*ReadResp_ReadEvent_RecordedEvent) GetMetadata 

func (x *ReadResp_ReadEvent_RecordedEvent) GetMetadata() map[string]string

func (*ReadResp_ReadEvent_RecordedEvent) GetPreparePosition 

func (x *ReadResp_ReadEvent_RecordedEvent) GetPreparePosition() uint64

func (*ReadResp_ReadEvent_RecordedEvent) GetStreamIdentifier 

func (x *ReadResp_ReadEvent_RecordedEvent) GetStreamIdentifier() *shared.StreamIdentifier

func (*ReadResp_ReadEvent_RecordedEvent) GetStreamRevision 

func (x *ReadResp_ReadEvent_RecordedEvent) GetStreamRevision() uint64

func (*ReadResp_ReadEvent_RecordedEvent) ProtoMessage 

func (*ReadResp_ReadEvent_RecordedEvent) ProtoMessage()

func (*ReadResp_ReadEvent_RecordedEvent) ProtoReflect 

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

func (*ReadResp_ReadEvent_RecordedEvent) Reset 

func (x *ReadResp_ReadEvent_RecordedEvent) Reset()

func (*ReadResp_ReadEvent_RecordedEvent) String 

func (x *ReadResp_ReadEvent_RecordedEvent) String() string

type ReadResp_StreamNotFound 

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

func (*ReadResp_StreamNotFound) Descriptor deprecated 

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

Deprecated: Use ReadResp_StreamNotFound.ProtoReflect.Descriptor instead.

func (*ReadResp_StreamNotFound) GetStreamIdentifier 

func (x *ReadResp_StreamNotFound) GetStreamIdentifier() *shared.StreamIdentifier

func (*ReadResp_StreamNotFound) ProtoMessage 

func (*ReadResp_StreamNotFound) ProtoMessage()

func (*ReadResp_StreamNotFound) ProtoReflect 

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

func (*ReadResp_StreamNotFound) Reset 

func (x *ReadResp_StreamNotFound) Reset()

func (*ReadResp_StreamNotFound) String 

func (x *ReadResp_StreamNotFound) String() string

type ReadResp_StreamNotFound_ 

type ReadResp_StreamNotFound_ struct {
	StreamNotFound *ReadResp_StreamNotFound `protobuf:"bytes,4,opt,name=stream_not_found,json=streamNotFound,proto3,oneof"`
}

type ReadResp_SubscriptionConfirmation 

type ReadResp_SubscriptionConfirmation struct {
	SubscriptionId string `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResp_SubscriptionConfirmation) Descriptor deprecated 

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

Deprecated: Use ReadResp_SubscriptionConfirmation.ProtoReflect.Descriptor instead.

func (*ReadResp_SubscriptionConfirmation) GetSubscriptionId 

func (x *ReadResp_SubscriptionConfirmation) GetSubscriptionId() string

func (*ReadResp_SubscriptionConfirmation) ProtoMessage 

func (*ReadResp_SubscriptionConfirmation) ProtoMessage()

func (*ReadResp_SubscriptionConfirmation) ProtoReflect 

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

func (*ReadResp_SubscriptionConfirmation) Reset 

func (x *ReadResp_SubscriptionConfirmation) Reset()

func (*ReadResp_SubscriptionConfirmation) String 

func (x *ReadResp_SubscriptionConfirmation) String() string

type StreamsClient 

type StreamsClient interface {
	Read(ctx context.Context, in *ReadReq, opts ...grpc.CallOption) (Streams_ReadClient, error)
	Append(ctx context.Context, opts ...grpc.CallOption) (Streams_AppendClient, error)
	Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteResp, error)
	Tombstone(ctx context.Context, in *TombstoneReq, opts ...grpc.CallOption) (*TombstoneResp, error)
	BatchAppend(ctx context.Context, opts ...grpc.CallOption) (Streams_BatchAppendClient, error)
}

StreamsClient is the client API for Streams 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 NewStreamsClient 

func NewStreamsClient(cc grpc.ClientConnInterface) StreamsClient

type StreamsServer 

type StreamsServer interface {
	Read(*ReadReq, Streams_ReadServer) error
	Append(Streams_AppendServer) error
	Delete(context.Context, *DeleteReq) (*DeleteResp, error)
	Tombstone(context.Context, *TombstoneReq) (*TombstoneResp, error)
	BatchAppend(Streams_BatchAppendServer) error
	// contains filtered or unexported methods
}

StreamsServer is the server API for Streams service. All implementations must embed UnimplementedStreamsServer for forward compatibility

type Streams_AppendClient 

type Streams_AppendClient interface {
	Send(*AppendReq) error
	CloseAndRecv() (*AppendResp, error)
	grpc.ClientStream
}

type Streams_AppendServer 

type Streams_AppendServer interface {
	SendAndClose(*AppendResp) error
	Recv() (*AppendReq, error)
	grpc.ServerStream
}

type Streams_BatchAppendClient 

type Streams_BatchAppendClient interface {
	Send(*BatchAppendReq) error
	Recv() (*BatchAppendResp, error)
	grpc.ClientStream
}

type Streams_BatchAppendServer 

type Streams_BatchAppendServer interface {
	Send(*BatchAppendResp) error
	Recv() (*BatchAppendReq, error)
	grpc.ServerStream
}

type Streams_ReadClient 

type Streams_ReadClient interface {
	Recv() (*ReadResp, error)
	grpc.ClientStream
}

type Streams_ReadServer 

type Streams_ReadServer interface {
	Send(*ReadResp) error
	grpc.ServerStream
}

type TombstoneReq 

type TombstoneReq struct {
	Options *TombstoneReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*TombstoneReq) Descriptor deprecated 

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

Deprecated: Use TombstoneReq.ProtoReflect.Descriptor instead.

func (*TombstoneReq) GetOptions 

func (x *TombstoneReq) GetOptions() *TombstoneReq_Options

func (*TombstoneReq) ProtoMessage 

func (*TombstoneReq) ProtoMessage()

func (*TombstoneReq) ProtoReflect 

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

func (*TombstoneReq) Reset 

func (x *TombstoneReq) Reset()

func (*TombstoneReq) String 

func (x *TombstoneReq) String() string

type TombstoneReq_Options 

type TombstoneReq_Options struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	// Types that are assignable to ExpectedStreamRevision:
	//	*TombstoneReq_Options_Revision
	//	*TombstoneReq_Options_NoStream
	//	*TombstoneReq_Options_Any
	//	*TombstoneReq_Options_StreamExists
	ExpectedStreamRevision isTombstoneReq_Options_ExpectedStreamRevision `protobuf_oneof:"expected_stream_revision"`
	// contains filtered or unexported fields
}

func (*TombstoneReq_Options) Descriptor deprecated 

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

Deprecated: Use TombstoneReq_Options.ProtoReflect.Descriptor instead.

func (*TombstoneReq_Options) GetAny 

func (x *TombstoneReq_Options) GetAny() *shared.Empty

func (*TombstoneReq_Options) GetExpectedStreamRevision 

func (m *TombstoneReq_Options) GetExpectedStreamRevision() isTombstoneReq_Options_ExpectedStreamRevision

func (*TombstoneReq_Options) GetNoStream 

func (x *TombstoneReq_Options) GetNoStream() *shared.Empty

func (*TombstoneReq_Options) GetRevision 

func (x *TombstoneReq_Options) GetRevision() uint64

func (*TombstoneReq_Options) GetStreamExists 

func (x *TombstoneReq_Options) GetStreamExists() *shared.Empty

func (*TombstoneReq_Options) GetStreamIdentifier 

func (x *TombstoneReq_Options) GetStreamIdentifier() *shared.StreamIdentifier

func (*TombstoneReq_Options) ProtoMessage 

func (*TombstoneReq_Options) ProtoMessage()

func (*TombstoneReq_Options) ProtoReflect 

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

func (*TombstoneReq_Options) Reset 

func (x *TombstoneReq_Options) Reset()

func (*TombstoneReq_Options) String 

func (x *TombstoneReq_Options) String() string

type TombstoneReq_Options_Any 

type TombstoneReq_Options_Any struct {
	Any *shared.Empty `protobuf:"bytes,4,opt,name=any,proto3,oneof"`
}

type TombstoneReq_Options_NoStream 

type TombstoneReq_Options_NoStream struct {
	NoStream *shared.Empty `protobuf:"bytes,3,opt,name=no_stream,json=noStream,proto3,oneof"`
}

type TombstoneReq_Options_Revision 

type TombstoneReq_Options_Revision struct {
	Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3,oneof"`
}

type TombstoneReq_Options_StreamExists 

type TombstoneReq_Options_StreamExists struct {
	StreamExists *shared.Empty `protobuf:"bytes,5,opt,name=stream_exists,json=streamExists,proto3,oneof"`
}

type TombstoneResp 

type TombstoneResp struct {

	// Types that are assignable to PositionOption:
	//	*TombstoneResp_Position_
	//	*TombstoneResp_NoPosition
	PositionOption isTombstoneResp_PositionOption `protobuf_oneof:"position_option"`
	// contains filtered or unexported fields
}

func (*TombstoneResp) Descriptor deprecated 

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

Deprecated: Use TombstoneResp.ProtoReflect.Descriptor instead.

func (*TombstoneResp) GetNoPosition 

func (x *TombstoneResp) GetNoPosition() *shared.Empty

func (*TombstoneResp) GetPosition 

func (x *TombstoneResp) GetPosition() *TombstoneResp_Position

func (*TombstoneResp) GetPositionOption 

func (m *TombstoneResp) GetPositionOption() isTombstoneResp_PositionOption

func (*TombstoneResp) ProtoMessage 

func (*TombstoneResp) ProtoMessage()

func (*TombstoneResp) ProtoReflect 

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

func (*TombstoneResp) Reset 

func (x *TombstoneResp) Reset()

func (*TombstoneResp) String 

func (x *TombstoneResp) String() string

type TombstoneResp_NoPosition 

type TombstoneResp_NoPosition struct {
	NoPosition *shared.Empty `protobuf:"bytes,2,opt,name=no_position,json=noPosition,proto3,oneof"`
}

type TombstoneResp_Position 

type TombstoneResp_Position 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 (*TombstoneResp_Position) Descriptor deprecated 

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

Deprecated: Use TombstoneResp_Position.ProtoReflect.Descriptor instead.

func (*TombstoneResp_Position) GetCommitPosition 

func (x *TombstoneResp_Position) GetCommitPosition() uint64

func (*TombstoneResp_Position) GetPreparePosition 

func (x *TombstoneResp_Position) GetPreparePosition() uint64

func (*TombstoneResp_Position) ProtoMessage 

func (*TombstoneResp_Position) ProtoMessage()

func (*TombstoneResp_Position) ProtoReflect 

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

func (*TombstoneResp_Position) Reset 

func (x *TombstoneResp_Position) Reset()

func (*TombstoneResp_Position) String 

func (x *TombstoneResp_Position) String() string

type TombstoneResp_Position_ 

type TombstoneResp_Position_ struct {
	Position *TombstoneResp_Position `protobuf:"bytes,1,opt,name=position,proto3,oneof"`
}

type UnimplementedStreamsServer 

type UnimplementedStreamsServer struct {
}

UnimplementedStreamsServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamsServer) Append 

func (UnimplementedStreamsServer) Append(Streams_AppendServer) error

func (UnimplementedStreamsServer) BatchAppend 

func (UnimplementedStreamsServer) BatchAppend(Streams_BatchAppendServer) error

func (UnimplementedStreamsServer) Delete 

func (UnimplementedStreamsServer) Delete(context.Context, *DeleteReq) (*DeleteResp, error)

func (UnimplementedStreamsServer) Read 

func (UnimplementedStreamsServer) Read(*ReadReq, Streams_ReadServer) error

func (UnimplementedStreamsServer) Tombstone 

func (UnimplementedStreamsServer) Tombstone(context.Context, *TombstoneReq) (*TombstoneResp, error)

type UnsafeStreamsServer 

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

UnsafeStreamsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamsServer 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.