persistent

package
v4.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PersistentSubscriptions_Create_FullMethodName           = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/Create"
	PersistentSubscriptions_Update_FullMethodName           = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/Update"
	PersistentSubscriptions_Delete_FullMethodName           = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/Delete"
	PersistentSubscriptions_Read_FullMethodName             = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/Read"
	PersistentSubscriptions_GetInfo_FullMethodName          = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/GetInfo"
	PersistentSubscriptions_ReplayParked_FullMethodName     = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/ReplayParked"
	PersistentSubscriptions_List_FullMethodName             = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/List"
	PersistentSubscriptions_RestartSubsystem_FullMethodName = "/event_store.client.persistent_subscriptions.PersistentSubscriptions/RestartSubsystem"
)

Variables

View Source 
var (
	ReadReq_Nack_Action_name = map[int32]string{
		0: "Unknown",
		1: "Park",
		2: "Retry",
		3: "Skip",
		4: "Stop",
	}
	ReadReq_Nack_Action_value = map[string]int32{
		"Unknown": 0,
		"Park":    1,
		"Retry":   2,
		"Skip":    3,
		"Stop":    4,
	}
)

Enum value maps for ReadReq_Nack_Action.

View Source 
var (
	CreateReq_ConsumerStrategy_name = map[int32]string{
		0: "DispatchToSingle",
		1: "RoundRobin",
		2: "Pinned",
	}
	CreateReq_ConsumerStrategy_value = map[string]int32{
		"DispatchToSingle": 0,
		"RoundRobin":       1,
		"Pinned":           2,
	}
)

Enum value maps for CreateReq_ConsumerStrategy.

View Source 
var (
	UpdateReq_ConsumerStrategy_name = map[int32]string{
		0: "DispatchToSingle",
		1: "RoundRobin",
		2: "Pinned",
	}
	UpdateReq_ConsumerStrategy_value = map[string]int32{
		"DispatchToSingle": 0,
		"RoundRobin":       1,
		"Pinned":           2,
	}
)

Enum value maps for UpdateReq_ConsumerStrategy.

View Source 
var File_persistent_proto protoreflect.FileDescriptor
View Source 
var PersistentSubscriptions_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "event_store.client.persistent_subscriptions.PersistentSubscriptions",
	HandlerType: (*PersistentSubscriptionsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _PersistentSubscriptions_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _PersistentSubscriptions_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _PersistentSubscriptions_Delete_Handler,
		},
		{
			MethodName: "GetInfo",
			Handler:    _PersistentSubscriptions_GetInfo_Handler,
		},
		{
			MethodName: "ReplayParked",
			Handler:    _PersistentSubscriptions_ReplayParked_Handler,
		},
		{
			MethodName: "List",
			Handler:    _PersistentSubscriptions_List_Handler,
		},
		{
			MethodName: "RestartSubsystem",
			Handler:    _PersistentSubscriptions_RestartSubsystem_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Read",
			Handler:       _PersistentSubscriptions_Read_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "persistent.proto",
}

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

Functions

func RegisterPersistentSubscriptionsServer 

func RegisterPersistentSubscriptionsServer(s grpc.ServiceRegistrar, srv PersistentSubscriptionsServer)

Types

type CreateReq 

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

func (*CreateReq) Descriptor deprecated 

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

Deprecated: Use CreateReq.ProtoReflect.Descriptor instead.

func (*CreateReq) GetOptions 

func (x *CreateReq) GetOptions() *CreateReq_Options

func (*CreateReq) ProtoMessage 

func (*CreateReq) ProtoMessage()

func (*CreateReq) ProtoReflect 

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

func (*CreateReq) Reset 

func (x *CreateReq) Reset()

func (*CreateReq) String 

func (x *CreateReq) String() string

type CreateReq_AllOptions 

type CreateReq_AllOptions struct {

	// Types that are assignable to AllOption:
	//
	//	*CreateReq_AllOptions_Position
	//	*CreateReq_AllOptions_Start
	//	*CreateReq_AllOptions_End
	AllOption isCreateReq_AllOptions_AllOption `protobuf_oneof:"all_option"`
	// Types that are assignable to FilterOption:
	//
	//	*CreateReq_AllOptions_Filter
	//	*CreateReq_AllOptions_NoFilter
	FilterOption isCreateReq_AllOptions_FilterOption `protobuf_oneof:"filter_option"`
	// contains filtered or unexported fields
}

func (*CreateReq_AllOptions) Descriptor deprecated 

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

Deprecated: Use CreateReq_AllOptions.ProtoReflect.Descriptor instead.

func (*CreateReq_AllOptions) GetAllOption 

func (m *CreateReq_AllOptions) GetAllOption() isCreateReq_AllOptions_AllOption

func (*CreateReq_AllOptions) GetEnd 

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

func (*CreateReq_AllOptions) GetFilter 

func (x *CreateReq_AllOptions) GetFilter() *CreateReq_AllOptions_FilterOptions

func (*CreateReq_AllOptions) GetFilterOption 

func (m *CreateReq_AllOptions) GetFilterOption() isCreateReq_AllOptions_FilterOption

func (*CreateReq_AllOptions) GetNoFilter 

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

func (*CreateReq_AllOptions) GetPosition 

func (x *CreateReq_AllOptions) GetPosition() *CreateReq_Position

func (*CreateReq_AllOptions) GetStart 

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

func (*CreateReq_AllOptions) ProtoMessage 

func (*CreateReq_AllOptions) ProtoMessage()

func (*CreateReq_AllOptions) ProtoReflect 

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

func (*CreateReq_AllOptions) Reset 

func (x *CreateReq_AllOptions) Reset()

func (*CreateReq_AllOptions) String 

func (x *CreateReq_AllOptions) String() string

type CreateReq_AllOptions_End 

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

type CreateReq_AllOptions_Filter 

type CreateReq_AllOptions_Filter struct {
	Filter *CreateReq_AllOptions_FilterOptions `protobuf:"bytes,4,opt,name=filter,proto3,oneof"`
}

type CreateReq_AllOptions_FilterOptions 

