Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

streams

package

Go to main page

Versions in this module

v2

v2.1.1

May 24, 2022

v2.1.0

May 2, 2022

v2.0.2

Apr 13, 2022

v2.0.1

Mar 23, 2022

Changes in this version

+ var File_streams_proto protoreflect.FileDescriptor

+ var ReadReq_Options_ReadDirection_name = map[int32]string

+ var ReadReq_Options_ReadDirection_value = map[string]int32

+ var Streams_ServiceDesc = grpc.ServiceDesc

+ func RegisterStreamsServer(s grpc.ServiceRegistrar, srv StreamsServer)

+ type AppendReq struct

+ Content isAppendReq_Content

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

+ func (*AppendReq) ProtoMessage()

+ func (m *AppendReq) GetContent() isAppendReq_Content

+ func (x *AppendReq) GetOptions() *AppendReq_Options

+ func (x *AppendReq) GetProposedMessage() *AppendReq_ProposedMessage

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

+ func (x *AppendReq) Reset()

+ func (x *AppendReq) String() string

+ type AppendReq_Options struct

+ ExpectedStreamRevision isAppendReq_Options_ExpectedStreamRevision

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*AppendReq_Options) ProtoMessage()

+ func (m *AppendReq_Options) GetExpectedStreamRevision() isAppendReq_Options_ExpectedStreamRevision

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

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

+ func (x *AppendReq_Options) GetRevision() uint64

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

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

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

+ func (x *AppendReq_Options) Reset()

+ func (x *AppendReq_Options) String() string

+ type AppendReq_Options_ struct

+ Options *AppendReq_Options

+ type AppendReq_Options_Any struct

+ Any *shared.Empty

+ type AppendReq_Options_NoStream struct

+ NoStream *shared.Empty

+ type AppendReq_Options_Revision struct

+ Revision uint64

+ type AppendReq_Options_StreamExists struct

+ StreamExists *shared.Empty

+ type AppendReq_ProposedMessage struct

+ CustomMetadata []byte

+ Data []byte

+ Id *shared.UUID

+ Metadata map[string]string

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

+ func (*AppendReq_ProposedMessage) ProtoMessage()

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

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

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

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

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

+ func (x *AppendReq_ProposedMessage) Reset()

+ func (x *AppendReq_ProposedMessage) String() string

+ type AppendReq_ProposedMessage_ struct

+ ProposedMessage *AppendReq_ProposedMessage

+ type AppendResp struct

+ Result isAppendResp_Result

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

+ func (*AppendResp) ProtoMessage()

+ func (m *AppendResp) GetResult() isAppendResp_Result

+ func (x *AppendResp) GetSuccess() *AppendResp_Success

+ func (x *AppendResp) GetWrongExpectedVersion() *AppendResp_WrongExpectedVersion

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

+ func (x *AppendResp) Reset()

+ func (x *AppendResp) String() string

+ type AppendResp_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*AppendResp_Position) ProtoMessage()

+ func (x *AppendResp_Position) GetCommitPosition() uint64

+ func (x *AppendResp_Position) GetPreparePosition() uint64

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

+ func (x *AppendResp_Position) Reset()

+ func (x *AppendResp_Position) String() string

+ type AppendResp_Success struct

+ CurrentRevisionOption isAppendResp_Success_CurrentRevisionOption

+ PositionOption isAppendResp_Success_PositionOption

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

+ func (*AppendResp_Success) ProtoMessage()

+ func (m *AppendResp_Success) GetCurrentRevisionOption() isAppendResp_Success_CurrentRevisionOption

+ func (m *AppendResp_Success) GetPositionOption() isAppendResp_Success_PositionOption

+ func (x *AppendResp_Success) GetCurrentRevision() uint64

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

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

+ func (x *AppendResp_Success) GetPosition() *AppendResp_Position

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

+ func (x *AppendResp_Success) Reset()

