streams

type AppendReq struct {

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

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
}

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

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

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

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

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

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
}

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

type AppendResp struct {

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

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
}

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
}

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

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

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

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

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

type AppendResp_WrongExpectedVersion struct {

	// Types that are assignable to CurrentRevisionOption:
	//	*AppendResp_WrongExpectedVersion_CurrentRevision
	//	*AppendResp_WrongExpectedVersion_NoStream
	CurrentRevisionOption isAppendResp_WrongExpectedVersion_CurrentRevisionOption `protobuf_oneof:"current_revision_option"`
	// Types that are assignable to ExpectedRevisionOption:
	//	*AppendResp_WrongExpectedVersion_ExpectedRevision
	//	*AppendResp_WrongExpectedVersion_Any
	//	*AppendResp_WrongExpectedVersion_StreamExists
	ExpectedRevisionOption isAppendResp_WrongExpectedVersion_ExpectedRevisionOption `protobuf_oneof:"expected_revision_option"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

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
}

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

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

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

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

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
}

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

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
}

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

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

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

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

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
}

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

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

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

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

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

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
}

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

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 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
}

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

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 struct {
	NoFilter *shared.Empty `protobuf:"bytes,8,opt,name=no_filter,json=noFilter,proto3,oneof"`
}

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
}

type ReadReq_Options_ReadDirection int32

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

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
}

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

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

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

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

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

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
}

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

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

type ReadResp struct {

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

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
}

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

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

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

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
}

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

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

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
}

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
}

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

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
}

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)
}

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

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

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

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

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

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

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
}

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

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

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

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

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
}

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

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
}

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

type UnimplementedStreamsServer struct {
}

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