type CreateReq_AllOptions_FilterOptions struct {

	// Types that are assignable to Filter:
	//
	//	*CreateReq_AllOptions_FilterOptions_StreamIdentifier
	//	*CreateReq_AllOptions_FilterOptions_EventType
	Filter isCreateReq_AllOptions_FilterOptions_Filter `protobuf_oneof:"filter"`
	// Types that are assignable to Window:
	//
	//	*CreateReq_AllOptions_FilterOptions_Max
	//	*CreateReq_AllOptions_FilterOptions_Count
	Window                       isCreateReq_AllOptions_FilterOptions_Window `protobuf_oneof:"window"`
	CheckpointIntervalMultiplier uint32                                      `protobuf:"varint,5,opt,name=checkpointIntervalMultiplier,proto3" json:"checkpointIntervalMultiplier,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_AllOptions_FilterOptions) Descriptor deprecated 

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

Deprecated: Use CreateReq_AllOptions_FilterOptions.ProtoReflect.Descriptor instead.

func (*CreateReq_AllOptions_FilterOptions) GetCheckpointIntervalMultiplier 

func (x *CreateReq_AllOptions_FilterOptions) GetCheckpointIntervalMultiplier() uint32

func (*CreateReq_AllOptions_FilterOptions) GetCount 

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

func (*CreateReq_AllOptions_FilterOptions) GetEventType 

func (x *CreateReq_AllOptions_FilterOptions) GetEventType() *CreateReq_AllOptions_FilterOptions_Expression

func (*CreateReq_AllOptions_FilterOptions) GetFilter 

func (m *CreateReq_AllOptions_FilterOptions) GetFilter() isCreateReq_AllOptions_FilterOptions_Filter

func (*CreateReq_AllOptions_FilterOptions) GetMax 

func (x *CreateReq_AllOptions_FilterOptions) GetMax() uint32

func (*CreateReq_AllOptions_FilterOptions) GetStreamIdentifier 

func (x *CreateReq_AllOptions_FilterOptions) GetStreamIdentifier() *CreateReq_AllOptions_FilterOptions_Expression

func (*CreateReq_AllOptions_FilterOptions) GetWindow 

func (m *CreateReq_AllOptions_FilterOptions) GetWindow() isCreateReq_AllOptions_FilterOptions_Window

func (*CreateReq_AllOptions_FilterOptions) ProtoMessage 

func (*CreateReq_AllOptions_FilterOptions) ProtoMessage()

func (*CreateReq_AllOptions_FilterOptions) ProtoReflect 

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

func (*CreateReq_AllOptions_FilterOptions) Reset 

func (x *CreateReq_AllOptions_FilterOptions) Reset()

func (*CreateReq_AllOptions_FilterOptions) String 

func (x *CreateReq_AllOptions_FilterOptions) String() string

type CreateReq_AllOptions_FilterOptions_Count 

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

type CreateReq_AllOptions_FilterOptions_EventType 

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

type CreateReq_AllOptions_FilterOptions_Expression 

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

func (*CreateReq_AllOptions_FilterOptions_Expression) Descriptor deprecated 

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

Deprecated: Use CreateReq_AllOptions_FilterOptions_Expression.ProtoReflect.Descriptor instead.

func (*CreateReq_AllOptions_FilterOptions_Expression) GetPrefix 

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

func (*CreateReq_AllOptions_FilterOptions_Expression) GetRegex 

func (x *CreateReq_AllOptions_FilterOptions_Expression) GetRegex() string

func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoMessage 

func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoMessage()

func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoReflect 

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

func (*CreateReq_AllOptions_FilterOptions_Expression) Reset 

func (x *CreateReq_AllOptions_FilterOptions_Expression) Reset()

func (*CreateReq_AllOptions_FilterOptions_Expression) String 

func (x *CreateReq_AllOptions_FilterOptions_Expression) String() string

type CreateReq_AllOptions_FilterOptions_Max 

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

type CreateReq_AllOptions_FilterOptions_StreamIdentifier 

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

type CreateReq_AllOptions_NoFilter 

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

type CreateReq_AllOptions_Position 

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

type CreateReq_AllOptions_Start 

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

type CreateReq_ConsumerStrategy 

type CreateReq_ConsumerStrategy int32
const (
	CreateReq_DispatchToSingle CreateReq_ConsumerStrategy = 0
	CreateReq_RoundRobin       CreateReq_ConsumerStrategy = 1
	CreateReq_Pinned           CreateReq_ConsumerStrategy = 2
)

func (CreateReq_ConsumerStrategy) Descriptor 

func (CreateReq_ConsumerStrategy) Descriptor() protoreflect.EnumDescriptor

func (CreateReq_ConsumerStrategy) Enum 

func (x CreateReq_ConsumerStrategy) Enum() *CreateReq_ConsumerStrategy

func (CreateReq_ConsumerStrategy) EnumDescriptor deprecated 

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

Deprecated: Use CreateReq_ConsumerStrategy.Descriptor instead.

func (CreateReq_ConsumerStrategy) Number 

func (x CreateReq_ConsumerStrategy) Number() protoreflect.EnumNumber

func (CreateReq_ConsumerStrategy) String 

func (x CreateReq_ConsumerStrategy) String() string

func (CreateReq_ConsumerStrategy) Type 

func (CreateReq_ConsumerStrategy) Type() protoreflect.EnumType

type CreateReq_Options 

type CreateReq_Options struct {

	// Types that are assignable to StreamOption:
	//
	//	*CreateReq_Options_Stream
	//	*CreateReq_Options_All
	StreamOption isCreateReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	// Deprecated: Marked as deprecated in persistent.proto.
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	GroupName        string                   `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Settings         *CreateReq_Settings      `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_Options) Descriptor deprecated 

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

Deprecated: Use CreateReq_Options.ProtoReflect.Descriptor instead.

func (*CreateReq_Options) GetAll 

func (x *CreateReq_Options) GetAll() *CreateReq_AllOptions

func (*CreateReq_Options) GetGroupName 

func (x *CreateReq_Options) GetGroupName() string

func (*CreateReq_Options) GetSettings 

func (x *CreateReq_Options) GetSettings() *CreateReq_Settings

func (*CreateReq_Options) GetStream 

func (x *CreateReq_Options) GetStream() *CreateReq_StreamOptions

func (*CreateReq_Options) GetStreamIdentifier deprecated 

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

Deprecated: Marked as deprecated in persistent.proto.

func (*CreateReq_Options) GetStreamOption 

func (m *CreateReq_Options) GetStreamOption() isCreateReq_Options_StreamOption

func (*CreateReq_Options) ProtoMessage 

func (*CreateReq_Options) ProtoMessage()

func (*CreateReq_Options) ProtoReflect 

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

func (*CreateReq_Options) Reset 

func (x *CreateReq_Options) Reset()

func (*CreateReq_Options) String 

func (x *CreateReq_Options) String() string

type CreateReq_Options_All 

type CreateReq_Options_All struct {
	All *CreateReq_AllOptions `protobuf:"bytes,5,opt,name=all,proto3,oneof"`
}

type CreateReq_Options_Stream 

type CreateReq_Options_Stream struct {
	Stream *CreateReq_StreamOptions `protobuf:"bytes,4,opt,name=stream,proto3,oneof"`
}

type CreateReq_Position 

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

func (*CreateReq_Position) Descriptor deprecated 

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

Deprecated: Use CreateReq_Position.ProtoReflect.Descriptor instead.

func (*CreateReq_Position) GetCommitPosition 

func (x *CreateReq_Position) GetCommitPosition() uint64

func (*CreateReq_Position) GetPreparePosition 

func (x *CreateReq_Position) GetPreparePosition() uint64

func (*CreateReq_Position) ProtoMessage 

func (*CreateReq_Position) ProtoMessage()

func (*CreateReq_Position) ProtoReflect 

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

func (*CreateReq_Position) Reset 

func (x *CreateReq_Position) Reset()

func (*CreateReq_Position) String 

func (x *CreateReq_Position) String() string

type CreateReq_Settings 

type CreateReq_Settings struct {
	ResolveLinks bool `protobuf:"varint,1,opt,name=resolve_links,json=resolveLinks,proto3" json:"resolve_links,omitempty"`
	// Deprecated: Marked as deprecated in persistent.proto.
	Revision           uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	ExtraStatistics    bool   `protobuf:"varint,3,opt,name=extra_statistics,json=extraStatistics,proto3" json:"extra_statistics,omitempty"`
	MaxRetryCount      int32  `protobuf:"varint,5,opt,name=max_retry_count,json=maxRetryCount,proto3" json:"max_retry_count,omitempty"`
	MinCheckpointCount int32  `protobuf:"varint,7,opt,name=min_checkpoint_count,json=minCheckpointCount,proto3" json:"min_checkpoint_count,omitempty"`
	MaxCheckpointCount int32  `protobuf:"varint,8,opt,name=max_checkpoint_count,json=maxCheckpointCount,proto3" json:"max_checkpoint_count,omitempty"`
	MaxSubscriberCount int32  `protobuf:"varint,9,opt,name=max_subscriber_count,json=maxSubscriberCount,proto3" json:"max_subscriber_count,omitempty"`
	LiveBufferSize     int32  `protobuf:"varint,10,opt,name=live_buffer_size,json=liveBufferSize,proto3" json:"live_buffer_size,omitempty"`
	ReadBatchSize      int32  `protobuf:"varint,11,opt,name=read_batch_size,json=readBatchSize,proto3" json:"read_batch_size,omitempty"`
	HistoryBufferSize  int32  `protobuf:"varint,12,opt,name=history_buffer_size,json=historyBufferSize,proto3" json:"history_buffer_size,omitempty"`
	// Deprecated: Marked as deprecated in persistent.proto.
	NamedConsumerStrategy CreateReq_ConsumerStrategy `` /* 204-byte string literal not displayed */
	// Types that are assignable to MessageTimeout:
	//
	//	*CreateReq_Settings_MessageTimeoutTicks
	//	*CreateReq_Settings_MessageTimeoutMs
	MessageTimeout isCreateReq_Settings_MessageTimeout `protobuf_oneof:"message_timeout"`
	// Types that are assignable to CheckpointAfter:
	//
	//	*CreateReq_Settings_CheckpointAfterTicks
	//	*CreateReq_Settings_CheckpointAfterMs
	CheckpointAfter  isCreateReq_Settings_CheckpointAfter `protobuf_oneof:"checkpoint_after"`
	ConsumerStrategy string                               `protobuf:"bytes,16,opt,name=consumer_strategy,json=consumerStrategy,proto3" json:"consumer_strategy,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_Settings) Descriptor deprecated 

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

Deprecated: Use CreateReq_Settings.ProtoReflect.Descriptor instead.

func (*CreateReq_Settings) GetCheckpointAfter 

func (m *CreateReq_Settings) GetCheckpointAfter() isCreateReq_Settings_CheckpointAfter

func (*CreateReq_Settings) GetCheckpointAfterMs 

func (x *CreateReq_Settings) GetCheckpointAfterMs() int32

func (*CreateReq_Settings) GetCheckpointAfterTicks 

func (x *CreateReq_Settings) GetCheckpointAfterTicks() int64

func (*CreateReq_Settings) GetConsumerStrategy 

func (x *CreateReq_Settings) GetConsumerStrategy() string

func (*CreateReq_Settings) GetExtraStatistics 

func (x *CreateReq_Settings) GetExtraStatistics() bool

func (*CreateReq_Settings) GetHistoryBufferSize 

func (x *CreateReq_Settings) GetHistoryBufferSize() int32

func (*CreateReq_Settings) GetLiveBufferSize 

func (x *CreateReq_Settings) GetLiveBufferSize() int32

func (*CreateReq_Settings) GetMaxCheckpointCount 

func (x *CreateReq_Settings) GetMaxCheckpointCount() int32

func (*CreateReq_Settings) GetMaxRetryCount 

func (x *CreateReq_Settings) GetMaxRetryCount() int32

func (*CreateReq_Settings) GetMaxSubscriberCount 

func (x *CreateReq_Settings) GetMaxSubscriberCount() int32

func (*CreateReq_Settings) GetMessageTimeout 

func (m *CreateReq_Settings) GetMessageTimeout() isCreateReq_Settings_MessageTimeout

func (*CreateReq_Settings) GetMessageTimeoutMs 

func (x *CreateReq_Settings) GetMessageTimeoutMs() int32

func (*CreateReq_Settings) GetMessageTimeoutTicks 

func (x *CreateReq_Settings) GetMessageTimeoutTicks() int64

func (*CreateReq_Settings) GetMinCheckpointCount 

func (x *CreateReq_Settings) GetMinCheckpointCount() int32

func (*CreateReq_Settings) GetNamedConsumerStrategy deprecated 

func (x *CreateReq_Settings) GetNamedConsumerStrategy() CreateReq_ConsumerStrategy

Deprecated: Marked as deprecated in persistent.proto.

func (*CreateReq_Settings) GetReadBatchSize 

func (x *CreateReq_Settings) GetReadBatchSize() int32
func (x *CreateReq_Settings) GetResolveLinks() bool

func (*CreateReq_Settings) GetRevision deprecated 

func (x *CreateReq_Settings) GetRevision() uint64

Deprecated: Marked as deprecated in persistent.proto.

func (*CreateReq_Settings) ProtoMessage 

func (*CreateReq_Settings) ProtoMessage()

func (*CreateReq_Settings) ProtoReflect 

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

func (*CreateReq_Settings) Reset 

func (x *CreateReq_Settings) Reset()

func (*CreateReq_Settings) String 

func (x *CreateReq_Settings) String() string

type CreateReq_Settings_CheckpointAfterMs 

type CreateReq_Settings_CheckpointAfterMs struct {
	CheckpointAfterMs int32 `protobuf:"varint,15,opt,name=checkpoint_after_ms,json=checkpointAfterMs,proto3,oneof"`
}

type CreateReq_Settings_CheckpointAfterTicks 

type CreateReq_Settings_CheckpointAfterTicks struct {
	CheckpointAfterTicks int64 `protobuf:"varint,6,opt,name=checkpoint_after_ticks,json=checkpointAfterTicks,proto3,oneof"`
}

type CreateReq_Settings_MessageTimeoutMs 

type CreateReq_Settings_MessageTimeoutMs struct {
	MessageTimeoutMs int32 `protobuf:"varint,14,opt,name=message_timeout_ms,json=messageTimeoutMs,proto3,oneof"`
}

type CreateReq_Settings_MessageTimeoutTicks 

type CreateReq_Settings_MessageTimeoutTicks struct {
	MessageTimeoutTicks int64 `protobuf:"varint,4,opt,name=message_timeout_ticks,json=messageTimeoutTicks,proto3,oneof"`
}

type CreateReq_StreamOptions 

type CreateReq_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:
	//
	//	*CreateReq_StreamOptions_Revision
	//	*CreateReq_StreamOptions_Start
	//	*CreateReq_StreamOptions_End
	RevisionOption isCreateReq_StreamOptions_RevisionOption `protobuf_oneof:"revision_option"`
	// contains filtered or unexported fields
}

