persistent

package
v2.1.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

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 (*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 (*CreateReq_AllOptions_FilterOptions) GetEventType

func (*CreateReq_AllOptions_FilterOptions) GetFilter

func (m *CreateReq_AllOptions_FilterOptions) GetFilter() isCreateReq_AllOptions_FilterOptions_Filter

func (*CreateReq_AllOptions_FilterOptions) GetMax

func (*CreateReq_AllOptions_FilterOptions) GetStreamIdentifier

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 (*CreateReq_AllOptions_FilterOptions) Reset

func (*CreateReq_AllOptions_FilterOptions) 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

Deprecated: Use CreateReq_AllOptions_FilterOptions_Expression.ProtoReflect.Descriptor instead.

func (*CreateReq_AllOptions_FilterOptions_Expression) GetPrefix

func (*CreateReq_AllOptions_FilterOptions_Expression) GetRegex

func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoMessage

func (*CreateReq_AllOptions_FilterOptions_Expression) ProtoReflect

func (*CreateReq_AllOptions_FilterOptions_Expression) Reset

func (*CreateReq_AllOptions_FilterOptions_Expression) 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) Enum

func (CreateReq_ConsumerStrategy) EnumDescriptor deprecated

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

Deprecated: Use CreateReq_ConsumerStrategy.Descriptor instead.

func (CreateReq_ConsumerStrategy) Number

func (CreateReq_ConsumerStrategy) String

func (CreateReq_ConsumerStrategy) Type

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: Do not use.
	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 (*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 (*CreateReq_Options) GetStreamIdentifier deprecated

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

Deprecated: Do not use.

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: Do not use.
	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: Do not use.
	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: Do not use.

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: Do not use.

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 (*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.

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

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 (ReadReq_Nack_Action) String

func (x ReadReq_Nack_Action) String() string

func (ReadReq_Nack_Action) Type

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 (*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 (*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 (*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 (*ReadResp_ReadEvent_RecordedEvent) Reset

func (*ReadResp_ReadEvent_RecordedEvent) 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 (*ReadResp_SubscriptionConfirmation) Reset

func (*ReadResp_SubscriptionConfirmation) 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 (*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 (*SubscriptionInfo_ConnectionInfo) Reset

func (*SubscriptionInfo_ConnectionInfo) 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 (*SubscriptionInfo_Measurement) GetValue

func (x *SubscriptionInfo_Measurement) GetValue() int64

func (*SubscriptionInfo_Measurement) ProtoMessage

func (*SubscriptionInfo_Measurement) ProtoMessage()

func (*SubscriptionInfo_Measurement) ProtoReflect

func (*SubscriptionInfo_Measurement) Reset

func (x *SubscriptionInfo_Measurement) Reset()

func (*SubscriptionInfo_Measurement) String

type UnimplementedPersistentSubscriptionsServer

type UnimplementedPersistentSubscriptionsServer struct {
}

UnimplementedPersistentSubscriptionsServer must be embedded to have forward compatible implementations.

func (UnimplementedPersistentSubscriptionsServer) Create

func (UnimplementedPersistentSubscriptionsServer) Delete

func (UnimplementedPersistentSubscriptionsServer) GetInfo

func (UnimplementedPersistentSubscriptionsServer) List

func (UnimplementedPersistentSubscriptionsServer) Read

func (UnimplementedPersistentSubscriptionsServer) ReplayParked

func (UnimplementedPersistentSubscriptionsServer) RestartSubsystem

func (UnimplementedPersistentSubscriptionsServer) Update

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

func (UpdateReq_ConsumerStrategy) EnumDescriptor deprecated

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

Deprecated: Use UpdateReq_ConsumerStrategy.Descriptor instead.

func (UpdateReq_ConsumerStrategy) Number

func (UpdateReq_ConsumerStrategy) String

func (UpdateReq_ConsumerStrategy) Type

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: Do not use.
	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 (*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 (*UpdateReq_Options) GetStreamIdentifier deprecated

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

Deprecated: Do not use.

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: Do not use.
	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: Do not use.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL