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

persistent

package

Go to main page

Versions in this module

v4

v4.2.0

Oct 11, 2024

v4.1.0

Jun 5, 2024

Changes in this version

+ const PersistentSubscriptions_Create_FullMethodName

+ const PersistentSubscriptions_Delete_FullMethodName

+ const PersistentSubscriptions_GetInfo_FullMethodName

+ const PersistentSubscriptions_List_FullMethodName

+ const PersistentSubscriptions_Read_FullMethodName

+ const PersistentSubscriptions_ReplayParked_FullMethodName

+ const PersistentSubscriptions_RestartSubsystem_FullMethodName

+ const PersistentSubscriptions_Update_FullMethodName

v4.0.0

Mar 4, 2024

Changes in this version

+ var CreateReq_ConsumerStrategy_name = map[int32]string

+ var CreateReq_ConsumerStrategy_value = map[string]int32

+ var File_persistent_proto protoreflect.FileDescriptor

+ var PersistentSubscriptions_ServiceDesc = grpc.ServiceDesc

+ var ReadReq_Nack_Action_name = map[int32]string

+ var ReadReq_Nack_Action_value = map[string]int32

+ var UpdateReq_ConsumerStrategy_name = map[int32]string

+ var UpdateReq_ConsumerStrategy_value = map[string]int32

+ func RegisterPersistentSubscriptionsServer(s grpc.ServiceRegistrar, srv PersistentSubscriptionsServer)

+ type CreateReq struct

+ Options *CreateReq_Options

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

+ func (*CreateReq) ProtoMessage()

+ func (x *CreateReq) GetOptions() *CreateReq_Options

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

+ func (x *CreateReq) Reset()

+ func (x *CreateReq) String() string

+ type CreateReq_AllOptions struct

+ AllOption isCreateReq_AllOptions_AllOption

+ FilterOption isCreateReq_AllOptions_FilterOption

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

+ func (*CreateReq_AllOptions) ProtoMessage()

+ func (m *CreateReq_AllOptions) GetAllOption() isCreateReq_AllOptions_AllOption

+ func (m *CreateReq_AllOptions) GetFilterOption() isCreateReq_AllOptions_FilterOption

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

+ func (x *CreateReq_AllOptions) GetFilter() *CreateReq_AllOptions_FilterOptions

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

+ func (x *CreateReq_AllOptions) GetPosition() *CreateReq_Position

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

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

+ func (x *CreateReq_AllOptions) Reset()

+ func (x *CreateReq_AllOptions) String() string

+ type CreateReq_AllOptions_End struct

+ End *shared.Empty

+ type CreateReq_AllOptions_Filter struct

+ Filter *CreateReq_AllOptions_FilterOptions

+ type CreateReq_AllOptions_FilterOptions struct

+ CheckpointIntervalMultiplier uint32

+ Filter isCreateReq_AllOptions_FilterOptions_Filter

+ Window isCreateReq_AllOptions_FilterOptions_Window

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

+ func (*CreateReq_AllOptions_FilterOptions) ProtoMessage()

+ func (m *CreateReq_AllOptions_FilterOptions) GetFilter() isCreateReq_AllOptions_FilterOptions_Filter

+ func (m *CreateReq_AllOptions_FilterOptions) GetWindow() isCreateReq_AllOptions_FilterOptions_Window

+ func (x *CreateReq_AllOptions_FilterOptions) GetCheckpointIntervalMultiplier() uint32

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

+ func (x *CreateReq_AllOptions_FilterOptions) GetEventType() *CreateReq_AllOptions_FilterOptions_Expression

+ func (x *CreateReq_AllOptions_FilterOptions) GetMax() uint32

+ func (x *CreateReq_AllOptions_FilterOptions) GetStreamIdentifier() *CreateReq_AllOptions_FilterOptions_Expression

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

+ func (x *CreateReq_AllOptions_FilterOptions) Reset()

+ func (x *CreateReq_AllOptions_FilterOptions) String() string

+ type CreateReq_AllOptions_FilterOptions_Count struct

+ Count *shared.Empty

+ type CreateReq_AllOptions_FilterOptions_EventType struct

+ EventType *CreateReq_AllOptions_FilterOptions_Expression

+ type CreateReq_AllOptions_FilterOptions_Expression struct

+ Prefix []string

+ Regex string

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

+ func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoMessage()

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

+ func (x *CreateReq_AllOptions_FilterOptions_Expression) GetRegex() string

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