+ func (x *AppendResp_Success) String() string

+ type AppendResp_Success_ struct

+ Success *AppendResp_Success

+ type AppendResp_Success_CurrentRevision struct

+ CurrentRevision uint64

+ type AppendResp_Success_NoPosition struct

+ NoPosition *shared.Empty

+ type AppendResp_Success_NoStream struct

+ NoStream *shared.Empty

+ type AppendResp_Success_Position struct

+ Position *AppendResp_Position

+ type AppendResp_WrongExpectedVersion struct

+ CurrentRevisionOption isAppendResp_WrongExpectedVersion_CurrentRevisionOption

+ CurrentRevisionOption_20_6_0 isAppendResp_WrongExpectedVersion_CurrentRevisionOption_20_6_0

+ ExpectedRevisionOption isAppendResp_WrongExpectedVersion_ExpectedRevisionOption

+ ExpectedRevisionOption_20_6_0 isAppendResp_WrongExpectedVersion_ExpectedRevisionOption_20_6_0

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

+ func (*AppendResp_WrongExpectedVersion) ProtoMessage()

+ func (m *AppendResp_WrongExpectedVersion) GetCurrentRevisionOption() isAppendResp_WrongExpectedVersion_CurrentRevisionOption

+ func (m *AppendResp_WrongExpectedVersion) GetCurrentRevisionOption_20_6_0() isAppendResp_WrongExpectedVersion_CurrentRevisionOption_20_6_0

+ func (m *AppendResp_WrongExpectedVersion) GetExpectedRevisionOption() isAppendResp_WrongExpectedVersion_ExpectedRevisionOption

+ func (m *AppendResp_WrongExpectedVersion) GetExpectedRevisionOption_20_6_0() isAppendResp_WrongExpectedVersion_ExpectedRevisionOption_20_6_0

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

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

+ func (x *AppendResp_WrongExpectedVersion) GetCurrentRevision() uint64

+ func (x *AppendResp_WrongExpectedVersion) GetCurrentRevision_20_6_0() uint64

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

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

+ func (x *AppendResp_WrongExpectedVersion) GetExpectedRevision() uint64

+ func (x *AppendResp_WrongExpectedVersion) GetExpectedRevision_20_6_0() uint64

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

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

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

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

+ func (x *AppendResp_WrongExpectedVersion) Reset()

+ func (x *AppendResp_WrongExpectedVersion) String() string

+ type AppendResp_WrongExpectedVersion_ struct

+ WrongExpectedVersion *AppendResp_WrongExpectedVersion

+ type AppendResp_WrongExpectedVersion_Any_20_6_0 struct

+ Any_20_6_0 *shared.Empty

+ type AppendResp_WrongExpectedVersion_CurrentNoStream struct

+ CurrentNoStream *shared.Empty

+ type AppendResp_WrongExpectedVersion_CurrentRevision struct

+ CurrentRevision uint64

+ type AppendResp_WrongExpectedVersion_CurrentRevision_20_6_0 struct

+ CurrentRevision_20_6_0 uint64

+ type AppendResp_WrongExpectedVersion_ExpectedAny struct

+ ExpectedAny *shared.Empty

+ type AppendResp_WrongExpectedVersion_ExpectedNoStream struct

+ ExpectedNoStream *shared.Empty

+ type AppendResp_WrongExpectedVersion_ExpectedRevision struct

+ ExpectedRevision uint64

+ type AppendResp_WrongExpectedVersion_ExpectedRevision_20_6_0 struct

+ ExpectedRevision_20_6_0 uint64

+ type AppendResp_WrongExpectedVersion_ExpectedStreamExists struct

+ ExpectedStreamExists *shared.Empty

+ type AppendResp_WrongExpectedVersion_NoStream_20_6_0 struct

+ NoStream_20_6_0 *shared.Empty

+ type AppendResp_WrongExpectedVersion_StreamExists_20_6_0 struct