func (*CreateReq_StreamOptions) Descriptor deprecated 

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

Deprecated: Use CreateReq_StreamOptions.ProtoReflect.Descriptor instead.

func (*CreateReq_StreamOptions) GetEnd 

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

func (*CreateReq_StreamOptions) GetRevision 

func (x *CreateReq_StreamOptions) GetRevision() uint64

func (*CreateReq_StreamOptions) GetRevisionOption 

func (m *CreateReq_StreamOptions) GetRevisionOption() isCreateReq_StreamOptions_RevisionOption

func (*CreateReq_StreamOptions) GetStart 

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

func (*CreateReq_StreamOptions) GetStreamIdentifier 

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

func (*CreateReq_StreamOptions) ProtoMessage 

func (*CreateReq_StreamOptions) ProtoMessage()

func (*CreateReq_StreamOptions) ProtoReflect 

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

func (*CreateReq_StreamOptions) Reset 

func (x *CreateReq_StreamOptions) Reset()

func (*CreateReq_StreamOptions) String 

func (x *CreateReq_StreamOptions) String() string

type CreateReq_StreamOptions_End 

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

type CreateReq_StreamOptions_Revision 

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

type CreateReq_StreamOptions_Start 

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

type CreateResp 

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

func (*CreateResp) Descriptor deprecated 

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

Deprecated: Use CreateResp.ProtoReflect.Descriptor instead.

func (*CreateResp) ProtoMessage 

func (*CreateResp) ProtoMessage()

func (*CreateResp) ProtoReflect 

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

func (*CreateResp) Reset 

func (x *CreateResp) Reset()

func (*CreateResp) String 

func (x *CreateResp) String() string

type DeleteReq 

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

func (*DeleteReq) Descriptor deprecated 

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

Deprecated: Use DeleteReq.ProtoReflect.Descriptor instead.

func (*DeleteReq) GetOptions 

func (x *DeleteReq) GetOptions() *DeleteReq_Options

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) ProtoReflect 

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

func (*DeleteReq) Reset 

func (x *DeleteReq) Reset()

func (*DeleteReq) String 

func (x *DeleteReq) String() string

type DeleteReq_Options 