+ func (x *CreateReq_AllOptions_FilterOptions_Expression) Reset()

+ func (x *CreateReq_AllOptions_FilterOptions_Expression) String() string

+ type CreateReq_AllOptions_FilterOptions_Max struct

+ Max uint32

+ type CreateReq_AllOptions_FilterOptions_StreamIdentifier struct

+ StreamIdentifier *CreateReq_AllOptions_FilterOptions_Expression

+ type CreateReq_AllOptions_NoFilter struct

+ NoFilter *shared.Empty

+ type CreateReq_AllOptions_Position struct

+ Position *CreateReq_Position

+ type CreateReq_AllOptions_Start struct

+ Start *shared.Empty

+ type CreateReq_ConsumerStrategy int32

+ const CreateReq_DispatchToSingle

+ const CreateReq_Pinned

+ const CreateReq_RoundRobin

+ func (CreateReq_ConsumerStrategy) Descriptor() protoreflect.EnumDescriptor

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

+ func (CreateReq_ConsumerStrategy) Type() protoreflect.EnumType

+ func (x CreateReq_ConsumerStrategy) Enum() *CreateReq_ConsumerStrategy

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

+ func (x CreateReq_ConsumerStrategy) String() string

+ type CreateReq_Options struct

+ GroupName string

+ Settings *CreateReq_Settings

+ StreamIdentifier *shared.StreamIdentifier

+ StreamOption isCreateReq_Options_StreamOption

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

+ func (*CreateReq_Options) ProtoMessage()

+ func (m *CreateReq_Options) GetStreamOption() isCreateReq_Options_StreamOption

+ func (x *CreateReq_Options) GetAll() *CreateReq_AllOptions

+ func (x *CreateReq_Options) GetGroupName() string

+ func (x *CreateReq_Options) GetSettings() *CreateReq_Settings

+ func (x *CreateReq_Options) GetStream() *CreateReq_StreamOptions

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

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

+ func (x *CreateReq_Options) Reset()

+ func (x *CreateReq_Options) String() string

+ type CreateReq_Options_All struct

+ All *CreateReq_AllOptions

+ type CreateReq_Options_Stream struct

+ Stream *CreateReq_StreamOptions

+ type CreateReq_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*CreateReq_Position) ProtoMessage()

+ func (x *CreateReq_Position) GetCommitPosition() uint64

+ func (x *CreateReq_Position) GetPreparePosition() uint64

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

+ func (x *CreateReq_Position) Reset()

+ func (x *CreateReq_Position) String() string

+ type CreateReq_Settings struct

+ CheckpointAfter isCreateReq_Settings_CheckpointAfter

+ ConsumerStrategy string

+ ExtraStatistics bool

+ HistoryBufferSize int32

+ LiveBufferSize int32

+ MaxCheckpointCount int32

+ MaxRetryCount int32

+ MaxSubscriberCount int32

+ MessageTimeout isCreateReq_Settings_MessageTimeout

+ MinCheckpointCount int32

+ NamedConsumerStrategy CreateReq_ConsumerStrategy

+ ReadBatchSize int32

+ ResolveLinks bool

+ Revision uint64

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

+ func (*CreateReq_Settings) ProtoMessage()

+ func (m *CreateReq_Settings) GetCheckpointAfter() isCreateReq_Settings_CheckpointAfter

+ func (m *CreateReq_Settings) GetMessageTimeout() isCreateReq_Settings_MessageTimeout

+ func (x *CreateReq_Settings) GetCheckpointAfterMs() int32

+ func (x *CreateReq_Settings) GetCheckpointAfterTicks() int64

+ func (x *CreateReq_Settings) GetConsumerStrategy() string

+ func (x *CreateReq_Settings) GetExtraStatistics() bool

+ func (x *CreateReq_Settings) GetHistoryBufferSize() int32

+ func (x *CreateReq_Settings) GetLiveBufferSize() int32

+ func (x *CreateReq_Settings) GetMaxCheckpointCount() int32

+ func (x *CreateReq_Settings) GetMaxRetryCount() int32

+ func (x *CreateReq_Settings) GetMaxSubscriberCount() int32

+ func (x *CreateReq_Settings) GetMessageTimeoutMs() int32

+ func (x *CreateReq_Settings) GetMessageTimeoutTicks() int64

+ func (x *CreateReq_Settings) GetMinCheckpointCount() int32