+ StreamExists_20_6_0 *shared.Empty

+ type BatchAppendReq struct

+ CorrelationId *shared.UUID

+ IsFinal bool

+ Options *BatchAppendReq_Options

+ ProposedMessages []*BatchAppendReq_ProposedMessage

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

+ func (*BatchAppendReq) ProtoMessage()

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

+ func (x *BatchAppendReq) GetIsFinal() bool

+ func (x *BatchAppendReq) GetOptions() *BatchAppendReq_Options

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

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

+ func (x *BatchAppendReq) Reset()

+ func (x *BatchAppendReq) String() string

+ type BatchAppendReq_Options struct

+ Deadline *timestamppb.Timestamp

+ ExpectedStreamPosition isBatchAppendReq_Options_ExpectedStreamPosition

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*BatchAppendReq_Options) ProtoMessage()

+ func (m *BatchAppendReq_Options) GetExpectedStreamPosition() isBatchAppendReq_Options_ExpectedStreamPosition

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

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

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

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

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

+ func (x *BatchAppendReq_Options) GetStreamPosition() uint64

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

+ func (x *BatchAppendReq_Options) Reset()

+ func (x *BatchAppendReq_Options) String() string

+ type BatchAppendReq_Options_Any struct

+ Any *emptypb.Empty

+ type BatchAppendReq_Options_NoStream struct

+ NoStream *emptypb.Empty

+ type BatchAppendReq_Options_StreamExists struct

+ StreamExists *emptypb.Empty

+ type BatchAppendReq_Options_StreamPosition struct

+ StreamPosition uint64

+ type BatchAppendReq_ProposedMessage struct

+ CustomMetadata []byte

+ Data []byte

+ Id *shared.UUID

+ Metadata map[string]string

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

+ func (*BatchAppendReq_ProposedMessage) ProtoMessage()

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

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

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

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

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

+ func (x *BatchAppendReq_ProposedMessage) Reset()

+ func (x *BatchAppendReq_ProposedMessage) String() string

+ type BatchAppendResp struct

+ CorrelationId *shared.UUID

+ ExpectedStreamPosition isBatchAppendResp_ExpectedStreamPosition

+ Result isBatchAppendResp_Result

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*BatchAppendResp) ProtoMessage()

+ func (m *BatchAppendResp) GetExpectedStreamPosition() isBatchAppendResp_ExpectedStreamPosition

+ func (m *BatchAppendResp) GetResult() isBatchAppendResp_Result

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

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

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

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

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

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

+ func (x *BatchAppendResp) GetStreamPosition() uint64

+ func (x *BatchAppendResp) GetSuccess() *BatchAppendResp_Success

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

+ func (x *BatchAppendResp) Reset()

+ func (x *BatchAppendResp) String() string

+ type BatchAppendResp_Any struct

+ Any *emptypb.Empty

+ type BatchAppendResp_Error struct

+ Error *status.Status

+ type BatchAppendResp_NoStream struct

+ NoStream *emptypb.Empty

+ type BatchAppendResp_StreamExists struct

+ StreamExists *emptypb.Empty

+ type BatchAppendResp_StreamPosition struct

+ StreamPosition uint64

+ type BatchAppendResp_Success struct

+ CurrentRevisionOption isBatchAppendResp_Success_CurrentRevisionOption

+ PositionOption isBatchAppendResp_Success_PositionOption

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

+ func (*BatchAppendResp_Success) ProtoMessage()

+ func (m *BatchAppendResp_Success) GetCurrentRevisionOption() isBatchAppendResp_Success_CurrentRevisionOption

+ func (m *BatchAppendResp_Success) GetPositionOption() isBatchAppendResp_Success_PositionOption

+ func (x *BatchAppendResp_Success) GetCurrentRevision() uint64

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

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

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

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

+ func (x *BatchAppendResp_Success) Reset()

