persistent

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Overview

Package persistent is a generated GoMock package.

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,
		},
	},
	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: 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 (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: 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"`
	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"`
	// 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) 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 

func (x *CreateReq_Settings) GetNamedConsumerStrategy() CreateReq_ConsumerStrategy

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 MockPersistentSubscriptionsClient 

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

MockPersistentSubscriptionsClient is a mock of PersistentSubscriptionsClient interface.

func NewMockPersistentSubscriptionsClient 

func NewMockPersistentSubscriptionsClient(ctrl *gomock.Controller) *MockPersistentSubscriptionsClient

NewMockPersistentSubscriptionsClient creates a new mock instance.

func (*MockPersistentSubscriptionsClient) Create 

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

Create mocks base method.

func (*MockPersistentSubscriptionsClient) Delete 

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

Delete mocks base method.

func (*MockPersistentSubscriptionsClient) EXPECT 

func (m *MockPersistentSubscriptionsClient) EXPECT() *MockPersistentSubscriptionsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPersistentSubscriptionsClient) Read 

func (m *MockPersistentSubscriptionsClient) Read(ctx context.Context, opts ...grpc.CallOption) (PersistentSubscriptions_ReadClient, error)

Read mocks base method.

func (*MockPersistentSubscriptionsClient) Update 

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

Update mocks base method.

type MockPersistentSubscriptionsClientMockRecorder 

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

MockPersistentSubscriptionsClientMockRecorder is the mock recorder for MockPersistentSubscriptionsClient.

func (*MockPersistentSubscriptionsClientMockRecorder) Create 

func (mr *MockPersistentSubscriptionsClientMockRecorder) Create(ctx, in interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockPersistentSubscriptionsClientMockRecorder) Delete 

func (mr *MockPersistentSubscriptionsClientMockRecorder) Delete(ctx, in interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockPersistentSubscriptionsClientMockRecorder) Read 

func (mr *MockPersistentSubscriptionsClientMockRecorder) Read(ctx interface{}, opts ...interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockPersistentSubscriptionsClientMockRecorder) Update 

func (mr *MockPersistentSubscriptionsClientMockRecorder) Update(ctx, in interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockPersistentSubscriptionsServer 

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

MockPersistentSubscriptionsServer is a mock of PersistentSubscriptionsServer interface.

func NewMockPersistentSubscriptionsServer 

func NewMockPersistentSubscriptionsServer(ctrl *gomock.Controller) *MockPersistentSubscriptionsServer

NewMockPersistentSubscriptionsServer creates a new mock instance.

func (*MockPersistentSubscriptionsServer) Create 

func (m *MockPersistentSubscriptionsServer) Create(arg0 context.Context, arg1 *CreateReq) (*CreateResp, error)

Create mocks base method.

func (*MockPersistentSubscriptionsServer) Delete 

func (m *MockPersistentSubscriptionsServer) Delete(arg0 context.Context, arg1 *DeleteReq) (*DeleteResp, error)

Delete mocks base method.

func (*MockPersistentSubscriptionsServer) EXPECT 

func (m *MockPersistentSubscriptionsServer) EXPECT() *MockPersistentSubscriptionsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPersistentSubscriptionsServer) Read 

func (m *MockPersistentSubscriptionsServer) Read(arg0 PersistentSubscriptions_ReadServer) error

Read mocks base method.

func (*MockPersistentSubscriptionsServer) Update 

func (m *MockPersistentSubscriptionsServer) Update(arg0 context.Context, arg1 *UpdateReq) (*UpdateResp, error)

Update mocks base method.

type MockPersistentSubscriptionsServerMockRecorder 

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

MockPersistentSubscriptionsServerMockRecorder is the mock recorder for MockPersistentSubscriptionsServer.

func (*MockPersistentSubscriptionsServerMockRecorder) Create 

func (mr *MockPersistentSubscriptionsServerMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockPersistentSubscriptionsServerMockRecorder) Delete 

func (mr *MockPersistentSubscriptionsServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockPersistentSubscriptionsServerMockRecorder) Read 

func (mr *MockPersistentSubscriptionsServerMockRecorder) Read(arg0 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockPersistentSubscriptionsServerMockRecorder) Update 

func (mr *MockPersistentSubscriptionsServerMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockPersistentSubscriptions_ReadClient 

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

MockPersistentSubscriptions_ReadClient is a mock of PersistentSubscriptions_ReadClient interface.

func NewMockPersistentSubscriptions_ReadClient 

func NewMockPersistentSubscriptions_ReadClient(ctrl *gomock.Controller) *MockPersistentSubscriptions_ReadClient

NewMockPersistentSubscriptions_ReadClient creates a new mock instance.

func (*MockPersistentSubscriptions_ReadClient) CloseSend 

func (m *MockPersistentSubscriptions_ReadClient) CloseSend() error

CloseSend mocks base method.

func (*MockPersistentSubscriptions_ReadClient) Context 

func (m *MockPersistentSubscriptions_ReadClient) Context() context.Context

Context mocks base method.

func (*MockPersistentSubscriptions_ReadClient) EXPECT 

func (m *MockPersistentSubscriptions_ReadClient) EXPECT() *MockPersistentSubscriptions_ReadClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPersistentSubscriptions_ReadClient) Header 