+ func (x *CreateReq_Settings) GetNamedConsumerStrategy() CreateReq_ConsumerStrategy

+ func (x *CreateReq_Settings) GetReadBatchSize() int32

+ func (x *CreateReq_Settings) GetResolveLinks() bool

+ func (x *CreateReq_Settings) GetRevision() uint64

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

+ func (x *CreateReq_Settings) Reset()

+ func (x *CreateReq_Settings) String() string

+ type CreateReq_Settings_CheckpointAfterMs struct

+ CheckpointAfterMs int32

+ type CreateReq_Settings_CheckpointAfterTicks struct

+ CheckpointAfterTicks int64

+ type CreateReq_Settings_MessageTimeoutMs struct

+ MessageTimeoutMs int32

+ type CreateReq_Settings_MessageTimeoutTicks struct

+ MessageTimeoutTicks int64

+ type CreateReq_StreamOptions struct

+ RevisionOption isCreateReq_StreamOptions_RevisionOption

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*CreateReq_StreamOptions) ProtoMessage()

+ func (m *CreateReq_StreamOptions) GetRevisionOption() isCreateReq_StreamOptions_RevisionOption

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

+ func (x *CreateReq_StreamOptions) GetRevision() uint64

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

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

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

+ func (x *CreateReq_StreamOptions) Reset()

+ func (x *CreateReq_StreamOptions) String() string

+ type CreateReq_StreamOptions_End struct

+ End *shared.Empty

+ type CreateReq_StreamOptions_Revision struct

+ Revision uint64

+ type CreateReq_StreamOptions_Start struct

+ Start *shared.Empty

+ type CreateResp struct

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

+ func (*CreateResp) ProtoMessage()

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

+ func (x *CreateResp) Reset()

+ func (x *CreateResp) String() string

+ 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

+ GroupName string

+ StreamOption isDeleteReq_Options_StreamOption

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

+ func (*DeleteReq_Options) ProtoMessage()

+ func (m *DeleteReq_Options) GetStreamOption() isDeleteReq_Options_StreamOption

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

+ func (x *DeleteReq_Options) GetGroupName() string

+ 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_All struct

+ All *shared.Empty

+ type DeleteReq_Options_StreamIdentifier struct

+ StreamIdentifier *shared.StreamIdentifier

+ type DeleteResp struct

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

+ func (*DeleteResp) ProtoMessage()

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

+ func (x *DeleteResp) Reset()

+ func (x *DeleteResp) String() string

+ type GetInfoReq struct

+ Options *GetInfoReq_Options

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

+ func (*GetInfoReq) ProtoMessage()

+ func (x *GetInfoReq) GetOptions() *GetInfoReq_Options

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

+ func (x *GetInfoReq) Reset()

+ func (x *GetInfoReq) String() string

+ type GetInfoReq_Options struct

+ GroupName string

+ StreamOption isGetInfoReq_Options_StreamOption

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

+ func (*GetInfoReq_Options) ProtoMessage()

+ func (m *GetInfoReq_Options) GetStreamOption() isGetInfoReq_Options_StreamOption

+ func (x *GetInfoReq_Options) GetAll() *shared.Empty

+ func (x *GetInfoReq_Options) GetGroupName() string

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

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

+ func (x *GetInfoReq_Options) Reset()

+ func (x *GetInfoReq_Options) String() string

+ type GetInfoReq_Options_All struct

+ All *shared.Empty

+ type GetInfoReq_Options_StreamIdentifier struct

+ StreamIdentifier *shared.StreamIdentifier

+ type GetInfoResp struct

+ SubscriptionInfo *SubscriptionInfo

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

+ func (*GetInfoResp) ProtoMessage()

+ func (x *GetInfoResp) GetSubscriptionInfo() *SubscriptionInfo

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

+ func (x *GetInfoResp) Reset()

+ func (x *GetInfoResp) String() string

+ type ListReq struct

+ Options *ListReq_Options

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

+ func (*ListReq) ProtoMessage()

+ func (x *ListReq) GetOptions() *ListReq_Options

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

+ func (x *ListReq) Reset()

+ func (x *ListReq) String() string

+ type ListReq_Options struct

+ ListOption isListReq_Options_ListOption

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

+ func (*ListReq_Options) ProtoMessage()

+ func (m *ListReq_Options) GetListOption() isListReq_Options_ListOption

+ func (x *ListReq_Options) GetListAllSubscriptions() *shared.Empty