+ func (x *BatchAppendResp_Success) String() string

+ type BatchAppendResp_Success_ struct

+ Success *BatchAppendResp_Success

+ type BatchAppendResp_Success_CurrentRevision struct

+ CurrentRevision uint64

+ type BatchAppendResp_Success_NoPosition struct

+ NoPosition *emptypb.Empty

+ type BatchAppendResp_Success_NoStream struct

+ NoStream *emptypb.Empty

+ type BatchAppendResp_Success_Position struct

+ Position *shared.AllStreamPosition

+ type DeleteReq struct

+ Options *DeleteReq_Options

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

+ func (*DeleteReq) ProtoMessage()

+ func (x *DeleteReq) GetOptions() *DeleteReq_Options

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

+ func (x *DeleteReq) Reset()

+ func (x *DeleteReq) String() string

+ type DeleteReq_Options struct

+ ExpectedStreamRevision isDeleteReq_Options_ExpectedStreamRevision

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*DeleteReq_Options) ProtoMessage()

+ func (m *DeleteReq_Options) GetExpectedStreamRevision() isDeleteReq_Options_ExpectedStreamRevision

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

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

+ func (x *DeleteReq_Options) GetRevision() uint64

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

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

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

+ func (x *DeleteReq_Options) Reset()

+ func (x *DeleteReq_Options) String() string

+ type DeleteReq_Options_Any struct

+ Any *shared.Empty

+ type DeleteReq_Options_NoStream struct

+ NoStream *shared.Empty

+ type DeleteReq_Options_Revision struct

+ Revision uint64

+ type DeleteReq_Options_StreamExists struct

+ StreamExists *shared.Empty

+ type DeleteResp struct

+ PositionOption isDeleteResp_PositionOption

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

+ func (*DeleteResp) ProtoMessage()

+ func (m *DeleteResp) GetPositionOption() isDeleteResp_PositionOption

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

+ func (x *DeleteResp) GetPosition() *DeleteResp_Position

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

+ func (x *DeleteResp) Reset()

+ func (x *DeleteResp) String() string

+ type DeleteResp_NoPosition struct

+ NoPosition *shared.Empty

+ type DeleteResp_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*DeleteResp_Position) ProtoMessage()

+ func (x *DeleteResp_Position) GetCommitPosition() uint64

+ func (x *DeleteResp_Position) GetPreparePosition() uint64

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

+ func (x *DeleteResp_Position) Reset()

+ func (x *DeleteResp_Position) String() string

+ type DeleteResp_Position_ struct

+ Position *DeleteResp_Position

+ type ReadReq struct

+ Options *ReadReq_Options

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

+ func (*ReadReq) ProtoMessage()

+ func (x *ReadReq) GetOptions() *ReadReq_Options

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

+ func (x *ReadReq) Reset()

+ func (x *ReadReq) String() string

+ type ReadReq_Options struct

+ ControlOption *ReadReq_Options_ControlOption

+ CountOption isReadReq_Options_CountOption

+ FilterOption isReadReq_Options_FilterOption

+ ReadDirection ReadReq_Options_ReadDirection

+ ResolveLinks bool

+ StreamOption isReadReq_Options_StreamOption

+ UuidOption *ReadReq_Options_UUIDOption

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

+ func (*ReadReq_Options) ProtoMessage()

+ func (m *ReadReq_Options) GetCountOption() isReadReq_Options_CountOption

+ func (m *ReadReq_Options) GetFilterOption() isReadReq_Options_FilterOption

+ func (m *ReadReq_Options) GetStreamOption() isReadReq_Options_StreamOption

+ func (x *ReadReq_Options) GetAll() *ReadReq_Options_AllOptions

+ func (x *ReadReq_Options) GetControlOption() *ReadReq_Options_ControlOption

+ func (x *ReadReq_Options) GetCount() uint64

+ func (x *ReadReq_Options) GetFilter() *ReadReq_Options_FilterOptions

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