func (m *MockPersistentSubscriptions_ReadClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockPersistentSubscriptions_ReadClient) Recv 

func (m *MockPersistentSubscriptions_ReadClient) Recv() (*ReadResp, error)

Recv mocks base method.

func (*MockPersistentSubscriptions_ReadClient) RecvMsg 

func (m_2 *MockPersistentSubscriptions_ReadClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockPersistentSubscriptions_ReadClient) Send 

func (m *MockPersistentSubscriptions_ReadClient) Send(arg0 *ReadReq) error

Send mocks base method.

func (*MockPersistentSubscriptions_ReadClient) SendMsg 

func (m_2 *MockPersistentSubscriptions_ReadClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockPersistentSubscriptions_ReadClient) Trailer 

func (m *MockPersistentSubscriptions_ReadClient) Trailer() metadata.MD

Trailer mocks base method.

type MockPersistentSubscriptions_ReadClientMockRecorder 

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

MockPersistentSubscriptions_ReadClientMockRecorder is the mock recorder for MockPersistentSubscriptions_ReadClient.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) CloseSend 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) Context 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) Header 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) Recv 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) RecvMsg 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) Send 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) SendMsg 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockPersistentSubscriptions_ReadClientMockRecorder) Trailer 

func (mr *MockPersistentSubscriptions_ReadClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockPersistentSubscriptions_ReadServer 

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

MockPersistentSubscriptions_ReadServer is a mock of PersistentSubscriptions_ReadServer interface.

func NewMockPersistentSubscriptions_ReadServer 

func NewMockPersistentSubscriptions_ReadServer(ctrl *gomock.Controller) *MockPersistentSubscriptions_ReadServer

NewMockPersistentSubscriptions_ReadServer creates a new mock instance.

func (*MockPersistentSubscriptions_ReadServer) Context 

func (m *MockPersistentSubscriptions_ReadServer) Context() context.Context

Context mocks base method.

func (*MockPersistentSubscriptions_ReadServer) EXPECT 

func (m *MockPersistentSubscriptions_ReadServer) EXPECT() *MockPersistentSubscriptions_ReadServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPersistentSubscriptions_ReadServer) Recv 

func (m *MockPersistentSubscriptions_ReadServer) Recv() (*ReadReq, error)

Recv mocks base method.

func (*MockPersistentSubscriptions_ReadServer) RecvMsg 

func (m_2 *MockPersistentSubscriptions_ReadServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockPersistentSubscriptions_ReadServer) Send 

func (m *MockPersistentSubscriptions_ReadServer) Send(arg0 *ReadResp) error

Send mocks base method.

func (*MockPersistentSubscriptions_ReadServer) SendHeader 

func (m *MockPersistentSubscriptions_ReadServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockPersistentSubscriptions_ReadServer) SendMsg 

func (m_2 *MockPersistentSubscriptions_ReadServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockPersistentSubscriptions_ReadServer) SetHeader 

func (m *MockPersistentSubscriptions_ReadServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockPersistentSubscriptions_ReadServer) SetTrailer 

func (m *MockPersistentSubscriptions_ReadServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockPersistentSubscriptions_ReadServerMockRecorder 

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

MockPersistentSubscriptions_ReadServerMockRecorder is the mock recorder for MockPersistentSubscriptions_ReadServer.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) Context 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) Recv 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) RecvMsg 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) Send 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) SendHeader 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) SendMsg 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) SetHeader 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockPersistentSubscriptions_ReadServerMockRecorder) SetTrailer 

func (mr *MockPersistentSubscriptions_ReadServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafePersistentSubscriptionsServer 

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

MockUnsafePersistentSubscriptionsServer is a mock of UnsafePersistentSubscriptionsServer interface.

func NewMockUnsafePersistentSubscriptionsServer 

func NewMockUnsafePersistentSubscriptionsServer(ctrl *gomock.Controller) *MockUnsafePersistentSubscriptionsServer

NewMockUnsafePersistentSubscriptionsServer creates a new mock instance.

func (*MockUnsafePersistentSubscriptionsServer) EXPECT 

func (m *MockUnsafePersistentSubscriptionsServer) EXPECT() *MockUnsafePersistentSubscriptionsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafePersistentSubscriptionsServerMockRecorder 

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

MockUnsafePersistentSubscriptionsServerMockRecorder is the mock recorder for MockUnsafePersistentSubscriptionsServer.

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

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
	// 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 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) Read 

func (UnimplementedPersistentSubscriptionsServer) Read(PersistentSubscriptions_ReadServer) 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: 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 (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: 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

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.