+ func (x *ListReq_Options) GetListForStream() *ListReq_StreamOption

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

+ func (x *ListReq_Options) Reset()

+ func (x *ListReq_Options) String() string

+ type ListReq_Options_ListAllSubscriptions struct

+ ListAllSubscriptions *shared.Empty

+ type ListReq_Options_ListForStream struct

+ ListForStream *ListReq_StreamOption

+ type ListReq_StreamOption struct

+ StreamOption isListReq_StreamOption_StreamOption

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

+ func (*ListReq_StreamOption) ProtoMessage()

+ func (m *ListReq_StreamOption) GetStreamOption() isListReq_StreamOption_StreamOption

+ func (x *ListReq_StreamOption) GetAll() *shared.Empty

+ func (x *ListReq_StreamOption) GetStream() *shared.StreamIdentifier

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

+ func (x *ListReq_StreamOption) Reset()

+ func (x *ListReq_StreamOption) String() string

+ type ListReq_StreamOption_All struct

+ All *shared.Empty

+ type ListReq_StreamOption_Stream struct

+ Stream *shared.StreamIdentifier

+ type ListResp struct

+ Subscriptions []*SubscriptionInfo

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

+ func (*ListResp) ProtoMessage()

+ func (x *ListResp) GetSubscriptions() []*SubscriptionInfo

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

+ func (x *ListResp) Reset()

+ func (x *ListResp) String() string

+ type PersistentSubscriptionsClient interface

+ Create func(ctx context.Context, in *CreateReq, opts ...grpc.CallOption) (*CreateResp, error)

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

+ GetInfo func(ctx context.Context, in *GetInfoReq, opts ...grpc.CallOption) (*GetInfoResp, error)

+ List func(ctx context.Context, in *ListReq, opts ...grpc.CallOption) (*ListResp, error)

+ Read func(ctx context.Context, opts ...grpc.CallOption) (PersistentSubscriptions_ReadClient, error)

+ ReplayParked func(ctx context.Context, in *ReplayParkedReq, opts ...grpc.CallOption) (*ReplayParkedResp, error)

+ RestartSubsystem func(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)

+ Update func(ctx context.Context, in *UpdateReq, opts ...grpc.CallOption) (*UpdateResp, error)

+ func NewPersistentSubscriptionsClient(cc grpc.ClientConnInterface) PersistentSubscriptionsClient

+ type PersistentSubscriptionsServer interface

+ Create func(context.Context, *CreateReq) (*CreateResp, error)

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

+ GetInfo func(context.Context, *GetInfoReq) (*GetInfoResp, error)

+ List func(context.Context, *ListReq) (*ListResp, error)

+ Read func(PersistentSubscriptions_ReadServer) error

+ ReplayParked func(context.Context, *ReplayParkedReq) (*ReplayParkedResp, error)

+ RestartSubsystem func(context.Context, *shared.Empty) (*shared.Empty, error)

+ Update func(context.Context, *UpdateReq) (*UpdateResp, error)

+ type PersistentSubscriptions_ReadClient interface

+ Recv func() (*ReadResp, error)

+ Send func(*ReadReq) error

+ type PersistentSubscriptions_ReadServer interface

+ Recv func() (*ReadReq, error)

+ Send func(*ReadResp) error

+ type ReadReq struct

+ Content isReadReq_Content

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

+ func (*ReadReq) ProtoMessage()

+ func (m *ReadReq) GetContent() isReadReq_Content

+ func (x *ReadReq) GetAck() *ReadReq_Ack

+ func (x *ReadReq) GetNack() *ReadReq_Nack

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

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

+ func (x *ReadReq) Reset()

+ func (x *ReadReq) String() string

+ type ReadReq_Ack struct

+ Id []byte

+ Ids []*shared.UUID

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

+ func (*ReadReq_Ack) ProtoMessage()

+ func (x *ReadReq_Ack) GetId() []byte

+ func (x *ReadReq_Ack) GetIds() []*shared.UUID

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

+ func (x *ReadReq_Ack) Reset()

+ func (x *ReadReq_Ack) String() string

+ type ReadReq_Ack_ struct

+ Ack *ReadReq_Ack

+ type ReadReq_Nack struct

+ Action ReadReq_Nack_Action

+ Id []byte

+ Ids []*shared.UUID

+ Reason string

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

+ func (*ReadReq_Nack) ProtoMessage()