+ func (x *ReadReq_Options) GetReadDirection() ReadReq_Options_ReadDirection

+ func (x *ReadReq_Options) GetResolveLinks() bool

+ func (x *ReadReq_Options) GetStream() *ReadReq_Options_StreamOptions

+ func (x *ReadReq_Options) GetSubscription() *ReadReq_Options_SubscriptionOptions

+ func (x *ReadReq_Options) GetUuidOption() *ReadReq_Options_UUIDOption

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

+ func (x *ReadReq_Options) Reset()

+ func (x *ReadReq_Options) String() string

+ type ReadReq_Options_All struct

+ All *ReadReq_Options_AllOptions

+ type ReadReq_Options_AllOptions struct

+ AllOption isReadReq_Options_AllOptions_AllOption

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

+ func (*ReadReq_Options_AllOptions) ProtoMessage()

+ func (m *ReadReq_Options_AllOptions) GetAllOption() isReadReq_Options_AllOptions_AllOption

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

+ func (x *ReadReq_Options_AllOptions) GetPosition() *ReadReq_Options_Position

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

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

+ func (x *ReadReq_Options_AllOptions) Reset()

+ func (x *ReadReq_Options_AllOptions) String() string

+ type ReadReq_Options_AllOptions_End struct

+ End *shared.Empty

+ type ReadReq_Options_AllOptions_Position struct

+ Position *ReadReq_Options_Position

+ type ReadReq_Options_AllOptions_Start struct

+ Start *shared.Empty

+ type ReadReq_Options_ControlOption struct

+ Compatibility uint32

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

+ func (*ReadReq_Options_ControlOption) ProtoMessage()

+ func (x *ReadReq_Options_ControlOption) GetCompatibility() uint32

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

+ func (x *ReadReq_Options_ControlOption) Reset()

+ func (x *ReadReq_Options_ControlOption) String() string

+ type ReadReq_Options_Count struct

+ Count uint64

+ type ReadReq_Options_Filter struct

+ Filter *ReadReq_Options_FilterOptions

+ type ReadReq_Options_FilterOptions struct

+ CheckpointIntervalMultiplier uint32

+ Filter isReadReq_Options_FilterOptions_Filter

+ Window isReadReq_Options_FilterOptions_Window

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

+ func (*ReadReq_Options_FilterOptions) ProtoMessage()

+ func (m *ReadReq_Options_FilterOptions) GetFilter() isReadReq_Options_FilterOptions_Filter

+ func (m *ReadReq_Options_FilterOptions) GetWindow() isReadReq_Options_FilterOptions_Window

+ func (x *ReadReq_Options_FilterOptions) GetCheckpointIntervalMultiplier() uint32

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

+ func (x *ReadReq_Options_FilterOptions) GetEventType() *ReadReq_Options_FilterOptions_Expression

+ func (x *ReadReq_Options_FilterOptions) GetMax() uint32

+ func (x *ReadReq_Options_FilterOptions) GetStreamIdentifier() *ReadReq_Options_FilterOptions_Expression

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

+ func (x *ReadReq_Options_FilterOptions) Reset()

+ func (x *ReadReq_Options_FilterOptions) String() string

+ type ReadReq_Options_FilterOptions_Count struct

+ Count *shared.Empty

+ type ReadReq_Options_FilterOptions_EventType struct

+ EventType *ReadReq_Options_FilterOptions_Expression

+ type ReadReq_Options_FilterOptions_Expression struct

+ Prefix []string

+ Regex string

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

+ func (*ReadReq_Options_FilterOptions_Expression) ProtoMessage()

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

+ func (x *ReadReq_Options_FilterOptions_Expression) GetRegex() string

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

+ func (x *ReadReq_Options_FilterOptions_Expression) Reset()

+ func (x *ReadReq_Options_FilterOptions_Expression) String() string