type DeleteReq_Options struct {

	// Types that are assignable to StreamOption:
	//
	//	*DeleteReq_Options_StreamIdentifier
	//	*DeleteReq_Options_All
	StreamOption isDeleteReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	GroupName    string                           `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteReq_Options) Descriptor deprecated 

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

Deprecated: Use DeleteReq_Options.ProtoReflect.Descriptor instead.

func (*DeleteReq_Options) GetAll 

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

func (*DeleteReq_Options) GetGroupName 

func (x *DeleteReq_Options) GetGroupName() string

func (*DeleteReq_Options) GetStreamIdentifier 

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

func (*DeleteReq_Options) GetStreamOption 

func (m *DeleteReq_Options) GetStreamOption() isDeleteReq_Options_StreamOption

func (*DeleteReq_Options) ProtoMessage 

func (*DeleteReq_Options) ProtoMessage()

func (*DeleteReq_Options) ProtoReflect 

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

func (*DeleteReq_Options) Reset 

func (x *DeleteReq_Options) Reset()

func (*DeleteReq_Options) String 

func (x *DeleteReq_Options) String() string

type DeleteReq_Options_All 

type DeleteReq_Options_All struct {
	All *shared.Empty `protobuf:"bytes,3,opt,name=all,proto3,oneof"`
}

type DeleteReq_Options_StreamIdentifier 

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

type DeleteResp 

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

func (*DeleteResp) Descriptor deprecated 

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

Deprecated: Use DeleteResp.ProtoReflect.Descriptor instead.

func (*DeleteResp) ProtoMessage 

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) ProtoReflect 

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

func (*DeleteResp) Reset 

func (x *DeleteResp) Reset()

func (*DeleteResp) String 

func (x *DeleteResp) String() string

type GetInfoReq 

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

func (*GetInfoReq) Descriptor deprecated 

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

Deprecated: Use GetInfoReq.ProtoReflect.Descriptor instead.

func (*GetInfoReq) GetOptions 

func (x *GetInfoReq) GetOptions() *GetInfoReq_Options

func (*GetInfoReq) ProtoMessage 

func (*GetInfoReq) ProtoMessage()

func (*GetInfoReq) ProtoReflect 

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

func (*GetInfoReq) Reset 

func (x *GetInfoReq) Reset()

func (*GetInfoReq) String 

func (x *GetInfoReq) String() string

type GetInfoReq_Options 

type GetInfoReq_Options struct {

	// Types that are assignable to StreamOption:
	//
	//	*GetInfoReq_Options_StreamIdentifier
	//	*GetInfoReq_Options_All
	StreamOption isGetInfoReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	GroupName    string                            `protobuf:"bytes,3,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoReq_Options) Descriptor deprecated 

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

Deprecated: Use GetInfoReq_Options.ProtoReflect.Descriptor instead.

func (*GetInfoReq_Options) GetAll 

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

func (*GetInfoReq_Options) GetGroupName 

func (x *GetInfoReq_Options) GetGroupName() string

func (*GetInfoReq_Options) GetStreamIdentifier 

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

func (*GetInfoReq_Options) GetStreamOption 

func (m *GetInfoReq_Options) GetStreamOption() isGetInfoReq_Options_StreamOption

func (*GetInfoReq_Options) ProtoMessage 

func (*GetInfoReq_Options) ProtoMessage()

func (*GetInfoReq_Options) ProtoReflect 

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

func (*GetInfoReq_Options) Reset 

func (x *GetInfoReq_Options) Reset()

func (*GetInfoReq_Options) String 

func (x *GetInfoReq_Options) String() string

type GetInfoReq_Options_All 

type GetInfoReq_Options_All struct {
	All *shared.Empty `protobuf:"bytes,2,opt,name=all,proto3,oneof"`
}

type GetInfoReq_Options_StreamIdentifier 

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

type GetInfoResp 

type GetInfoResp struct {
	SubscriptionInfo *SubscriptionInfo `protobuf:"bytes,1,opt,name=subscription_info,json=subscriptionInfo,proto3" json:"subscription_info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoResp) Descriptor deprecated 

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

Deprecated: Use GetInfoResp.ProtoReflect.Descriptor instead.

func (*GetInfoResp) GetSubscriptionInfo 

func (x *GetInfoResp) GetSubscriptionInfo() *SubscriptionInfo

func (*GetInfoResp) ProtoMessage 

func (*GetInfoResp) ProtoMessage()

func (*GetInfoResp) ProtoReflect 

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

func (*GetInfoResp) Reset 

func (x *GetInfoResp) Reset()

func (*GetInfoResp) String 

func (x *GetInfoResp) String() string

type ListReq 

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

func (*ListReq) Descriptor deprecated 

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

Deprecated: Use ListReq.ProtoReflect.Descriptor instead.

func (*ListReq) GetOptions 

func (x *ListReq) GetOptions() *ListReq_Options

func (*ListReq) ProtoMessage 

func (*ListReq) ProtoMessage()

func (*ListReq) ProtoReflect 

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

func (*ListReq) Reset 

func (x *ListReq) Reset()

func (*ListReq) String 

func (x *ListReq) String() string

type ListReq_Options 

type ListReq_Options struct {

	// Types that are assignable to ListOption:
	//
	//	*ListReq_Options_ListAllSubscriptions
	//	*ListReq_Options_ListForStream
	ListOption isListReq_Options_ListOption `protobuf_oneof:"list_option"`
	// contains filtered or unexported fields
}

func (*ListReq_Options) Descriptor deprecated 

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

Deprecated: Use ListReq_Options.ProtoReflect.Descriptor instead.

func (*ListReq_Options) GetListAllSubscriptions 

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

func (*ListReq_Options) GetListForStream 

func (x *ListReq_Options) GetListForStream() *ListReq_StreamOption

func (*ListReq_Options) GetListOption 

func (m *ListReq_Options) GetListOption() isListReq_Options_ListOption

func (*ListReq_Options) ProtoMessage 

func (*ListReq_Options) ProtoMessage()

func (*ListReq_Options) ProtoReflect 

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

func (*ListReq_Options) Reset 

func (x *ListReq_Options) Reset()

func (*ListReq_Options) String 

func (x *ListReq_Options) String() string

type ListReq_Options_ListAllSubscriptions 

type ListReq_Options_ListAllSubscriptions struct {
	ListAllSubscriptions *shared.Empty `protobuf:"bytes,1,opt,name=list_all_subscriptions,json=listAllSubscriptions,proto3,oneof"`
}

type ListReq_Options_ListForStream 

type ListReq_Options_ListForStream struct {
	ListForStream *ListReq_StreamOption `protobuf:"bytes,2,opt,name=list_for_stream,json=listForStream,proto3,oneof"`
}

type ListReq_StreamOption 

type ListReq_StreamOption struct {

	// Types that are assignable to StreamOption:
	//
	//	*ListReq_StreamOption_Stream
	//	*ListReq_StreamOption_All
	StreamOption isListReq_StreamOption_StreamOption `protobuf_oneof:"stream_option"`
	// contains filtered or unexported fields
}

func (*ListReq_StreamOption) Descriptor deprecated 

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

Deprecated: Use ListReq_StreamOption.ProtoReflect.Descriptor instead.

func (*ListReq_StreamOption) GetAll 

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

func (*ListReq_StreamOption) GetStream 

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

func (*ListReq_StreamOption) GetStreamOption 

func (m *ListReq_StreamOption) GetStreamOption() isListReq_StreamOption_StreamOption

func (*ListReq_StreamOption) ProtoMessage 

func (*ListReq_StreamOption) ProtoMessage()

func (*ListReq_StreamOption) ProtoReflect 

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

func (*ListReq_StreamOption) Reset 

func (x *ListReq_StreamOption) Reset()

func (*ListReq_StreamOption) String 

func (x *ListReq_StreamOption) String() string

type ListReq_StreamOption_All 

type ListReq_StreamOption_All struct {
	All *shared.Empty `protobuf:"bytes,2,opt,name=all,proto3,oneof"`
}

type ListReq_StreamOption_Stream 

type ListReq_StreamOption_Stream struct {
	Stream *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream,proto3,oneof"`
}

type ListResp 

type ListResp struct {
	Subscriptions []*SubscriptionInfo `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResp) Descriptor deprecated 

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

Deprecated: Use ListResp.ProtoReflect.Descriptor instead.

func (*ListResp) GetSubscriptions 

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

func (*ListResp) ProtoMessage 

func (*ListResp) ProtoMessage()

func (*ListResp) ProtoReflect 

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

func (*ListResp) Reset 

func (x *ListResp) Reset()

func (*ListResp) String 

func (x *ListResp) String() string

type PersistentSubscriptionsClient 

type PersistentSubscriptionsClient interface {
	Create(ctx context.Context, in *CreateReq, opts ...grpc.CallOption) (*CreateResp, error)
	Update(ctx context.Context, in *UpdateReq, opts ...grpc.CallOption) (*UpdateResp, error)
	Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteResp, error)
	Read(ctx context.Context, opts ...grpc.CallOption) (PersistentSubscriptions_ReadClient, error)
	GetInfo(ctx context.Context, in *GetInfoReq, opts ...grpc.CallOption) (*GetInfoResp, error)
	ReplayParked(ctx context.Context, in *ReplayParkedReq, opts ...grpc.CallOption) (*ReplayParkedResp, error)
	List(ctx context.Context, in *ListReq, opts ...grpc.CallOption) (*ListResp, error)
	RestartSubsystem(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
}

PersistentSubscriptionsClient is the client API for PersistentSubscriptions service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPersistentSubscriptionsClient 

func NewPersistentSubscriptionsClient(cc grpc.ClientConnInterface) PersistentSubscriptionsClient

type PersistentSubscriptionsServer 

type PersistentSubscriptionsServer interface {
	Create(context.Context, *CreateReq) (*CreateResp, error)
	Update(context.Context, *UpdateReq) (*UpdateResp, error)
	Delete(context.Context, *DeleteReq) (*DeleteResp, error)
	Read(PersistentSubscriptions_ReadServer) error
	GetInfo(context.Context, *GetInfoReq) (*GetInfoResp, error)
	ReplayParked(context.Context, *ReplayParkedReq) (*ReplayParkedResp, error)
	List(context.Context, *ListReq) (*ListResp, error)
	RestartSubsystem(context.Context, *shared.Empty) (*shared.Empty, error)
	// contains filtered or unexported methods
}

PersistentSubscriptionsServer is the server API for PersistentSubscriptions service. All implementations must embed UnimplementedPersistentSubscriptionsServer for forward compatibility

type PersistentSubscriptions_ReadClient 

type PersistentSubscriptions_ReadClient interface {
	Send(*ReadReq) error
	Recv() (*ReadResp, error)
	grpc.ClientStream
}

type PersistentSubscriptions_ReadServer 

type PersistentSubscriptions_ReadServer interface {
	Send(*ReadResp) error
	Recv() (*ReadReq, error)
	grpc.ServerStream
}

type ReadReq 

type ReadReq struct {

	// Types that are assignable to Content:
	//
	//	*ReadReq_Options_
	//	*ReadReq_Ack_
	//	*ReadReq_Nack_
	Content isReadReq_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ReadReq) Descriptor deprecated 

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

Deprecated: Use ReadReq.ProtoReflect.Descriptor instead.

func (*ReadReq) GetAck 

func (x *ReadReq) GetAck() *ReadReq_Ack

func (*ReadReq) GetContent 

func (m *ReadReq) GetContent() isReadReq_Content

func (*ReadReq) GetNack 

func (x *ReadReq) GetNack() *ReadReq_Nack

func (*ReadReq) GetOptions 

func (x *ReadReq) GetOptions() *ReadReq_Options

func (*ReadReq) ProtoMessage 

func (*ReadReq) ProtoMessage()

func (*ReadReq) ProtoReflect 

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

func (*ReadReq) Reset 

func (x *ReadReq) Reset()

func (*ReadReq) String 

func (x *ReadReq) String() string

type ReadReq_Ack 

type ReadReq_Ack struct {
	Id  []byte         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ids []*shared.UUID `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Ack) Descriptor deprecated 

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

Deprecated: Use ReadReq_Ack.ProtoReflect.Descriptor instead.

func (*ReadReq_Ack) GetId 

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

func (*ReadReq_Ack) GetIds 

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

func (*ReadReq_Ack) ProtoMessage 

func (*ReadReq_Ack) ProtoMessage()

func (*ReadReq_Ack) ProtoReflect 

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

func (*ReadReq_Ack) Reset 

func (x *ReadReq_Ack) Reset()

func (*ReadReq_Ack) String 

func (x *ReadReq_Ack) String() string

type ReadReq_Ack_ 

type ReadReq_Ack_ struct {
	Ack *ReadReq_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type ReadReq_Nack 

type ReadReq_Nack struct {
	Id     []byte              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ids    []*shared.UUID      `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	Action ReadReq_Nack_Action `` /* 135-byte string literal not displayed */
	Reason string              `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Nack) Descriptor deprecated 

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

Deprecated: Use ReadReq_Nack.ProtoReflect.Descriptor instead.

func (*ReadReq_Nack) GetAction 

func (x *ReadReq_Nack) GetAction() ReadReq_Nack_Action

func (*ReadReq_Nack) GetId 

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

func (*ReadReq_Nack) GetIds 

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

func (*ReadReq_Nack) GetReason 

func (x *ReadReq_Nack) GetReason() string

func (*ReadReq_Nack) ProtoMessage 

func (*ReadReq_Nack) ProtoMessage()

func (*ReadReq_Nack) ProtoReflect 

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

func (*ReadReq_Nack) Reset 

func (x *ReadReq_Nack) Reset()

func (*ReadReq_Nack) String 

func (x *ReadReq_Nack) String() string

type ReadReq_Nack_ 

type ReadReq_Nack_ struct {
	Nack *ReadReq_Nack `protobuf:"bytes,3,opt,name=nack,proto3,oneof"`
}

type ReadReq_Nack_Action 

type ReadReq_Nack_Action int32
const (
	ReadReq_Nack_Unknown ReadReq_Nack_Action = 0
	ReadReq_Nack_Park    ReadReq_Nack_Action = 1
	ReadReq_Nack_Retry   ReadReq_Nack_Action = 2
	ReadReq_Nack_Skip    ReadReq_Nack_Action = 3
	ReadReq_Nack_Stop    ReadReq_Nack_Action = 4
)

func (ReadReq_Nack_Action) Descriptor 

func (ReadReq_Nack_Action) Descriptor() protoreflect.EnumDescriptor

func (ReadReq_Nack_Action) Enum 

func (x ReadReq_Nack_Action) Enum() *ReadReq_Nack_Action

func (ReadReq_Nack_Action) EnumDescriptor deprecated 

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

Deprecated: Use ReadReq_Nack_Action.Descriptor instead.

func (ReadReq_Nack_Action) Number 

func (x ReadReq_Nack_Action) Number() protoreflect.EnumNumber

func (ReadReq_Nack_Action) String 

func (x ReadReq_Nack_Action) String() string

func (ReadReq_Nack_Action) Type 

func (ReadReq_Nack_Action) Type() protoreflect.EnumType

type ReadReq_Options 

type ReadReq_Options struct {

	// Types that are assignable to StreamOption:
	//
	//	*ReadReq_Options_StreamIdentifier
	//	*ReadReq_Options_All
	StreamOption isReadReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	GroupName    string                         `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	BufferSize   int32                          `protobuf:"varint,3,opt,name=buffer_size,json=bufferSize,proto3" json:"buffer_size,omitempty"`
	UuidOption   *ReadReq_Options_UUIDOption    `protobuf:"bytes,4,opt,name=uuid_option,json=uuidOption,proto3" json:"uuid_option,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq_Options) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options.ProtoReflect.Descriptor instead.

func (*ReadReq_Options) GetAll 

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

func (*ReadReq_Options) GetBufferSize 

func (x *ReadReq_Options) GetBufferSize() int32

func (*ReadReq_Options) GetGroupName 

func (x *ReadReq_Options) GetGroupName() string

func (*ReadReq_Options) GetStreamIdentifier 

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

func (*ReadReq_Options) GetStreamOption 

func (m *ReadReq_Options) GetStreamOption() isReadReq_Options_StreamOption

func (*ReadReq_Options) GetUuidOption 

func (x *ReadReq_Options) GetUuidOption() *ReadReq_Options_UUIDOption

func (*ReadReq_Options) ProtoMessage 

func (*ReadReq_Options) ProtoMessage()

func (*ReadReq_Options) ProtoReflect 

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

func (*ReadReq_Options) Reset 

func (x *ReadReq_Options) Reset()

func (*ReadReq_Options) String 

func (x *ReadReq_Options) String() string

type ReadReq_Options_ 

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

type ReadReq_Options_All 

type ReadReq_Options_All struct {
	All *shared.Empty `protobuf:"bytes,5,opt,name=all,proto3,oneof"`
}

type ReadReq_Options_StreamIdentifier 

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

type ReadReq_Options_UUIDOption 

type ReadReq_Options_UUIDOption struct {

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

func (*ReadReq_Options_UUIDOption) Descriptor deprecated 

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

Deprecated: Use ReadReq_Options_UUIDOption.ProtoReflect.Descriptor instead.

func (*ReadReq_Options_UUIDOption) GetContent 

func (m *ReadReq_Options_UUIDOption) GetContent() isReadReq_Options_UUIDOption_Content

func (*ReadReq_Options_UUIDOption) GetString_ 

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

func (*ReadReq_Options_UUIDOption) GetStructured 

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

func (*ReadReq_Options_UUIDOption) ProtoMessage 

func (*ReadReq_Options_UUIDOption) ProtoMessage()

func (*ReadReq_Options_UUIDOption) ProtoReflect 

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

func (*ReadReq_Options_UUIDOption) Reset 

func (x *ReadReq_Options_UUIDOption) Reset()

func (*ReadReq_Options_UUIDOption) String 

func (x *ReadReq_Options_UUIDOption) String() string

type ReadReq_Options_UUIDOption_String_ 

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

type ReadReq_Options_UUIDOption_Structured 

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

type ReadResp 

type ReadResp struct {

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

func (*ReadResp) Descriptor deprecated 

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

Deprecated: Use ReadResp.ProtoReflect.Descriptor instead.

func (*ReadResp) GetContent 

func (m *ReadResp) GetContent() isReadResp_Content

func (*ReadResp) GetEvent 

func (x *ReadResp) GetEvent() *ReadResp_ReadEvent

func (*ReadResp) GetSubscriptionConfirmation 

func (x *ReadResp) GetSubscriptionConfirmation() *ReadResp_SubscriptionConfirmation

func (*ReadResp) ProtoMessage 

func (*ReadResp) ProtoMessage()

func (*ReadResp) ProtoReflect 

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

func (*ReadResp) Reset 

func (x *ReadResp) Reset()

func (*ReadResp) String 

func (x *ReadResp) String() string

type ReadResp_Event 

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

type ReadResp_ReadEvent 

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

func (*ReadResp_ReadEvent) Descriptor deprecated 

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

Deprecated: Use ReadResp_ReadEvent.ProtoReflect.Descriptor instead.

func (*ReadResp_ReadEvent) GetCommitPosition 

func (x *ReadResp_ReadEvent) GetCommitPosition() uint64

func (*ReadResp_ReadEvent) GetCount 

func (m *ReadResp_ReadEvent) GetCount() isReadResp_ReadEvent_Count

func (*ReadResp_ReadEvent) GetEvent 

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

func (*ReadResp_ReadEvent) GetNoPosition 

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

func (*ReadResp_ReadEvent) GetNoRetryCount 

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

func (*ReadResp_ReadEvent) GetPosition 

func (m *ReadResp_ReadEvent) GetPosition() isReadResp_ReadEvent_Position

func (*ReadResp_ReadEvent) GetRetryCount 

func (x *ReadResp_ReadEvent) GetRetryCount() int32

func (*ReadResp_ReadEvent) ProtoMessage 

func (*ReadResp_ReadEvent) ProtoMessage()

func (*ReadResp_ReadEvent) ProtoReflect 

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

func (*ReadResp_ReadEvent) Reset 

func (x *ReadResp_ReadEvent) Reset()

func (*ReadResp_ReadEvent) String 

func (x *ReadResp_ReadEvent) String() string

type ReadResp_ReadEvent_CommitPosition 

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

type ReadResp_ReadEvent_NoPosition 

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

type ReadResp_ReadEvent_NoRetryCount 

type ReadResp_ReadEvent_NoRetryCount struct {
	NoRetryCount *shared.Empty `protobuf:"bytes,6,opt,name=no_retry_count,json=noRetryCount,proto3,oneof"`
}

type ReadResp_ReadEvent_RecordedEvent 

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

func (*ReadResp_ReadEvent_RecordedEvent) Descriptor deprecated 

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

Deprecated: Use ReadResp_ReadEvent_RecordedEvent.ProtoReflect.Descriptor instead.

func (*ReadResp_ReadEvent_RecordedEvent) GetCommitPosition 

func (x *ReadResp_ReadEvent_RecordedEvent) GetCommitPosition() uint64

func (*ReadResp_ReadEvent_RecordedEvent) GetCustomMetadata 

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

func (*ReadResp_ReadEvent_RecordedEvent) GetData 

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

func (*ReadResp_ReadEvent_RecordedEvent) GetId 

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

func (*ReadResp_ReadEvent_RecordedEvent) GetMetadata 

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

func (*ReadResp_ReadEvent_RecordedEvent) GetPreparePosition 

func (x *ReadResp_ReadEvent_RecordedEvent) GetPreparePosition() uint64

func (*ReadResp_ReadEvent_RecordedEvent) GetStreamIdentifier 

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

func (*ReadResp_ReadEvent_RecordedEvent) GetStreamRevision 

func (x *ReadResp_ReadEvent_RecordedEvent) GetStreamRevision() uint64

func (*ReadResp_ReadEvent_RecordedEvent) ProtoMessage 

func (*ReadResp_ReadEvent_RecordedEvent) ProtoMessage()

func (*ReadResp_ReadEvent_RecordedEvent) ProtoReflect 

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

func (*ReadResp_ReadEvent_RecordedEvent) Reset 

func (x *ReadResp_ReadEvent_RecordedEvent) Reset()

func (*ReadResp_ReadEvent_RecordedEvent) String 

func (x *ReadResp_ReadEvent_RecordedEvent) String() string

type ReadResp_ReadEvent_RetryCount 

type ReadResp_ReadEvent_RetryCount struct {
	RetryCount int32 `protobuf:"varint,5,opt,name=retry_count,json=retryCount,proto3,oneof"`
}

type ReadResp_SubscriptionConfirmation 

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

func (*ReadResp_SubscriptionConfirmation) Descriptor deprecated 

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

Deprecated: Use ReadResp_SubscriptionConfirmation.ProtoReflect.Descriptor instead.

func (*ReadResp_SubscriptionConfirmation) GetSubscriptionId 

func (x *ReadResp_SubscriptionConfirmation) GetSubscriptionId() string

func (*ReadResp_SubscriptionConfirmation) ProtoMessage 

func (*ReadResp_SubscriptionConfirmation) ProtoMessage()

func (*ReadResp_SubscriptionConfirmation) ProtoReflect 

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

func (*ReadResp_SubscriptionConfirmation) Reset 

func (x *ReadResp_SubscriptionConfirmation) Reset()

func (*ReadResp_SubscriptionConfirmation) String 

func (x *ReadResp_SubscriptionConfirmation) String() string

type ReadResp_SubscriptionConfirmation_ 

type ReadResp_SubscriptionConfirmation_ struct {
	SubscriptionConfirmation *ReadResp_SubscriptionConfirmation `protobuf:"bytes,2,opt,name=subscription_confirmation,json=subscriptionConfirmation,proto3,oneof"`
}

type ReplayParkedReq 

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

func (*ReplayParkedReq) Descriptor deprecated 

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

Deprecated: Use ReplayParkedReq.ProtoReflect.Descriptor instead.

func (*ReplayParkedReq) GetOptions 

func (x *ReplayParkedReq) GetOptions() *ReplayParkedReq_Options

func (*ReplayParkedReq) ProtoMessage 

func (*ReplayParkedReq) ProtoMessage()

func (*ReplayParkedReq) ProtoReflect 

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

func (*ReplayParkedReq) Reset 

func (x *ReplayParkedReq) Reset()

func (*ReplayParkedReq) String 

func (x *ReplayParkedReq) String() string

type ReplayParkedReq_Options 

type ReplayParkedReq_Options struct {
	GroupName string `protobuf:"bytes,1,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// Types that are assignable to StreamOption:
	//
	//	*ReplayParkedReq_Options_StreamIdentifier
	//	*ReplayParkedReq_Options_All
	StreamOption isReplayParkedReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	// Types that are assignable to StopAtOption:
	//
	//	*ReplayParkedReq_Options_StopAt
	//	*ReplayParkedReq_Options_NoLimit
	StopAtOption isReplayParkedReq_Options_StopAtOption `protobuf_oneof:"stop_at_option"`
	// contains filtered or unexported fields
}

func (*ReplayParkedReq_Options) Descriptor deprecated 

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

Deprecated: Use ReplayParkedReq_Options.ProtoReflect.Descriptor instead.

func (*ReplayParkedReq_Options) GetAll 

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

func (*ReplayParkedReq_Options) GetGroupName 

func (x *ReplayParkedReq_Options) GetGroupName() string

func (*ReplayParkedReq_Options) GetNoLimit 

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

func (*ReplayParkedReq_Options) GetStopAt 

func (x *ReplayParkedReq_Options) GetStopAt() int64

func (*ReplayParkedReq_Options) GetStopAtOption 

func (m *ReplayParkedReq_Options) GetStopAtOption() isReplayParkedReq_Options_StopAtOption

func (*ReplayParkedReq_Options) GetStreamIdentifier 

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

func (*ReplayParkedReq_Options) GetStreamOption 

func (m *ReplayParkedReq_Options) GetStreamOption() isReplayParkedReq_Options_StreamOption

func (*ReplayParkedReq_Options) ProtoMessage 

func (*ReplayParkedReq_Options) ProtoMessage()

func (*ReplayParkedReq_Options) ProtoReflect 

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

func (*ReplayParkedReq_Options) Reset 

func (x *ReplayParkedReq_Options) Reset()

func (*ReplayParkedReq_Options) String 

func (x *ReplayParkedReq_Options) String() string

type ReplayParkedReq_Options_All 

type ReplayParkedReq_Options_All struct {
	All *shared.Empty `protobuf:"bytes,3,opt,name=all,proto3,oneof"`
}

type ReplayParkedReq_Options_NoLimit 

type ReplayParkedReq_Options_NoLimit struct {
	NoLimit *shared.Empty `protobuf:"bytes,5,opt,name=no_limit,json=noLimit,proto3,oneof"`
}

type ReplayParkedReq_Options_StopAt 

type ReplayParkedReq_Options_StopAt struct {
	StopAt int64 `protobuf:"varint,4,opt,name=stop_at,json=stopAt,proto3,oneof"`
}

type ReplayParkedReq_Options_StreamIdentifier 

type ReplayParkedReq_Options_StreamIdentifier struct {
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,2,opt,name=stream_identifier,json=streamIdentifier,proto3,oneof"`
}

type ReplayParkedResp 

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

func (*ReplayParkedResp) Descriptor deprecated 

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

Deprecated: Use ReplayParkedResp.ProtoReflect.Descriptor instead.

func (*ReplayParkedResp) ProtoMessage 

func (*ReplayParkedResp) ProtoMessage()

func (*ReplayParkedResp) ProtoReflect 

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

func (*ReplayParkedResp) Reset 

func (x *ReplayParkedResp) Reset()

func (*ReplayParkedResp) String 

func (x *ReplayParkedResp) String() string

type SubscriptionInfo 

type SubscriptionInfo struct {
	EventSource                   string                             `protobuf:"bytes,1,opt,name=event_source,json=eventSource,proto3" json:"event_source,omitempty"`
	GroupName                     string                             `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Status                        string                             `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Connections                   []*SubscriptionInfo_ConnectionInfo `protobuf:"bytes,4,rep,name=connections,proto3" json:"connections,omitempty"`
	AveragePerSecond              int32                              `protobuf:"varint,5,opt,name=average_per_second,json=averagePerSecond,proto3" json:"average_per_second,omitempty"`
	TotalItems                    int64                              `protobuf:"varint,6,opt,name=total_items,json=totalItems,proto3" json:"total_items,omitempty"`
	CountSinceLastMeasurement     int64                              `` /* 141-byte string literal not displayed */
	LastCheckpointedEventPosition string                             `` /* 152-byte string literal not displayed */
	LastKnownEventPosition        string                             `` /* 131-byte string literal not displayed */
	ResolveLinkTos                bool                               `protobuf:"varint,10,opt,name=resolve_link_tos,json=resolveLinkTos,proto3" json:"resolve_link_tos,omitempty"`
	StartFrom                     string                             `protobuf:"bytes,11,opt,name=start_from,json=startFrom,proto3" json:"start_from,omitempty"`
	MessageTimeoutMilliseconds    int32                              `` /* 143-byte string literal not displayed */
	ExtraStatistics               bool                               `protobuf:"varint,13,opt,name=extra_statistics,json=extraStatistics,proto3" json:"extra_statistics,omitempty"`
	MaxRetryCount                 int32                              `protobuf:"varint,14,opt,name=max_retry_count,json=maxRetryCount,proto3" json:"max_retry_count,omitempty"`
	LiveBufferSize                int32                              `protobuf:"varint,15,opt,name=live_buffer_size,json=liveBufferSize,proto3" json:"live_buffer_size,omitempty"`
	BufferSize                    int32                              `protobuf:"varint,16,opt,name=buffer_size,json=bufferSize,proto3" json:"buffer_size,omitempty"`
	ReadBatchSize                 int32                              `protobuf:"varint,17,opt,name=read_batch_size,json=readBatchSize,proto3" json:"read_batch_size,omitempty"`
	CheckPointAfterMilliseconds   int32                              `` /* 148-byte string literal not displayed */
	MinCheckPointCount            int32                              `protobuf:"varint,19,opt,name=min_check_point_count,json=minCheckPointCount,proto3" json:"min_check_point_count,omitempty"`
	MaxCheckPointCount            int32                              `protobuf:"varint,20,opt,name=max_check_point_count,json=maxCheckPointCount,proto3" json:"max_check_point_count,omitempty"`
	ReadBufferCount               int32                              `protobuf:"varint,21,opt,name=read_buffer_count,json=readBufferCount,proto3" json:"read_buffer_count,omitempty"`
	LiveBufferCount               int64                              `protobuf:"varint,22,opt,name=live_buffer_count,json=liveBufferCount,proto3" json:"live_buffer_count,omitempty"`
	RetryBufferCount              int32                              `protobuf:"varint,23,opt,name=retry_buffer_count,json=retryBufferCount,proto3" json:"retry_buffer_count,omitempty"`
	TotalInFlightMessages         int32                              `` /* 130-byte string literal not displayed */
	OutstandingMessagesCount      int32                              `` /* 137-byte string literal not displayed */
	NamedConsumerStrategy         string                             `` /* 127-byte string literal not displayed */
	MaxSubscriberCount            int32                              `protobuf:"varint,27,opt,name=max_subscriber_count,json=maxSubscriberCount,proto3" json:"max_subscriber_count,omitempty"`
	ParkedMessageCount            int64                              `protobuf:"varint,28,opt,name=parked_message_count,json=parkedMessageCount,proto3" json:"parked_message_count,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionInfo) GetAveragePerSecond 

func (x *SubscriptionInfo) GetAveragePerSecond() int32

func (*SubscriptionInfo) GetBufferSize 

func (x *SubscriptionInfo) GetBufferSize() int32

func (*SubscriptionInfo) GetCheckPointAfterMilliseconds 

func (x *SubscriptionInfo) GetCheckPointAfterMilliseconds() int32

func (*SubscriptionInfo) GetConnections 

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

func (*SubscriptionInfo) GetCountSinceLastMeasurement 

func (x *SubscriptionInfo) GetCountSinceLastMeasurement() int64

func (*SubscriptionInfo) GetEventSource 

func (x *SubscriptionInfo) GetEventSource() string

func (*SubscriptionInfo) GetExtraStatistics 

func (x *SubscriptionInfo) GetExtraStatistics() bool

func (*SubscriptionInfo) GetGroupName 

func (x *SubscriptionInfo) GetGroupName() string

func (*SubscriptionInfo) GetLastCheckpointedEventPosition 

func (x *SubscriptionInfo) GetLastCheckpointedEventPosition() string

func (*SubscriptionInfo) GetLastKnownEventPosition 

func (x *SubscriptionInfo) GetLastKnownEventPosition() string

func (*SubscriptionInfo) GetLiveBufferCount 

func (x *SubscriptionInfo) GetLiveBufferCount() int64

func (*SubscriptionInfo) GetLiveBufferSize 

func (x *SubscriptionInfo) GetLiveBufferSize() int32

func (*SubscriptionInfo) GetMaxCheckPointCount 

func (x *SubscriptionInfo) GetMaxCheckPointCount() int32

func (*SubscriptionInfo) GetMaxRetryCount 

func (x *SubscriptionInfo) GetMaxRetryCount() int32

func (*SubscriptionInfo) GetMaxSubscriberCount 

func (x *SubscriptionInfo) GetMaxSubscriberCount() int32

func (*SubscriptionInfo) GetMessageTimeoutMilliseconds 

func (x *SubscriptionInfo) GetMessageTimeoutMilliseconds() int32

func (*SubscriptionInfo) GetMinCheckPointCount 

func (x *SubscriptionInfo) GetMinCheckPointCount() int32

func (*SubscriptionInfo) GetNamedConsumerStrategy 

func (x *SubscriptionInfo) GetNamedConsumerStrategy() string

func (*SubscriptionInfo) GetOutstandingMessagesCount 

func (x *SubscriptionInfo) GetOutstandingMessagesCount() int32

func (*SubscriptionInfo) GetParkedMessageCount 

func (x *SubscriptionInfo) GetParkedMessageCount() int64

func (*SubscriptionInfo) GetReadBatchSize 

func (x *SubscriptionInfo) GetReadBatchSize() int32

func (*SubscriptionInfo) GetReadBufferCount 

func (x *SubscriptionInfo) GetReadBufferCount() int32

func (*SubscriptionInfo) GetResolveLinkTos 

func (x *SubscriptionInfo) GetResolveLinkTos() bool

func (*SubscriptionInfo) GetRetryBufferCount 

func (x *SubscriptionInfo) GetRetryBufferCount() int32

func (*SubscriptionInfo) GetStartFrom 

func (x *SubscriptionInfo) GetStartFrom() string

func (*SubscriptionInfo) GetStatus 

func (x *SubscriptionInfo) GetStatus() string

func (*SubscriptionInfo) GetTotalInFlightMessages 

func (x *SubscriptionInfo) GetTotalInFlightMessages() int32

func (*SubscriptionInfo) GetTotalItems 

func (x *SubscriptionInfo) GetTotalItems() int64

func (*SubscriptionInfo) ProtoMessage 

func (*SubscriptionInfo) ProtoMessage()

func (*SubscriptionInfo) ProtoReflect 

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

func (*SubscriptionInfo) Reset 

func (x *SubscriptionInfo) Reset()

func (*SubscriptionInfo) String 

func (x *SubscriptionInfo) String() string

type SubscriptionInfo_ConnectionInfo 

type SubscriptionInfo_ConnectionInfo struct {
	From                      string                          `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Username                  string                          `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	AverageItemsPerSecond     int32                           `` /* 129-byte string literal not displayed */
	TotalItems                int64                           `protobuf:"varint,4,opt,name=total_items,json=totalItems,proto3" json:"total_items,omitempty"`
	CountSinceLastMeasurement int64                           `` /* 141-byte string literal not displayed */
	ObservedMeasurements      []*SubscriptionInfo_Measurement `protobuf:"bytes,6,rep,name=observed_measurements,json=observedMeasurements,proto3" json:"observed_measurements,omitempty"`
	AvailableSlots            int32                           `protobuf:"varint,7,opt,name=available_slots,json=availableSlots,proto3" json:"available_slots,omitempty"`
	InFlightMessages          int32                           `protobuf:"varint,8,opt,name=in_flight_messages,json=inFlightMessages,proto3" json:"in_flight_messages,omitempty"`
	ConnectionName            string                          `protobuf:"bytes,9,opt,name=connection_name,json=connectionName,proto3" json:"connection_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionInfo_ConnectionInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionInfo_ConnectionInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionInfo_ConnectionInfo) GetAvailableSlots 

func (x *SubscriptionInfo_ConnectionInfo) GetAvailableSlots() int32

func (*SubscriptionInfo_ConnectionInfo) GetAverageItemsPerSecond 

func (x *SubscriptionInfo_ConnectionInfo) GetAverageItemsPerSecond() int32

func (*SubscriptionInfo_ConnectionInfo) GetConnectionName 

func (x *SubscriptionInfo_ConnectionInfo) GetConnectionName() string

func (*SubscriptionInfo_ConnectionInfo) GetCountSinceLastMeasurement 

func (x *SubscriptionInfo_ConnectionInfo) GetCountSinceLastMeasurement() int64

func (*SubscriptionInfo_ConnectionInfo) GetFrom 

func (x *SubscriptionInfo_ConnectionInfo) GetFrom() string

func (*SubscriptionInfo_ConnectionInfo) GetInFlightMessages 

func (x *SubscriptionInfo_ConnectionInfo) GetInFlightMessages() int32

func (*SubscriptionInfo_ConnectionInfo) GetObservedMeasurements 

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

func (*SubscriptionInfo_ConnectionInfo) GetTotalItems 

func (x *SubscriptionInfo_ConnectionInfo) GetTotalItems() int64

func (*SubscriptionInfo_ConnectionInfo) GetUsername 

func (x *SubscriptionInfo_ConnectionInfo) GetUsername() string

func (*SubscriptionInfo_ConnectionInfo) ProtoMessage 

func (*SubscriptionInfo_ConnectionInfo) ProtoMessage()

func (*SubscriptionInfo_ConnectionInfo) ProtoReflect 

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

func (*SubscriptionInfo_ConnectionInfo) Reset 

func (x *SubscriptionInfo_ConnectionInfo) Reset()

func (*SubscriptionInfo_ConnectionInfo) String 

func (x *SubscriptionInfo_ConnectionInfo) String() string

type SubscriptionInfo_Measurement 

type SubscriptionInfo_Measurement struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionInfo_Measurement) Descriptor deprecated 

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

Deprecated: Use SubscriptionInfo_Measurement.ProtoReflect.Descriptor instead.

func (*SubscriptionInfo_Measurement) GetKey 

func (x *SubscriptionInfo_Measurement) GetKey() string

func (*SubscriptionInfo_Measurement) GetValue 

func (x *SubscriptionInfo_Measurement) GetValue() int64

func (*SubscriptionInfo_Measurement) ProtoMessage 

func (*SubscriptionInfo_Measurement) ProtoMessage()

func (*SubscriptionInfo_Measurement) ProtoReflect 

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

func (*SubscriptionInfo_Measurement) Reset 

func (x *SubscriptionInfo_Measurement) Reset()

func (*SubscriptionInfo_Measurement) String 

func (x *SubscriptionInfo_Measurement) String() string

type UnimplementedPersistentSubscriptionsServer 

type UnimplementedPersistentSubscriptionsServer struct {
}

UnimplementedPersistentSubscriptionsServer must be embedded to have forward compatible implementations.

func (UnimplementedPersistentSubscriptionsServer) Create 

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

func (UnimplementedPersistentSubscriptionsServer) Delete 

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

func (UnimplementedPersistentSubscriptionsServer) GetInfo 

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

func (UnimplementedPersistentSubscriptionsServer) List 

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

func (UnimplementedPersistentSubscriptionsServer) Read 

func (UnimplementedPersistentSubscriptionsServer) Read(PersistentSubscriptions_ReadServer) error

func (UnimplementedPersistentSubscriptionsServer) ReplayParked 

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

func (UnimplementedPersistentSubscriptionsServer) RestartSubsystem 

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

func (UnimplementedPersistentSubscriptionsServer) Update 

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

type UnsafePersistentSubscriptionsServer 

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

UnsafePersistentSubscriptionsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PersistentSubscriptionsServer will result in compilation errors.

type UpdateReq 

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

func (*UpdateReq) Descriptor deprecated 

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

Deprecated: Use UpdateReq.ProtoReflect.Descriptor instead.

func (*UpdateReq) GetOptions 

func (x *UpdateReq) GetOptions() *UpdateReq_Options

func (*UpdateReq) ProtoMessage 

func (*UpdateReq) ProtoMessage()

func (*UpdateReq) ProtoReflect 

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

func (*UpdateReq) Reset 

func (x *UpdateReq) Reset()

func (*UpdateReq) String 

func (x *UpdateReq) String() string

type UpdateReq_AllOptions 

type UpdateReq_AllOptions struct {

	// Types that are assignable to AllOption:
	//
	//	*UpdateReq_AllOptions_Position
	//	*UpdateReq_AllOptions_Start
	//	*UpdateReq_AllOptions_End
	AllOption isUpdateReq_AllOptions_AllOption `protobuf_oneof:"all_option"`
	// contains filtered or unexported fields
}

func (*UpdateReq_AllOptions) Descriptor deprecated 

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

Deprecated: Use UpdateReq_AllOptions.ProtoReflect.Descriptor instead.

func (*UpdateReq_AllOptions) GetAllOption 

func (m *UpdateReq_AllOptions) GetAllOption() isUpdateReq_AllOptions_AllOption

func (*UpdateReq_AllOptions) GetEnd 

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

func (*UpdateReq_AllOptions) GetPosition 

func (x *UpdateReq_AllOptions) GetPosition() *UpdateReq_Position

func (*UpdateReq_AllOptions) GetStart 

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

func (*UpdateReq_AllOptions) ProtoMessage 

func (*UpdateReq_AllOptions) ProtoMessage()

func (*UpdateReq_AllOptions) ProtoReflect 

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

func (*UpdateReq_AllOptions) Reset 

func (x *UpdateReq_AllOptions) Reset()

func (*UpdateReq_AllOptions) String 

func (x *UpdateReq_AllOptions) String() string

type UpdateReq_AllOptions_End 

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

type UpdateReq_AllOptions_Position 

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

type UpdateReq_AllOptions_Start 

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

type UpdateReq_ConsumerStrategy 

type UpdateReq_ConsumerStrategy int32
const (
	UpdateReq_DispatchToSingle UpdateReq_ConsumerStrategy = 0
	UpdateReq_RoundRobin       UpdateReq_ConsumerStrategy = 1
	UpdateReq_Pinned           UpdateReq_ConsumerStrategy = 2
)

func (UpdateReq_ConsumerStrategy) Descriptor 

func (UpdateReq_ConsumerStrategy) Descriptor() protoreflect.EnumDescriptor

func (UpdateReq_ConsumerStrategy) Enum 

func (x UpdateReq_ConsumerStrategy) Enum() *UpdateReq_ConsumerStrategy

func (UpdateReq_ConsumerStrategy) EnumDescriptor deprecated 

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

Deprecated: Use UpdateReq_ConsumerStrategy.Descriptor instead.

func (UpdateReq_ConsumerStrategy) Number 

func (x UpdateReq_ConsumerStrategy) Number() protoreflect.EnumNumber

func (UpdateReq_ConsumerStrategy) String 

func (x UpdateReq_ConsumerStrategy) String() string

func (UpdateReq_ConsumerStrategy) Type 

func (UpdateReq_ConsumerStrategy) Type() protoreflect.EnumType

type UpdateReq_Options 

type UpdateReq_Options struct {

	// Types that are assignable to StreamOption:
	//
	//	*UpdateReq_Options_Stream
	//	*UpdateReq_Options_All
	StreamOption isUpdateReq_Options_StreamOption `protobuf_oneof:"stream_option"`
	// Deprecated: Marked as deprecated in persistent.proto.
	StreamIdentifier *shared.StreamIdentifier `protobuf:"bytes,1,opt,name=stream_identifier,json=streamIdentifier,proto3" json:"stream_identifier,omitempty"`
	GroupName        string                   `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Settings         *UpdateReq_Settings      `protobuf:"bytes,3,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateReq_Options) Descriptor deprecated 

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

Deprecated: Use UpdateReq_Options.ProtoReflect.Descriptor instead.

func (*UpdateReq_Options) GetAll 

func (x *UpdateReq_Options) GetAll() *UpdateReq_AllOptions

func (*UpdateReq_Options) GetGroupName 

func (x *UpdateReq_Options) GetGroupName() string

func (*UpdateReq_Options) GetSettings 

func (x *UpdateReq_Options) GetSettings() *UpdateReq_Settings

func (*UpdateReq_Options) GetStream 

func (x *UpdateReq_Options) GetStream() *UpdateReq_StreamOptions

func (*UpdateReq_Options) GetStreamIdentifier deprecated 

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

Deprecated: Marked as deprecated in persistent.proto.

func (*UpdateReq_Options) GetStreamOption 

func (m *UpdateReq_Options) GetStreamOption() isUpdateReq_Options_StreamOption

func (*UpdateReq_Options) ProtoMessage 

func (*UpdateReq_Options) ProtoMessage()

func (*UpdateReq_Options) ProtoReflect 

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

func (*UpdateReq_Options) Reset 

func (x *UpdateReq_Options) Reset()

func (*UpdateReq_Options) String 

func (x *UpdateReq_Options) String() string

type UpdateReq_Options_All 

type UpdateReq_Options_All struct {
	All *UpdateReq_AllOptions `protobuf:"bytes,5,opt,name=all,proto3,oneof"`
}

type UpdateReq_Options_Stream 

type UpdateReq_Options_Stream struct {
	Stream *UpdateReq_StreamOptions `protobuf:"bytes,4,opt,name=stream,proto3,oneof"`
}

type UpdateReq_Position 

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

func (*UpdateReq_Position) Descriptor deprecated 

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

Deprecated: Use UpdateReq_Position.ProtoReflect.Descriptor instead.

func (*UpdateReq_Position) GetCommitPosition 

func (x *UpdateReq_Position) GetCommitPosition() uint64

func (*UpdateReq_Position) GetPreparePosition 

func (x *UpdateReq_Position) GetPreparePosition() uint64

func (*UpdateReq_Position) ProtoMessage 

func (*UpdateReq_Position) ProtoMessage()

func (*UpdateReq_Position) ProtoReflect 

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

func (*UpdateReq_Position) Reset 

func (x *UpdateReq_Position) Reset()

func (*UpdateReq_Position) String 

func (x *UpdateReq_Position) String() string

type UpdateReq_Settings 

type UpdateReq_Settings struct {
	ResolveLinks bool `protobuf:"varint,1,opt,name=resolve_links,json=resolveLinks,proto3" json:"resolve_links,omitempty"`
	// Deprecated: Marked as deprecated in persistent.proto.
	Revision              uint64                     `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	ExtraStatistics       bool                       `protobuf:"varint,3,opt,name=extra_statistics,json=extraStatistics,proto3" json:"extra_statistics,omitempty"`
	MaxRetryCount         int32                      `protobuf:"varint,5,opt,name=max_retry_count,json=maxRetryCount,proto3" json:"max_retry_count,omitempty"`
	MinCheckpointCount    int32                      `protobuf:"varint,7,opt,name=min_checkpoint_count,json=minCheckpointCount,proto3" json:"min_checkpoint_count,omitempty"`
	MaxCheckpointCount    int32                      `protobuf:"varint,8,opt,name=max_checkpoint_count,json=maxCheckpointCount,proto3" json:"max_checkpoint_count,omitempty"`
	MaxSubscriberCount    int32                      `protobuf:"varint,9,opt,name=max_subscriber_count,json=maxSubscriberCount,proto3" json:"max_subscriber_count,omitempty"`
	LiveBufferSize        int32                      `protobuf:"varint,10,opt,name=live_buffer_size,json=liveBufferSize,proto3" json:"live_buffer_size,omitempty"`
	ReadBatchSize         int32                      `protobuf:"varint,11,opt,name=read_batch_size,json=readBatchSize,proto3" json:"read_batch_size,omitempty"`
	HistoryBufferSize     int32                      `protobuf:"varint,12,opt,name=history_buffer_size,json=historyBufferSize,proto3" json:"history_buffer_size,omitempty"`
	NamedConsumerStrategy UpdateReq_ConsumerStrategy `` /* 204-byte string literal not displayed */
	// Types that are assignable to MessageTimeout:
	//
	//	*UpdateReq_Settings_MessageTimeoutTicks
	//	*UpdateReq_Settings_MessageTimeoutMs
	MessageTimeout isUpdateReq_Settings_MessageTimeout `protobuf_oneof:"message_timeout"`
	// Types that are assignable to CheckpointAfter:
	//
	//	*UpdateReq_Settings_CheckpointAfterTicks
	//	*UpdateReq_Settings_CheckpointAfterMs
	CheckpointAfter isUpdateReq_Settings_CheckpointAfter `protobuf_oneof:"checkpoint_after"`
	// contains filtered or unexported fields
}

func (*UpdateReq_Settings) Descriptor deprecated 

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

Deprecated: Use UpdateReq_Settings.ProtoReflect.Descriptor instead.

func (*UpdateReq_Settings) GetCheckpointAfter 

func (m *UpdateReq_Settings) GetCheckpointAfter() isUpdateReq_Settings_CheckpointAfter

func (*UpdateReq_Settings) GetCheckpointAfterMs 

func (x *UpdateReq_Settings) GetCheckpointAfterMs() int32

func (*UpdateReq_Settings) GetCheckpointAfterTicks 

func (x *UpdateReq_Settings) GetCheckpointAfterTicks() int64

func (*UpdateReq_Settings) GetExtraStatistics 

func (x *UpdateReq_Settings) GetExtraStatistics() bool

func (*UpdateReq_Settings) GetHistoryBufferSize 

func (x *UpdateReq_Settings) GetHistoryBufferSize() int32

func (*UpdateReq_Settings) GetLiveBufferSize 

func (x *UpdateReq_Settings) GetLiveBufferSize() int32

func (*UpdateReq_Settings) GetMaxCheckpointCount 

func (x *UpdateReq_Settings) GetMaxCheckpointCount() int32

func (*UpdateReq_Settings) GetMaxRetryCount 

func (x *UpdateReq_Settings) GetMaxRetryCount() int32

func (*UpdateReq_Settings) GetMaxSubscriberCount 

func (x *UpdateReq_Settings) GetMaxSubscriberCount() int32

func (*UpdateReq_Settings) GetMessageTimeout 

func (m *UpdateReq_Settings) GetMessageTimeout() isUpdateReq_Settings_MessageTimeout

func (*UpdateReq_Settings) GetMessageTimeoutMs 

func (x *UpdateReq_Settings) GetMessageTimeoutMs() int32

func (*UpdateReq_Settings) GetMessageTimeoutTicks 

func (x *UpdateReq_Settings) GetMessageTimeoutTicks() int64

func (*UpdateReq_Settings) GetMinCheckpointCount 

func (x *UpdateReq_Settings) GetMinCheckpointCount() int32

func (*UpdateReq_Settings) GetNamedConsumerStrategy 

func (x *UpdateReq_Settings) GetNamedConsumerStrategy() UpdateReq_ConsumerStrategy

func (*UpdateReq_Settings) GetReadBatchSize 

func (x *UpdateReq_Settings) GetReadBatchSize() int32
func (x *UpdateReq_Settings) GetResolveLinks() bool

func (*UpdateReq_Settings) GetRevision deprecated 

func (x *UpdateReq_Settings) GetRevision() uint64

Deprecated: Marked as deprecated in persistent.proto.

func (*UpdateReq_Settings) ProtoMessage 

func (*UpdateReq_Settings) ProtoMessage()

func (*UpdateReq_Settings) ProtoReflect 

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

func (*UpdateReq_Settings) Reset 

func (x *UpdateReq_Settings) Reset()

func (*UpdateReq_Settings) String 

func (x *UpdateReq_Settings) String() string

type UpdateReq_Settings_CheckpointAfterMs 

type UpdateReq_Settings_CheckpointAfterMs struct {
	CheckpointAfterMs int32 `protobuf:"varint,15,opt,name=checkpoint_after_ms,json=checkpointAfterMs,proto3,oneof"`
}

type UpdateReq_Settings_CheckpointAfterTicks 

type UpdateReq_Settings_CheckpointAfterTicks struct {
	CheckpointAfterTicks int64 `protobuf:"varint,6,opt,name=checkpoint_after_ticks,json=checkpointAfterTicks,proto3,oneof"`
}

type UpdateReq_Settings_MessageTimeoutMs 

type UpdateReq_Settings_MessageTimeoutMs struct {
	MessageTimeoutMs int32 `protobuf:"varint,14,opt,name=message_timeout_ms,json=messageTimeoutMs,proto3,oneof"`
}

type UpdateReq_Settings_MessageTimeoutTicks 

type UpdateReq_Settings_MessageTimeoutTicks struct {
	MessageTimeoutTicks int64 `protobuf:"varint,4,opt,name=message_timeout_ticks,json=messageTimeoutTicks,proto3,oneof"`
}

type UpdateReq_StreamOptions 

type UpdateReq_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:
	//
	//	*UpdateReq_StreamOptions_Revision
	//	*UpdateReq_StreamOptions_Start
	//	*UpdateReq_StreamOptions_End
	RevisionOption isUpdateReq_StreamOptions_RevisionOption `protobuf_oneof:"revision_option"`
	// contains filtered or unexported fields
}

func (*UpdateReq_StreamOptions) Descriptor deprecated 

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

Deprecated: Use UpdateReq_StreamOptions.ProtoReflect.Descriptor instead.

func (*UpdateReq_StreamOptions) GetEnd 

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

func (*UpdateReq_StreamOptions) GetRevision 

func (x *UpdateReq_StreamOptions) GetRevision() uint64

func (*UpdateReq_StreamOptions) GetRevisionOption 

func (m *UpdateReq_StreamOptions) GetRevisionOption() isUpdateReq_StreamOptions_RevisionOption

func (*UpdateReq_StreamOptions) GetStart 

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

func (*UpdateReq_StreamOptions) GetStreamIdentifier 

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

func (*UpdateReq_StreamOptions) ProtoMessage 

func (*UpdateReq_StreamOptions) ProtoMessage()

func (*UpdateReq_StreamOptions) ProtoReflect 

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

func (*UpdateReq_StreamOptions) Reset 

func (x *UpdateReq_StreamOptions) Reset()

func (*UpdateReq_StreamOptions) String 

func (x *UpdateReq_StreamOptions) String() string

type UpdateReq_StreamOptions_End 

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

type UpdateReq_StreamOptions_Revision 

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

type UpdateReq_StreamOptions_Start 

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

type UpdateResp 

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

func (*UpdateResp) Descriptor deprecated 

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

Deprecated: Use UpdateResp.ProtoReflect.Descriptor instead.

func (*UpdateResp) ProtoMessage 

func (*UpdateResp) ProtoMessage()

func (*UpdateResp) ProtoReflect 

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

func (*UpdateResp) Reset 

func (x *UpdateResp) Reset()

func (*UpdateResp) String 

func (x *UpdateResp) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.