+ func (x *ReadReq_Nack) GetAction() ReadReq_Nack_Action

+ func (x *ReadReq_Nack) GetId() []byte

+ func (x *ReadReq_Nack) GetIds() []*shared.UUID

+ func (x *ReadReq_Nack) GetReason() string

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

+ func (x *ReadReq_Nack) Reset()

+ func (x *ReadReq_Nack) String() string

+ type ReadReq_Nack_ struct

+ Nack *ReadReq_Nack

+ type ReadReq_Nack_Action int32

+ const ReadReq_Nack_Park

+ const ReadReq_Nack_Retry

+ const ReadReq_Nack_Skip

+ const ReadReq_Nack_Stop

+ const ReadReq_Nack_Unknown

+ func (ReadReq_Nack_Action) Descriptor() protoreflect.EnumDescriptor

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

+ func (ReadReq_Nack_Action) Type() protoreflect.EnumType

+ func (x ReadReq_Nack_Action) Enum() *ReadReq_Nack_Action

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

+ func (x ReadReq_Nack_Action) String() string

+ type ReadReq_Options struct

+ BufferSize int32

+ GroupName string

+ StreamOption isReadReq_Options_StreamOption

+ UuidOption *ReadReq_Options_UUIDOption

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

+ func (*ReadReq_Options) ProtoMessage()

+ func (m *ReadReq_Options) GetStreamOption() isReadReq_Options_StreamOption

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

+ func (x *ReadReq_Options) GetBufferSize() int32

+ func (x *ReadReq_Options) GetGroupName() string

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

+ 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_ struct

+ Options *ReadReq_Options

+ type ReadReq_Options_All struct

+ All *shared.Empty

+ type ReadReq_Options_StreamIdentifier struct

+ StreamIdentifier *shared.StreamIdentifier

+ 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) GetEvent() *ReadResp_ReadEvent

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

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

+ func (x *ReadResp) Reset()

+ func (x *ReadResp) String() string

+ type ReadResp_Event struct

+ Event *ReadResp_ReadEvent

+ type ReadResp_ReadEvent struct

+ Count isReadResp_ReadEvent_Count

+ 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) GetCount() isReadResp_ReadEvent_Count

+ 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) GetNoRetryCount() *shared.Empty

+ func (x *ReadResp_ReadEvent) GetRetryCount() int32

+ 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_NoRetryCount struct

+ NoRetryCount *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_ReadEvent_RetryCount struct

+ RetryCount int32

+ 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 ReadResp_SubscriptionConfirmation_ struct

+ SubscriptionConfirmation *ReadResp_SubscriptionConfirmation

+ type ReplayParkedReq struct

+ Options *ReplayParkedReq_Options

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

+ func (*ReplayParkedReq) ProtoMessage()

+ func (x *ReplayParkedReq) GetOptions() *ReplayParkedReq_Options

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

+ func (x *ReplayParkedReq) Reset()

+ func (x *ReplayParkedReq) String() string

+ type ReplayParkedReq_Options struct

+ GroupName string

+ StopAtOption isReplayParkedReq_Options_StopAtOption

+ StreamOption isReplayParkedReq_Options_StreamOption

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

+ func (*ReplayParkedReq_Options) ProtoMessage()

+ func (m *ReplayParkedReq_Options) GetStopAtOption() isReplayParkedReq_Options_StopAtOption

+ func (m *ReplayParkedReq_Options) GetStreamOption() isReplayParkedReq_Options_StreamOption

+ func (x *ReplayParkedReq_Options) GetAll() *shared.Empty

+ func (x *ReplayParkedReq_Options) GetGroupName() string

+ func (x *ReplayParkedReq_Options) GetNoLimit() *shared.Empty

+ func (x *ReplayParkedReq_Options) GetStopAt() int64

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

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

+ func (x *ReplayParkedReq_Options) Reset()

+ func (x *ReplayParkedReq_Options) String() string

+ type ReplayParkedReq_Options_All struct

+ All *shared.Empty

+ type ReplayParkedReq_Options_NoLimit struct

+ NoLimit *shared.Empty

+ type ReplayParkedReq_Options_StopAt struct

+ StopAt int64

+ type ReplayParkedReq_Options_StreamIdentifier struct

+ StreamIdentifier *shared.StreamIdentifier

+ type ReplayParkedResp struct

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

+ func (*ReplayParkedResp) ProtoMessage()

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

+ func (x *ReplayParkedResp) Reset()