+ type ReadReq_Options_FilterOptions_Max struct

+ Max uint32

+ type ReadReq_Options_FilterOptions_StreamIdentifier struct

+ StreamIdentifier *ReadReq_Options_FilterOptions_Expression

+ type ReadReq_Options_NoFilter struct

+ NoFilter *shared.Empty

+ type ReadReq_Options_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*ReadReq_Options_Position) ProtoMessage()

+ func (x *ReadReq_Options_Position) GetCommitPosition() uint64

+ func (x *ReadReq_Options_Position) GetPreparePosition() uint64

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

+ func (x *ReadReq_Options_Position) Reset()

+ func (x *ReadReq_Options_Position) String() string

+ type ReadReq_Options_ReadDirection int32

+ const ReadReq_Options_Backwards

+ const ReadReq_Options_Forwards

+ func (ReadReq_Options_ReadDirection) Descriptor() protoreflect.EnumDescriptor

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

+ func (ReadReq_Options_ReadDirection) Type() protoreflect.EnumType

+ func (x ReadReq_Options_ReadDirection) Enum() *ReadReq_Options_ReadDirection

+ func (x ReadReq_Options_ReadDirection) Number() protoreflect.EnumNumber

+ func (x ReadReq_Options_ReadDirection) String() string

+ type ReadReq_Options_Stream struct

+ Stream *ReadReq_Options_StreamOptions

+ type ReadReq_Options_StreamOptions struct

+ RevisionOption isReadReq_Options_StreamOptions_RevisionOption

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*ReadReq_Options_StreamOptions) ProtoMessage()

+ func (m *ReadReq_Options_StreamOptions) GetRevisionOption() isReadReq_Options_StreamOptions_RevisionOption

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

+ func (x *ReadReq_Options_StreamOptions) GetRevision() uint64

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

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

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

+ func (x *ReadReq_Options_StreamOptions) Reset()

+ func (x *ReadReq_Options_StreamOptions) String() string

+ type ReadReq_Options_StreamOptions_End struct

+ End *shared.Empty

+ type ReadReq_Options_StreamOptions_Revision struct

+ Revision uint64

+ type ReadReq_Options_StreamOptions_Start struct

+ Start *shared.Empty

+ type ReadReq_Options_Subscription struct

+ Subscription *ReadReq_Options_SubscriptionOptions

+ type ReadReq_Options_SubscriptionOptions struct

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

+ func (*ReadReq_Options_SubscriptionOptions) ProtoMessage()

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

+ func (x *ReadReq_Options_SubscriptionOptions) Reset()

+ func (x *ReadReq_Options_SubscriptionOptions) String() string

+ type ReadReq_Options_UUIDOption struct

+ Content isReadReq_Options_UUIDOption_Content

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

+ func (*ReadReq_Options_UUIDOption) ProtoMessage()

+ func (m *ReadReq_Options_UUIDOption) GetContent() isReadReq_Options_UUIDOption_Content

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

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

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

+ func (x *ReadReq_Options_UUIDOption) Reset()

+ func (x *ReadReq_Options_UUIDOption) String() string

+ type ReadReq_Options_UUIDOption_String_ struct

+ String_ *shared.Empty

+ type ReadReq_Options_UUIDOption_Structured struct

+ Structured *shared.Empty

+ type ReadResp struct

+ Content isReadResp_Content

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

+ func (*ReadResp) ProtoMessage()

+ func (m *ReadResp) GetContent() isReadResp_Content

+ func (x *ReadResp) GetCheckpoint() *ReadResp_Checkpoint

+ func (x *ReadResp) GetConfirmation() *ReadResp_SubscriptionConfirmation

+ func (x *ReadResp) GetEvent() *ReadResp_ReadEvent

+ func (x *ReadResp) GetFirstStreamPosition() uint64

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

+ func (x *ReadResp) GetLastStreamPosition() uint64

+ func (x *ReadResp) GetStreamNotFound() *ReadResp_StreamNotFound

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

+ func (x *ReadResp) Reset()

+ func (x *ReadResp) String() string

+ type ReadResp_Checkpoint struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*ReadResp_Checkpoint) ProtoMessage()

+ func (x *ReadResp_Checkpoint) GetCommitPosition() uint64

+ func (x *ReadResp_Checkpoint) GetPreparePosition() uint64

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

+ func (x *ReadResp_Checkpoint) Reset()

+ func (x *ReadResp_Checkpoint) String() string

+ type ReadResp_Checkpoint_ struct

+ Checkpoint *ReadResp_Checkpoint

+ type ReadResp_Confirmation struct

+ Confirmation *ReadResp_SubscriptionConfirmation

+ type ReadResp_Event struct

+ Event *ReadResp_ReadEvent

+ type ReadResp_FirstStreamPosition struct

+ FirstStreamPosition uint64

+ type ReadResp_LastAllStreamPosition struct

+ LastAllStreamPosition *shared.AllStreamPosition

+ type ReadResp_LastStreamPosition struct

+ LastStreamPosition uint64

+ type ReadResp_ReadEvent struct

+ Event *ReadResp_ReadEvent_RecordedEvent

+ Link *ReadResp_ReadEvent_RecordedEvent

+ Position isReadResp_ReadEvent_Position

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

+ func (*ReadResp_ReadEvent) ProtoMessage()

+ func (m *ReadResp_ReadEvent) GetPosition() isReadResp_ReadEvent_Position

+ func (x *ReadResp_ReadEvent) GetCommitPosition() uint64

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

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

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

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

+ func (x *ReadResp_ReadEvent) Reset()

+ func (x *ReadResp_ReadEvent) String() string

+ type ReadResp_ReadEvent_CommitPosition struct

+ CommitPosition uint64

+ type ReadResp_ReadEvent_NoPosition struct

+ NoPosition *shared.Empty

+ type ReadResp_ReadEvent_RecordedEvent struct

+ CommitPosition uint64

+ CustomMetadata []byte

+ Data []byte

+ Id *shared.UUID

+ Metadata map[string]string

+ PreparePosition uint64

+ StreamIdentifier *shared.StreamIdentifier

+ StreamRevision uint64

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

+ func (*ReadResp_ReadEvent_RecordedEvent) ProtoMessage()

+ func (x *ReadResp_ReadEvent_RecordedEvent) GetCommitPosition() uint64

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

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

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

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

+ func (x *ReadResp_ReadEvent_RecordedEvent) GetPreparePosition() uint64

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

+ func (x *ReadResp_ReadEvent_RecordedEvent) GetStreamRevision() uint64

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

+ func (x *ReadResp_ReadEvent_RecordedEvent) Reset()

+ func (x *ReadResp_ReadEvent_RecordedEvent) String() string

+ type ReadResp_StreamNotFound struct

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*ReadResp_StreamNotFound) ProtoMessage()

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

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

+ func (x *ReadResp_StreamNotFound) Reset()

+ func (x *ReadResp_StreamNotFound) String() string

+ type ReadResp_StreamNotFound_ struct

+ StreamNotFound *ReadResp_StreamNotFound

+ type ReadResp_SubscriptionConfirmation struct

+ SubscriptionId string

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

+ func (*ReadResp_SubscriptionConfirmation) ProtoMessage()

+ func (x *ReadResp_SubscriptionConfirmation) GetSubscriptionId() string

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

+ func (x *ReadResp_SubscriptionConfirmation) Reset()

+ func (x *ReadResp_SubscriptionConfirmation) String() string

+ type StreamsClient interface

+ Append func(ctx context.Context, opts ...grpc.CallOption) (Streams_AppendClient, error)

+ BatchAppend func(ctx context.Context, opts ...grpc.CallOption) (Streams_BatchAppendClient, error)