+ func (x *ReplayParkedResp) String() string

+ type SubscriptionInfo struct

+ AveragePerSecond int32

+ BufferSize int32

+ CheckPointAfterMilliseconds int32

+ Connections []*SubscriptionInfo_ConnectionInfo

+ CountSinceLastMeasurement int64

+ EventSource string

+ ExtraStatistics bool

+ GroupName string

+ LastCheckpointedEventPosition string

+ LastKnownEventPosition string

+ LiveBufferCount int64

+ LiveBufferSize int32

+ MaxCheckPointCount int32

+ MaxRetryCount int32

+ MaxSubscriberCount int32

+ MessageTimeoutMilliseconds int32

+ MinCheckPointCount int32

+ NamedConsumerStrategy string

+ OutstandingMessagesCount int32

+ ParkedMessageCount int64

+ ReadBatchSize int32

+ ReadBufferCount int32

+ ResolveLinkTos bool

+ RetryBufferCount int32

+ StartFrom string

+ Status string

+ TotalInFlightMessages int32

+ TotalItems int64

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

+ func (*SubscriptionInfo) ProtoMessage()

+ func (x *SubscriptionInfo) GetAveragePerSecond() int32

+ func (x *SubscriptionInfo) GetBufferSize() int32

+ func (x *SubscriptionInfo) GetCheckPointAfterMilliseconds() int32

+ func (x *SubscriptionInfo) GetConnections() []*SubscriptionInfo_ConnectionInfo

+ func (x *SubscriptionInfo) GetCountSinceLastMeasurement() int64

+ func (x *SubscriptionInfo) GetEventSource() string

+ func (x *SubscriptionInfo) GetExtraStatistics() bool

+ func (x *SubscriptionInfo) GetGroupName() string

+ func (x *SubscriptionInfo) GetLastCheckpointedEventPosition() string

+ func (x *SubscriptionInfo) GetLastKnownEventPosition() string

+ func (x *SubscriptionInfo) GetLiveBufferCount() int64

+ func (x *SubscriptionInfo) GetLiveBufferSize() int32

+ func (x *SubscriptionInfo) GetMaxCheckPointCount() int32

+ func (x *SubscriptionInfo) GetMaxRetryCount() int32

+ func (x *SubscriptionInfo) GetMaxSubscriberCount() int32

+ func (x *SubscriptionInfo) GetMessageTimeoutMilliseconds() int32

+ func (x *SubscriptionInfo) GetMinCheckPointCount() int32

+ func (x *SubscriptionInfo) GetNamedConsumerStrategy() string

+ func (x *SubscriptionInfo) GetOutstandingMessagesCount() int32

+ func (x *SubscriptionInfo) GetParkedMessageCount() int64

+ func (x *SubscriptionInfo) GetReadBatchSize() int32

+ func (x *SubscriptionInfo) GetReadBufferCount() int32

+ func (x *SubscriptionInfo) GetResolveLinkTos() bool

+ func (x *SubscriptionInfo) GetRetryBufferCount() int32

+ func (x *SubscriptionInfo) GetStartFrom() string

+ func (x *SubscriptionInfo) GetStatus() string

+ func (x *SubscriptionInfo) GetTotalInFlightMessages() int32

+ func (x *SubscriptionInfo) GetTotalItems() int64

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

+ func (x *SubscriptionInfo) Reset()

+ func (x *SubscriptionInfo) String() string

+ type SubscriptionInfo_ConnectionInfo struct

+ AvailableSlots int32

+ AverageItemsPerSecond int32

+ ConnectionName string

+ CountSinceLastMeasurement int64

+ From string

+ InFlightMessages int32

+ ObservedMeasurements []*SubscriptionInfo_Measurement

+ TotalItems int64

+ Username string

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

+ func (*SubscriptionInfo_ConnectionInfo) ProtoMessage()

+ func (x *SubscriptionInfo_ConnectionInfo) GetAvailableSlots() int32

+ func (x *SubscriptionInfo_ConnectionInfo) GetAverageItemsPerSecond() int32

+ func (x *SubscriptionInfo_ConnectionInfo) GetConnectionName() string

+ func (x *SubscriptionInfo_ConnectionInfo) GetCountSinceLastMeasurement() int64

+ func (x *SubscriptionInfo_ConnectionInfo) GetFrom() string

+ func (x *SubscriptionInfo_ConnectionInfo) GetInFlightMessages() int32

+ func (x *SubscriptionInfo_ConnectionInfo) GetObservedMeasurements() []*SubscriptionInfo_Measurement

+ func (x *SubscriptionInfo_ConnectionInfo) GetTotalItems() int64

+ func (x *SubscriptionInfo_ConnectionInfo) GetUsername() string

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

+ func (x *SubscriptionInfo_ConnectionInfo) Reset()

+ func (x *SubscriptionInfo_ConnectionInfo) String() string

+ type SubscriptionInfo_Measurement struct

+ Key string

+ Value int64

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

+ func (*SubscriptionInfo_Measurement) ProtoMessage()

+ func (x *SubscriptionInfo_Measurement) GetKey() string

+ func (x *SubscriptionInfo_Measurement) GetValue() int64

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

+ func (x *SubscriptionInfo_Measurement) Reset()

+ func (x *SubscriptionInfo_Measurement) String() string

+ type UnimplementedPersistentSubscriptionsServer struct

+ func (UnimplementedPersistentSubscriptionsServer) Create(context.Context, *CreateReq) (*CreateResp, error)

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

+ func (UnimplementedPersistentSubscriptionsServer) GetInfo(context.Context, *GetInfoReq) (*GetInfoResp, error)

+ func (UnimplementedPersistentSubscriptionsServer) List(context.Context, *ListReq) (*ListResp, error)

+ func (UnimplementedPersistentSubscriptionsServer) Read(PersistentSubscriptions_ReadServer) error

+ func (UnimplementedPersistentSubscriptionsServer) ReplayParked(context.Context, *ReplayParkedReq) (*ReplayParkedResp, error)

+ func (UnimplementedPersistentSubscriptionsServer) RestartSubsystem(context.Context, *shared.Empty) (*shared.Empty, error)

+ func (UnimplementedPersistentSubscriptionsServer) Update(context.Context, *UpdateReq) (*UpdateResp, error)

+ type UnsafePersistentSubscriptionsServer interface

+ type UpdateReq struct

+ Options *UpdateReq_Options

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

+ func (*UpdateReq) ProtoMessage()

+ func (x *UpdateReq) GetOptions() *UpdateReq_Options

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

+ func (x *UpdateReq) Reset()

+ func (x *UpdateReq) String() string

+ type UpdateReq_AllOptions struct

+ AllOption isUpdateReq_AllOptions_AllOption

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

+ func (*UpdateReq_AllOptions) ProtoMessage()

+ func (m *UpdateReq_AllOptions) GetAllOption() isUpdateReq_AllOptions_AllOption

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

+ func (x *UpdateReq_AllOptions) GetPosition() *UpdateReq_Position

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

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

+ func (x *UpdateReq_AllOptions) Reset()

+ func (x *UpdateReq_AllOptions) String() string

+ type UpdateReq_AllOptions_End struct

+ End *shared.Empty

+ type UpdateReq_AllOptions_Position struct

+ Position *UpdateReq_Position

+ type UpdateReq_AllOptions_Start struct

+ Start *shared.Empty

+ type UpdateReq_ConsumerStrategy int32

+ const UpdateReq_DispatchToSingle

+ const UpdateReq_Pinned

+ const UpdateReq_RoundRobin

+ func (UpdateReq_ConsumerStrategy) Descriptor() protoreflect.EnumDescriptor

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

+ func (UpdateReq_ConsumerStrategy) Type() protoreflect.EnumType

+ func (x UpdateReq_ConsumerStrategy) Enum() *UpdateReq_ConsumerStrategy

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

+ func (x UpdateReq_ConsumerStrategy) String() string

+ type UpdateReq_Options struct

+ GroupName string

+ Settings *UpdateReq_Settings

+ StreamIdentifier *shared.StreamIdentifier

+ StreamOption isUpdateReq_Options_StreamOption

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

+ func (*UpdateReq_Options) ProtoMessage()

+ func (m *UpdateReq_Options) GetStreamOption() isUpdateReq_Options_StreamOption

+ func (x *UpdateReq_Options) GetAll() *UpdateReq_AllOptions

+ func (x *UpdateReq_Options) GetGroupName() string

+ func (x *UpdateReq_Options) GetSettings() *UpdateReq_Settings

+ func (x *UpdateReq_Options) GetStream() *UpdateReq_StreamOptions

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

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

+ func (x *UpdateReq_Options) Reset()

+ func (x *UpdateReq_Options) String() string