+ Delete func(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteResp, error)

+ Read func(ctx context.Context, in *ReadReq, opts ...grpc.CallOption) (Streams_ReadClient, error)

+ Tombstone func(ctx context.Context, in *TombstoneReq, opts ...grpc.CallOption) (*TombstoneResp, error)

+ func NewStreamsClient(cc grpc.ClientConnInterface) StreamsClient

+ type StreamsServer interface

+ Append func(Streams_AppendServer) error

+ BatchAppend func(Streams_BatchAppendServer) error

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

+ Read func(*ReadReq, Streams_ReadServer) error

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

+ type Streams_AppendClient interface

+ CloseAndRecv func() (*AppendResp, error)

+ Send func(*AppendReq) error

+ type Streams_AppendServer interface

+ Recv func() (*AppendReq, error)

+ SendAndClose func(*AppendResp) error

+ type Streams_BatchAppendClient interface

+ Recv func() (*BatchAppendResp, error)

+ Send func(*BatchAppendReq) error

+ type Streams_BatchAppendServer interface

+ Recv func() (*BatchAppendReq, error)

+ Send func(*BatchAppendResp) error

+ type Streams_ReadClient interface

+ Recv func() (*ReadResp, error)

+ type Streams_ReadServer interface

+ Send func(*ReadResp) error

+ type TombstoneReq struct

+ Options *TombstoneReq_Options

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

+ func (*TombstoneReq) ProtoMessage()

+ func (x *TombstoneReq) GetOptions() *TombstoneReq_Options

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

+ func (x *TombstoneReq) Reset()

+ func (x *TombstoneReq) String() string

+ type TombstoneReq_Options struct

+ ExpectedStreamRevision isTombstoneReq_Options_ExpectedStreamRevision

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*TombstoneReq_Options) ProtoMessage()

+ func (m *TombstoneReq_Options) GetExpectedStreamRevision() isTombstoneReq_Options_ExpectedStreamRevision

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

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

+ func (x *TombstoneReq_Options) GetRevision() uint64

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

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

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

+ func (x *TombstoneReq_Options) Reset()

+ func (x *TombstoneReq_Options) String() string

+ type TombstoneReq_Options_Any struct

+ Any *shared.Empty

+ type TombstoneReq_Options_NoStream struct

+ NoStream *shared.Empty

+ type TombstoneReq_Options_Revision struct

+ Revision uint64

+ type TombstoneReq_Options_StreamExists struct

+ StreamExists *shared.Empty

+ type TombstoneResp struct

+ PositionOption isTombstoneResp_PositionOption

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

+ func (*TombstoneResp) ProtoMessage()

+ func (m *TombstoneResp) GetPositionOption() isTombstoneResp_PositionOption

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

+ func (x *TombstoneResp) GetPosition() *TombstoneResp_Position

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

+ func (x *TombstoneResp) Reset()

+ func (x *TombstoneResp) String() string

+ type TombstoneResp_NoPosition struct

+ NoPosition *shared.Empty

+ type TombstoneResp_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*TombstoneResp_Position) ProtoMessage()

+ func (x *TombstoneResp_Position) GetCommitPosition() uint64

+ func (x *TombstoneResp_Position) GetPreparePosition() uint64

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

+ func (x *TombstoneResp_Position) Reset()

+ func (x *TombstoneResp_Position) String() string

+ type TombstoneResp_Position_ struct

+ Position *TombstoneResp_Position

+ type UnimplementedStreamsServer struct

+ func (UnimplementedStreamsServer) Append(Streams_AppendServer) error

+ func (UnimplementedStreamsServer) BatchAppend(Streams_BatchAppendServer) error

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

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

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

+ type UnsafeStreamsServer interface

Other modules containing this package

github.com/EventStore/EventStore-Client-Go

github.com/EventStore/EventStore-Client-Go/v3

github.com/EventStore/EventStore-Client-Go/v4