+ type UpdateReq_Options_All struct

+ All *UpdateReq_AllOptions

+ type UpdateReq_Options_Stream struct

+ Stream *UpdateReq_StreamOptions

+ type UpdateReq_Position struct

+ CommitPosition uint64

+ PreparePosition uint64

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

+ func (*UpdateReq_Position) ProtoMessage()

+ func (x *UpdateReq_Position) GetCommitPosition() uint64

+ func (x *UpdateReq_Position) GetPreparePosition() uint64

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

+ func (x *UpdateReq_Position) Reset()

+ func (x *UpdateReq_Position) String() string

+ type UpdateReq_Settings struct

+ CheckpointAfter isUpdateReq_Settings_CheckpointAfter

+ ExtraStatistics bool

+ HistoryBufferSize int32

+ LiveBufferSize int32

+ MaxCheckpointCount int32

+ MaxRetryCount int32

+ MaxSubscriberCount int32

+ MessageTimeout isUpdateReq_Settings_MessageTimeout

+ MinCheckpointCount int32

+ NamedConsumerStrategy UpdateReq_ConsumerStrategy

+ ReadBatchSize int32

+ ResolveLinks bool

+ Revision uint64

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

+ func (*UpdateReq_Settings) ProtoMessage()

+ func (m *UpdateReq_Settings) GetCheckpointAfter() isUpdateReq_Settings_CheckpointAfter

+ func (m *UpdateReq_Settings) GetMessageTimeout() isUpdateReq_Settings_MessageTimeout

+ func (x *UpdateReq_Settings) GetCheckpointAfterMs() int32

+ func (x *UpdateReq_Settings) GetCheckpointAfterTicks() int64

+ func (x *UpdateReq_Settings) GetExtraStatistics() bool

+ func (x *UpdateReq_Settings) GetHistoryBufferSize() int32

+ func (x *UpdateReq_Settings) GetLiveBufferSize() int32

+ func (x *UpdateReq_Settings) GetMaxCheckpointCount() int32

+ func (x *UpdateReq_Settings) GetMaxRetryCount() int32

+ func (x *UpdateReq_Settings) GetMaxSubscriberCount() int32

+ func (x *UpdateReq_Settings) GetMessageTimeoutMs() int32

+ func (x *UpdateReq_Settings) GetMessageTimeoutTicks() int64

+ func (x *UpdateReq_Settings) GetMinCheckpointCount() int32

+ func (x *UpdateReq_Settings) GetNamedConsumerStrategy() UpdateReq_ConsumerStrategy

+ func (x *UpdateReq_Settings) GetReadBatchSize() int32

+ func (x *UpdateReq_Settings) GetResolveLinks() bool

+ func (x *UpdateReq_Settings) GetRevision() uint64

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

+ func (x *UpdateReq_Settings) Reset()

+ func (x *UpdateReq_Settings) String() string

+ type UpdateReq_Settings_CheckpointAfterMs struct

+ CheckpointAfterMs int32

+ type UpdateReq_Settings_CheckpointAfterTicks struct

+ CheckpointAfterTicks int64

+ type UpdateReq_Settings_MessageTimeoutMs struct

+ MessageTimeoutMs int32

+ type UpdateReq_Settings_MessageTimeoutTicks struct

+ MessageTimeoutTicks int64

+ type UpdateReq_StreamOptions struct

+ RevisionOption isUpdateReq_StreamOptions_RevisionOption

+ StreamIdentifier *shared.StreamIdentifier

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

+ func (*UpdateReq_StreamOptions) ProtoMessage()

+ func (m *UpdateReq_StreamOptions) GetRevisionOption() isUpdateReq_StreamOptions_RevisionOption

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

+ func (x *UpdateReq_StreamOptions) GetRevision() uint64

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

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

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

+ func (x *UpdateReq_StreamOptions) Reset()

+ func (x *UpdateReq_StreamOptions) String() string

+ type UpdateReq_StreamOptions_End struct

+ End *shared.Empty

+ type UpdateReq_StreamOptions_Revision struct

+ Revision uint64

+ type UpdateReq_StreamOptions_Start struct

+ Start *shared.Empty

+ type UpdateResp struct

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

+ func (*UpdateResp) ProtoMessage()

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

+ func (x *UpdateResp) Reset()

+ func (x *UpdateResp) String() string

Other modules containing this package

github.com/EventStore/EventStore-Client-Go

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

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