eventsv1alpha1

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnsureStreamRequest_DiscardPolicy_name = map[int32]string{
		0: "DISCARD_POLICY_UNSPECIFIED",
		1: "DISCARD_POLICY_OLD",
		2: "DISCARD_POLICY_NEW",
	}
	EnsureStreamRequest_DiscardPolicy_value = map[string]int32{
		"DISCARD_POLICY_UNSPECIFIED": 0,
		"DISCARD_POLICY_OLD":         1,
		"DISCARD_POLICY_NEW":         2,
	}
)

Enum value maps for EnsureStreamRequest_DiscardPolicy.

View Source 
var (
	EnsureStreamRequest_StorageType_name = map[int32]string{
		0: "STORAGE_TYPE_UNSPECIFIED",
		1: "STORAGE_TYPE_FILE",
		2: "STORAGE_TYPE_MEMORY",
	}
	EnsureStreamRequest_StorageType_value = map[string]int32{
		"STORAGE_TYPE_UNSPECIFIED": 0,
		"STORAGE_TYPE_FILE":        1,
		"STORAGE_TYPE_MEMORY":      2,
	}
)

Enum value maps for EnsureStreamRequest_StorageType.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "windshift.events.v1alpha1.EventsService",
	HandlerType: (*EventsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EnsureStream",
			Handler:    _EventsService_EnsureStream_Handler,
		},
		{
			MethodName: "EnsureConsumer",
			Handler:    _EventsService_EnsureConsumer_Handler,
		},
		{
			MethodName: "DeleteConsumer",
			Handler:    _EventsService_DeleteConsumer_Handler,
		},
		{
			MethodName: "PublishEvent",
			Handler:    _EventsService_PublishEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _EventsService_Events_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "windshift/events/v1alpha1/service.proto",
}

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

View Source 
var File_windshift_events_v1alpha1_service_proto protoreflect.FileDescriptor

Functions

func RegisterEventsServiceServer 

func RegisterEventsServiceServer(s grpc.ServiceRegistrar, srv EventsServiceServer)

Types

type DeleteConsumerRequest 

type DeleteConsumerRequest struct {

	// The event stream to delete the consumer from. The stream must already
	// exist.
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// The id of the consumer to delete. The consumer must already exist.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a consumer.

func (*DeleteConsumerRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerRequest.ProtoReflect.Descriptor instead.

func (*DeleteConsumerRequest) GetId 

func (x *DeleteConsumerRequest) GetId() string

func (*DeleteConsumerRequest) GetStream 

func (x *DeleteConsumerRequest) GetStream() string

func (*DeleteConsumerRequest) MarshalToSizedBufferVT 

func (m *DeleteConsumerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteConsumerRequest) MarshalToVT 

func (m *DeleteConsumerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteConsumerRequest) MarshalVT 

func (m *DeleteConsumerRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteConsumerRequest) ProtoMessage 

func (*DeleteConsumerRequest) ProtoMessage()

func (*DeleteConsumerRequest) ProtoReflect 

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

func (*DeleteConsumerRequest) Reset 

func (x *DeleteConsumerRequest) Reset()

func (*DeleteConsumerRequest) SizeVT 

func (m *DeleteConsumerRequest) SizeVT() (n int)

func (*DeleteConsumerRequest) String 

func (x *DeleteConsumerRequest) String() string

func (*DeleteConsumerRequest) UnmarshalVT 

func (m *DeleteConsumerRequest) UnmarshalVT(dAtA []byte) error

type DeleteConsumerResponse 

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

Response to deleting a consumer.

func (*DeleteConsumerResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerResponse.ProtoReflect.Descriptor instead.

func (*DeleteConsumerResponse) MarshalToSizedBufferVT 

func (m *DeleteConsumerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteConsumerResponse) MarshalToVT 

func (m *DeleteConsumerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteConsumerResponse) MarshalVT 

func (m *DeleteConsumerResponse) MarshalVT() (dAtA []byte, err error)

func (*DeleteConsumerResponse) ProtoMessage 

func (*DeleteConsumerResponse) ProtoMessage()

func (*DeleteConsumerResponse) ProtoReflect 

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

func (*DeleteConsumerResponse) Reset 

func (x *DeleteConsumerResponse) Reset()

func (*DeleteConsumerResponse) SizeVT 

func (m *DeleteConsumerResponse) SizeVT() (n int)

func (*DeleteConsumerResponse) String 

func (x *DeleteConsumerResponse) String() string

func (*DeleteConsumerResponse) UnmarshalVT 

func (m *DeleteConsumerResponse) UnmarshalVT(dAtA []byte) error

type EnsureConsumerRequest 

type EnsureConsumerRequest struct {

	// The event stream to consume events from. The stream must already exist.
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// The name of the consumer, should be unique to stream if provided,
	// providing one creates a durable consumer which supports resumption and
	// shared processing of events.
	//
	// If not provided the consumer will be ephemeral and will not be able to
	// resume or share processing of events.
	//
	// When a name is specified it is case-sensitive and should only
	// contain the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//   - `_` and `-` are allowed for separating words, but the use of camelCase
	//     is recommended.
	Name *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// The subjects to subscribe to. Subjects are case-sensitive and should only
	// contain the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//
	//   - `_` and `-` are allowed for separating words, but the use of camelCase
	//     is recommended.
	//
	//   - `.` is allowed and used as a hierarchy separator, such as
	//     `time.us.east` and `time.eu.sweden`, which share the `time`
	//     prefix.
	//
	//   - `*` matches a single token, at any level of the subject. Such as
	//     `time.*.east` will match `time.us.east` and `time.eu.east` but not
	//     `time.us.west` or `time.us.central.east`. Similarly `time.us.*` will
	//     match `time.us.east` but not `time.us.east.atlanta`.
	//
	//     The `*` wildcard can be used multiple times in a subject, such as
	//     `time.*.*` will match `time.us.east` and `time.eu.west` but not
	//     `time.us.east.atlanta`.
	//   - `>` matches one or more tokens at the tail of a subject, and can only
	//     be used as the last token. Such as `time.us.>` will match
	//     `time.us.east` and `time.us.east.atlanta` but not `time.eu.east`.
	//
	// See NATS concepts: https://docs.nats.io/nats-concepts/subjects
	Subjects []string `protobuf:"bytes,3,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// The pointer to start receiving events from. Used to control how this
	// subscriber will receive old events.
	//
	// Defaults to new events if not provided.
	From *StreamPointer `protobuf:"bytes,4,opt,name=from,proto3,oneof" json:"from,omitempty"`
	// The timeout for events, after which they will be resent.
	//
	// Events will need to be acknowledged, rejected or pinged before the
	// timeout expires, otherwise they will be marked as failed and queued
	// for delivery again.
	//
	// Defaults to 30 seconds if not provided.
	ProcessingTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=processing_timeout,json=processingTimeout,proto3,oneof" json:"processing_timeout,omitempty"`
	// contains filtered or unexported fields
}

Request to create or update a consumer. Consumers are managed by the programs that use them, and this event is commonly sent at the start of a program to ensure that the consumer exists.

func (*EnsureConsumerRequest) Descriptor deprecated 

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

Deprecated: Use EnsureConsumerRequest.ProtoReflect.Descriptor instead.

func (*EnsureConsumerRequest) GetFrom 

func (x *EnsureConsumerRequest) GetFrom() *StreamPointer

func (*EnsureConsumerRequest) GetName 

func (x *EnsureConsumerRequest) GetName() string

func (*EnsureConsumerRequest) GetProcessingTimeout 

func (x *EnsureConsumerRequest) GetProcessingTimeout() *durationpb.Duration

func (*EnsureConsumerRequest) GetStream 

func (x *EnsureConsumerRequest) GetStream() string

func (*EnsureConsumerRequest) GetSubjects 

func (x *EnsureConsumerRequest) GetSubjects() []string

func (*EnsureConsumerRequest) MarshalToSizedBufferVT 

func (m *EnsureConsumerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureConsumerRequest) MarshalToVT 

func (m *EnsureConsumerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureConsumerRequest) MarshalVT 

func (m *EnsureConsumerRequest) MarshalVT() (dAtA []byte, err error)

func (*EnsureConsumerRequest) ProtoMessage 

func (*EnsureConsumerRequest) ProtoMessage()

func (*EnsureConsumerRequest) ProtoReflect 

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

func (*EnsureConsumerRequest) Reset 

func (x *EnsureConsumerRequest) Reset()

func (*EnsureConsumerRequest) SizeVT 

func (m *EnsureConsumerRequest) SizeVT() (n int)

func (*EnsureConsumerRequest) String 

func (x *EnsureConsumerRequest) String() string

func (*EnsureConsumerRequest) UnmarshalVT 

func (m *EnsureConsumerRequest) UnmarshalVT(dAtA []byte) error

type EnsureConsumerResponse 

type EnsureConsumerResponse struct {

	// The id of the consumer.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Response to creating or updating a consumer.

func (*EnsureConsumerResponse) Descriptor deprecated 

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

Deprecated: Use EnsureConsumerResponse.ProtoReflect.Descriptor instead.

func (*EnsureConsumerResponse) GetId 

func (x *EnsureConsumerResponse) GetId() string

func (*EnsureConsumerResponse) MarshalToSizedBufferVT 

func (m *EnsureConsumerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureConsumerResponse) MarshalToVT 

func (m *EnsureConsumerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureConsumerResponse) MarshalVT 

func (m *EnsureConsumerResponse) MarshalVT() (dAtA []byte, err error)

func (*EnsureConsumerResponse) ProtoMessage 

func (*EnsureConsumerResponse) ProtoMessage()

func (*EnsureConsumerResponse) ProtoReflect 

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

func (*EnsureConsumerResponse) Reset 

func (x *EnsureConsumerResponse) Reset()

func (*EnsureConsumerResponse) SizeVT 

func (m *EnsureConsumerResponse) SizeVT() (n int)

func (*EnsureConsumerResponse) String 

func (x *EnsureConsumerResponse) String() string

func (*EnsureConsumerResponse) UnmarshalVT 

func (m *EnsureConsumerResponse) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest 

type EnsureStreamRequest struct {

	// Name of the stream. Will be referenced by consumers and subscribers.
	//
	// Names are case-sensitive and should only contain the following
	// characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//   - `_` and `-` are allowed as non-alphanumeric characters for
	//     separating words.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Retention policy for the stream.
	//
	// Defaults to retaining events forever if not provided.
	RetentionPolicy *EnsureStreamRequest_RetentionPolicy `protobuf:"bytes,2,opt,name=retention_policy,json=retentionPolicy,proto3,oneof" json:"retention_policy,omitempty"`
	// Source of events for the stream.
	//
	// Types that are assignable to Source:
	//
	//	*EnsureStreamRequest_Subjects_
	//	*EnsureStreamRequest_Mirror
	//	*EnsureStreamRequest_Aggregate
	Source isEnsureStreamRequest_Source `protobuf_oneof:"source"`
	// Configuration for how the stream should be stored.
	Storage *EnsureStreamRequest_Storage `protobuf:"bytes,6,opt,name=storage,proto3,oneof" json:"storage,omitempty"`
	// The amount of time duplicate detection should be enabled for. This is
	// how long an idempotency key will be stored and checked for.
	//
	// Defaults to 2 minutes if not provided.
	DeduplicationWindow *durationpb.Duration `protobuf:"bytes,7,opt,name=deduplication_window,json=deduplicationWindow,proto3,oneof" json:"deduplication_window,omitempty"`
	// The maximum size of an event in bytes.
	//
	// Defaults to 1 MiB if not provided.
	MaxEventSize *uint32 `protobuf:"varint,8,opt,name=max_event_size,json=maxEventSize,proto3,oneof" json:"max_event_size,omitempty"`
	// contains filtered or unexported fields
}

Request that creates or updates a stream. Commonly called at the start of a program to ensure that the stream exists, or in a declarative way by the admin to ensure that the stream is configured correctly.

func (*EnsureStreamRequest) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest) GetAggregate 

func (x *EnsureStreamRequest) GetAggregate() *EnsureStreamRequest_StreamSources

func (*EnsureStreamRequest) GetDeduplicationWindow 

func (x *EnsureStreamRequest) GetDeduplicationWindow() *durationpb.Duration

func (*EnsureStreamRequest) GetMaxEventSize 

func (x *EnsureStreamRequest) GetMaxEventSize() uint32

func (*EnsureStreamRequest) GetMirror 

func (x *EnsureStreamRequest) GetMirror() *EnsureStreamRequest_StreamSource

func (*EnsureStreamRequest) GetName 

func (x *EnsureStreamRequest) GetName() string

func (*EnsureStreamRequest) GetRetentionPolicy 

func (x *EnsureStreamRequest) GetRetentionPolicy() *EnsureStreamRequest_RetentionPolicy

func (*EnsureStreamRequest) GetSource 

func (m *EnsureStreamRequest) GetSource() isEnsureStreamRequest_Source

func (*EnsureStreamRequest) GetStorage 

func (x *EnsureStreamRequest) GetStorage() *EnsureStreamRequest_Storage

func (*EnsureStreamRequest) GetSubjects 

func (x *EnsureStreamRequest) GetSubjects() *EnsureStreamRequest_Subjects

func (*EnsureStreamRequest) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest) MarshalToVT 

func (m *EnsureStreamRequest) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest) MarshalVT 

func (m *EnsureStreamRequest) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest) ProtoMessage 

func (*EnsureStreamRequest) ProtoMessage()

func (*EnsureStreamRequest) ProtoReflect 

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

func (*EnsureStreamRequest) Reset 

func (x *EnsureStreamRequest) Reset()

func (*EnsureStreamRequest) SizeVT 

func (m *EnsureStreamRequest) SizeVT() (n int)

func (*EnsureStreamRequest) String 

func (x *EnsureStreamRequest) String() string

func (*EnsureStreamRequest) UnmarshalVT 

func (m *EnsureStreamRequest) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_Aggregate 

type EnsureStreamRequest_Aggregate struct {
	// Streams to receive events from.
	Aggregate *EnsureStreamRequest_StreamSources `protobuf:"bytes,5,opt,name=aggregate,proto3,oneof"`
}

func (*EnsureStreamRequest_Aggregate) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_Aggregate) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Aggregate) MarshalToVT 

func (m *EnsureStreamRequest_Aggregate) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Aggregate) SizeVT 

func (m *EnsureStreamRequest_Aggregate) SizeVT() (n int)

type EnsureStreamRequest_DiscardPolicy 

type EnsureStreamRequest_DiscardPolicy int32

Policy to use when discarding events when the stream is full. 

const (
	EnsureStreamRequest_DISCARD_POLICY_UNSPECIFIED EnsureStreamRequest_DiscardPolicy = 0
	// Discard old events when the stream is full.
	EnsureStreamRequest_DISCARD_POLICY_OLD EnsureStreamRequest_DiscardPolicy = 1
	// Discard new events when the stream is full.
	EnsureStreamRequest_DISCARD_POLICY_NEW EnsureStreamRequest_DiscardPolicy = 2
)

func (EnsureStreamRequest_DiscardPolicy) Descriptor 

func (EnsureStreamRequest_DiscardPolicy) Descriptor() protoreflect.EnumDescriptor

func (EnsureStreamRequest_DiscardPolicy) Enum 

func (x EnsureStreamRequest_DiscardPolicy) Enum() *EnsureStreamRequest_DiscardPolicy

func (EnsureStreamRequest_DiscardPolicy) EnumDescriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_DiscardPolicy.Descriptor instead.

func (EnsureStreamRequest_DiscardPolicy) Number 

func (x EnsureStreamRequest_DiscardPolicy) Number() protoreflect.EnumNumber

func (EnsureStreamRequest_DiscardPolicy) String 

func (x EnsureStreamRequest_DiscardPolicy) String() string

func (EnsureStreamRequest_DiscardPolicy) Type 

func (EnsureStreamRequest_DiscardPolicy) Type() protoreflect.EnumType

type EnsureStreamRequest_Mirror 

type EnsureStreamRequest_Mirror struct {
	// Stream to mirror. If set can not be changed.
	Mirror *EnsureStreamRequest_StreamSource `protobuf:"bytes,4,opt,name=mirror,proto3,oneof"`
}

func (*EnsureStreamRequest_Mirror) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_Mirror) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Mirror) MarshalToVT 

func (m *EnsureStreamRequest_Mirror) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Mirror) SizeVT 

func (m *EnsureStreamRequest_Mirror) SizeVT() (n int)

type EnsureStreamRequest_RetentionPolicy 

type EnsureStreamRequest_RetentionPolicy struct {

	// Maximum age of events in the stream. Events older than this will be
	// deleted.
	//
	// No default, if not provided events will not be deleted based on age.
	MaxAge *durationpb.Duration `protobuf:"bytes,1,opt,name=max_age,json=maxAge,proto3,oneof" json:"max_age,omitempty"`
	// Maximum number of events in the stream. Events beyond this limit will
	// be deleted.
	//
	// No default, if not provided events will not be deleted based on
	// count.
	MaxEvents *uint64 `protobuf:"varint,2,opt,name=max_events,json=maxEvents,proto3,oneof" json:"max_events,omitempty"`
	// Maximum number of events per subject in the stream. Events beyond
	// this limit will be deleted.
	//
	// No default, if not provided events will not be deleted based on
	// count.
	MaxEventsPerSubject *uint64 `` /* 129-byte string literal not displayed */
	// Maximum total byte size of all events in the stream. Events beyond
	// this limit will be deleted.
	//
	// No default, if not provided events will not be deleted based on size.
	MaxBytes *uint64 `protobuf:"varint,4,opt,name=max_bytes,json=maxBytes,proto3,oneof" json:"max_bytes,omitempty"`
	// Policy to use when discarding events the stream is full.
	//
	// Defaults to discarding old events if not provided.
	DiscardPolicy *EnsureStreamRequest_DiscardPolicy `` /* 172-byte string literal not displayed */
	// If discard policy is set to discard new events, settings this to
	// true will discard new events per subject instead of globally.
	//
	// Defaults to false if not provided.
	DiscardNewPerSubject *bool `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Policy for how events in the stream should be retained.

func (*EnsureStreamRequest_RetentionPolicy) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_RetentionPolicy.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest_RetentionPolicy) GetDiscardNewPerSubject 

func (x *EnsureStreamRequest_RetentionPolicy) GetDiscardNewPerSubject() bool

func (*EnsureStreamRequest_RetentionPolicy) GetDiscardPolicy 

func (x *EnsureStreamRequest_RetentionPolicy) GetDiscardPolicy() EnsureStreamRequest_DiscardPolicy

func (*EnsureStreamRequest_RetentionPolicy) GetMaxAge 

func (x *EnsureStreamRequest_RetentionPolicy) GetMaxAge() *durationpb.Duration

func (*EnsureStreamRequest_RetentionPolicy) GetMaxBytes 

func (x *EnsureStreamRequest_RetentionPolicy) GetMaxBytes() uint64

func (*EnsureStreamRequest_RetentionPolicy) GetMaxEvents 

func (x *EnsureStreamRequest_RetentionPolicy) GetMaxEvents() uint64

func (*EnsureStreamRequest_RetentionPolicy) GetMaxEventsPerSubject 

func (x *EnsureStreamRequest_RetentionPolicy) GetMaxEventsPerSubject() uint64

func (*EnsureStreamRequest_RetentionPolicy) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_RetentionPolicy) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_RetentionPolicy) MarshalToVT 

func (m *EnsureStreamRequest_RetentionPolicy) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_RetentionPolicy) MarshalVT 

func (m *EnsureStreamRequest_RetentionPolicy) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest_RetentionPolicy) ProtoMessage 

func (*EnsureStreamRequest_RetentionPolicy) ProtoMessage()

func (*EnsureStreamRequest_RetentionPolicy) ProtoReflect 

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

func (*EnsureStreamRequest_RetentionPolicy) Reset 

func (x *EnsureStreamRequest_RetentionPolicy) Reset()

func (*EnsureStreamRequest_RetentionPolicy) SizeVT 

func (m *EnsureStreamRequest_RetentionPolicy) SizeVT() (n int)

func (*EnsureStreamRequest_RetentionPolicy) String 

func (x *EnsureStreamRequest_RetentionPolicy) String() string

func (*EnsureStreamRequest_RetentionPolicy) UnmarshalVT 

func (m *EnsureStreamRequest_RetentionPolicy) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_Storage 

type EnsureStreamRequest_Storage struct {

	// The type of storage to use for the stream.
	//
	// Defaults to file based storage if not provided.
	Type *EnsureStreamRequest_StorageType `` /* 131-byte string literal not displayed */
	// Number of replicas to use for the stream.
	//
	// Defaults to 1 if not provided.
	Replicas *uint32 `protobuf:"varint,2,opt,name=replicas,proto3,oneof" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

Define how the stream should be stored.

func (*EnsureStreamRequest_Storage) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_Storage.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest_Storage) GetReplicas 

func (x *EnsureStreamRequest_Storage) GetReplicas() uint32

func (*EnsureStreamRequest_Storage) GetType 

func (x *EnsureStreamRequest_Storage) GetType() EnsureStreamRequest_StorageType

func (*EnsureStreamRequest_Storage) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_Storage) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Storage) MarshalToVT 

func (m *EnsureStreamRequest_Storage) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Storage) MarshalVT 

func (m *EnsureStreamRequest_Storage) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest_Storage) ProtoMessage 

func (*EnsureStreamRequest_Storage) ProtoMessage()

func (*EnsureStreamRequest_Storage) ProtoReflect 

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

func (*EnsureStreamRequest_Storage) Reset 

func (x *EnsureStreamRequest_Storage) Reset()

func (*EnsureStreamRequest_Storage) SizeVT 

func (m *EnsureStreamRequest_Storage) SizeVT() (n int)

func (*EnsureStreamRequest_Storage) String 

func (x *EnsureStreamRequest_Storage) String() string

func (*EnsureStreamRequest_Storage) UnmarshalVT 

func (m *EnsureStreamRequest_Storage) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_StorageType 

type EnsureStreamRequest_StorageType int32

Type of storage to use for the stream. 

const (
	// Unspecified storage type, will default to file based storage.
	EnsureStreamRequest_STORAGE_TYPE_UNSPECIFIED EnsureStreamRequest_StorageType = 0
	// Use a file based storage.
	EnsureStreamRequest_STORAGE_TYPE_FILE EnsureStreamRequest_StorageType = 1
	// Use a memory based storage.
	EnsureStreamRequest_STORAGE_TYPE_MEMORY EnsureStreamRequest_StorageType = 2
)

func (EnsureStreamRequest_StorageType) Descriptor 

func (EnsureStreamRequest_StorageType) Descriptor() protoreflect.EnumDescriptor

func (EnsureStreamRequest_StorageType) Enum 

func (x EnsureStreamRequest_StorageType) Enum() *EnsureStreamRequest_StorageType

func (EnsureStreamRequest_StorageType) EnumDescriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_StorageType.Descriptor instead.

func (EnsureStreamRequest_StorageType) Number 

func (x EnsureStreamRequest_StorageType) Number() protoreflect.EnumNumber

func (EnsureStreamRequest_StorageType) String 

func (x EnsureStreamRequest_StorageType) String() string

func (EnsureStreamRequest_StorageType) Type 

func (EnsureStreamRequest_StorageType) Type() protoreflect.EnumType

type EnsureStreamRequest_StreamSource 

type EnsureStreamRequest_StreamSource struct {

	// Stream to receive events from. The stream must already exist.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optionally define where to start receiving events from.
	//
	// Defaults to the start of stream if not provided.
	From *StreamPointer `protobuf:"bytes,2,opt,name=from,proto3,oneof" json:"from,omitempty"`
	// Optionally filter events by subject. Subjects are case-sensitive and
	// should only contain the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//
	//   - `_` and `-` are allowed for separating words, but the use of
	//     camelCase is recommended.
	//
	//   - `.` is allowed and used as a hierarchy separator, such as
	//     `time.us.east` and `time.eu.sweden`, which share the `time`
	//     prefix.
	//
	//   - `*` matches a single token, at any level of the subject. Such as
	//     `time.*.east` will match `time.us.east` and `time.eu.east` but
	//     not `time.us.west` or `time.us.central.east`. Similarly `time.us.*`
	//     will match `time.us.east` but not `time.us.east.atlanta`.
	//
	//     The `*` wildcard can be used multiple times in a subject, such as
	//     `time.*.*` will match `time.us.east` and `time.eu.west` but not
	//     `time.us.east.atlanta`.
	//   - `>` matches one or more tokens at the tail of a subject, and can
	//     only be used as the last token. Such as `time.us.>` will match
	//     `time.us.east` and `time.us.east.atlanta` but not `time.eu.east`.
	//
	// See NATS concepts: https://docs.nats.io/nats-concepts/subjects
	FilterSubjects []string `protobuf:"bytes,3,rep,name=filter_subjects,json=filterSubjects,proto3" json:"filter_subjects,omitempty"`
	// contains filtered or unexported fields
}

Source describing mirroring/aggregation of events from another stream into this stream.

func (*EnsureStreamRequest_StreamSource) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_StreamSource.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest_StreamSource) GetFilterSubjects 

func (x *EnsureStreamRequest_StreamSource) GetFilterSubjects() []string

func (*EnsureStreamRequest_StreamSource) GetFrom 

func (x *EnsureStreamRequest_StreamSource) GetFrom() *StreamPointer

func (*EnsureStreamRequest_StreamSource) GetName 

func (x *EnsureStreamRequest_StreamSource) GetName() string

func (*EnsureStreamRequest_StreamSource) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_StreamSource) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_StreamSource) MarshalToVT 

func (m *EnsureStreamRequest_StreamSource) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_StreamSource) MarshalVT 

func (m *EnsureStreamRequest_StreamSource) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest_StreamSource) ProtoMessage 

func (*EnsureStreamRequest_StreamSource) ProtoMessage()

func (*EnsureStreamRequest_StreamSource) ProtoReflect 

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

func (*EnsureStreamRequest_StreamSource) Reset 

func (x *EnsureStreamRequest_StreamSource) Reset()

func (*EnsureStreamRequest_StreamSource) SizeVT 

func (m *EnsureStreamRequest_StreamSource) SizeVT() (n int)

func (*EnsureStreamRequest_StreamSource) String 

func (x *EnsureStreamRequest_StreamSource) String() string

func (*EnsureStreamRequest_StreamSource) UnmarshalVT 

func (m *EnsureStreamRequest_StreamSource) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_StreamSources 

type EnsureStreamRequest_StreamSources struct {

	// The streams to receive events from.
	Sources []*EnsureStreamRequest_StreamSource `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	// contains filtered or unexported fields
}

Multiple streams that can be mirrored into the stream.

func (*EnsureStreamRequest_StreamSources) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_StreamSources.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest_StreamSources) GetSources 

func (x *EnsureStreamRequest_StreamSources) GetSources() []*EnsureStreamRequest_StreamSource

func (*EnsureStreamRequest_StreamSources) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_StreamSources) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_StreamSources) MarshalToVT 

func (m *EnsureStreamRequest_StreamSources) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_StreamSources) MarshalVT 

func (m *EnsureStreamRequest_StreamSources) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest_StreamSources) ProtoMessage 

func (*EnsureStreamRequest_StreamSources) ProtoMessage()

func (*EnsureStreamRequest_StreamSources) ProtoReflect 

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

func (*EnsureStreamRequest_StreamSources) Reset 

func (x *EnsureStreamRequest_StreamSources) Reset()

func (*EnsureStreamRequest_StreamSources) SizeVT 

func (m *EnsureStreamRequest_StreamSources) SizeVT() (n int)

func (*EnsureStreamRequest_StreamSources) String 

func (x *EnsureStreamRequest_StreamSources) String() string

func (*EnsureStreamRequest_StreamSources) UnmarshalVT 

func (m *EnsureStreamRequest_StreamSources) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_Subjects 

type EnsureStreamRequest_Subjects struct {

	// List of subjects. Subjects are case-sensitive and should only
	// contain the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//
	//   - `_` and `-` are allowed for separating words, but the use of
	//     camelCase is recommended.
	//
	//   - `.` is allowed and used as a hierarchy separator, such as
	//     `time.us.east` and `time.eu.sweden`, which share the `time`
	//     prefix.
	//
	//   - `*` matches a single token, at any level of the subject. Such as
	//     `time.*.east` will match `time.us.east` and `time.eu.east` but
	//     not `time.us.west` or `time.us.central.east`. Similarly `time.us.*`
	//     will match `time.us.east` but not `time.us.east.atlanta`.
	//
	//     The `*` wildcard can be used multiple times in a subject, such as
	//     `time.*.*` will match `time.us.east` and `time.eu.west` but not
	//     `time.us.east.atlanta`.
	//   - `>` matches one or more tokens at the tail of a subject, and can
	//     only be used as the last token. Such as `time.us.>` will match
	//     `time.us.east` and `time.us.east.atlanta` but not `time.eu.east`.
	//
	// See NATS concepts: https://docs.nats.io/nats-concepts/subjects
	Subjects []string `protobuf:"bytes,1,rep,name=subjects,proto3" json:"subjects,omitempty"`
	// contains filtered or unexported fields
}

List of subjects that will be collected into the stream.

func (*EnsureStreamRequest_Subjects) Descriptor deprecated 

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

Deprecated: Use EnsureStreamRequest_Subjects.ProtoReflect.Descriptor instead.

func (*EnsureStreamRequest_Subjects) GetSubjects 

func (x *EnsureStreamRequest_Subjects) GetSubjects() []string

func (*EnsureStreamRequest_Subjects) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_Subjects) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Subjects) MarshalToVT 

func (m *EnsureStreamRequest_Subjects) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Subjects) MarshalVT 

func (m *EnsureStreamRequest_Subjects) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamRequest_Subjects) ProtoMessage 

func (*EnsureStreamRequest_Subjects) ProtoMessage()

func (*EnsureStreamRequest_Subjects) ProtoReflect 

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

func (*EnsureStreamRequest_Subjects) Reset 

func (x *EnsureStreamRequest_Subjects) Reset()

func (*EnsureStreamRequest_Subjects) SizeVT 

func (m *EnsureStreamRequest_Subjects) SizeVT() (n int)

func (*EnsureStreamRequest_Subjects) String 

func (x *EnsureStreamRequest_Subjects) String() string

func (*EnsureStreamRequest_Subjects) UnmarshalVT 

func (m *EnsureStreamRequest_Subjects) UnmarshalVT(dAtA []byte) error

type EnsureStreamRequest_Subjects_ 

type EnsureStreamRequest_Subjects_ struct {
	// Subjects to collect events for.
	Subjects *EnsureStreamRequest_Subjects `protobuf:"bytes,3,opt,name=subjects,proto3,oneof"`
}

func (*EnsureStreamRequest_Subjects_) MarshalToSizedBufferVT 

func (m *EnsureStreamRequest_Subjects_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Subjects_) MarshalToVT 

func (m *EnsureStreamRequest_Subjects_) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamRequest_Subjects_) SizeVT 

func (m *EnsureStreamRequest_Subjects_) SizeVT() (n int)

type EnsureStreamResponse 

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

Response to creating or updating a stream.

func (*EnsureStreamResponse) Descriptor deprecated 

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

Deprecated: Use EnsureStreamResponse.ProtoReflect.Descriptor instead.

func (*EnsureStreamResponse) MarshalToSizedBufferVT 

func (m *EnsureStreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnsureStreamResponse) MarshalToVT 

func (m *EnsureStreamResponse) MarshalToVT(dAtA []byte) (int, error)

func (*EnsureStreamResponse) MarshalVT 

func (m *EnsureStreamResponse) MarshalVT() (dAtA []byte, err error)

func (*EnsureStreamResponse) ProtoMessage 

func (*EnsureStreamResponse) ProtoMessage()

func (*EnsureStreamResponse) ProtoReflect 

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

func (*EnsureStreamResponse) Reset 

func (x *EnsureStreamResponse) Reset()

func (*EnsureStreamResponse) SizeVT 

func (m *EnsureStreamResponse) SizeVT() (n int)

func (*EnsureStreamResponse) String 

func (x *EnsureStreamResponse) String() string

func (*EnsureStreamResponse) UnmarshalVT 

func (m *EnsureStreamResponse) UnmarshalVT(dAtA []byte) error

type Event 

type Event struct {

	// Identifier of the event, used to acknowledge, reject or ping the event.
	// Can also be used to resume processing of events if using an ephemeral
	// subscriber.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The subject of this event.
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	// Headers of the event.
	Headers *Headers `protobuf:"bytes,3,opt,name=headers,proto3" json:"headers,omitempty"`
	// Data of the event. The data is dynamic and it is up to the publisher
	// and subscriber to agree on the Protobuf messages to support.
	//
	// Each subject can support several different types of data, which can be
	// useful to support different versions of the data. Subscribers should
	// ignore data they do not understand.
	Data *anypb.Any `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// The delivery attempt this is. Starts at 1 and increases for each
	// redelivery of the event.
	DeliveryAttempt uint64 `protobuf:"varint,5,opt,name=delivery_attempt,json=deliveryAttempt,proto3" json:"delivery_attempt,omitempty"`
	// contains filtered or unexported fields
}

Event that was published and sent to a subscriber.

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData 

func (x *Event) GetData() *anypb.Any

func (*Event) GetDeliveryAttempt 

func (x *Event) GetDeliveryAttempt() uint64

func (*Event) GetHeaders 

func (x *Event) GetHeaders() *Headers

func (*Event) GetId 

func (x *Event) GetId() uint64

func (*Event) GetSubject 

func (x *Event) GetSubject() string

func (*Event) MarshalToSizedBufferVT 

func (m *Event) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Event) MarshalToVT 

func (m *Event) MarshalToVT(dAtA []byte) (int, error)

func (*Event) MarshalVT 

func (m *Event) MarshalVT() (dAtA []byte, err error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) SizeVT 

func (m *Event) SizeVT() (n int)

func (*Event) String 

func (x *Event) String() string

func (*Event) UnmarshalVT 

func (m *Event) UnmarshalVT(dAtA []byte) error

type EventsRequest 

type EventsRequest struct {

	// Types that are assignable to Request:
	//
	//	*EventsRequest_Subscribe_
	//	*EventsRequest_Ack_
	//	*EventsRequest_Reject_
	//	*EventsRequest_Ping_
	Request isEventsRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

Request to subscribe to events or to acknowledge, reject or ping events. The first message sent on the stream must be a Subscribe message, after which the client can send Ack, Reject or Ping messages.

Events should be either acknowledged or rejected, otherwise they will be resent after a timeout. If processing takes of an event takes a while pings should be sent to indicate that the event is still being processed.

func (*EventsRequest) Descriptor deprecated 

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

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetAck 

func (x *EventsRequest) GetAck() *EventsRequest_Ack

func (*EventsRequest) GetPing 

func (x *EventsRequest) GetPing() *EventsRequest_Ping

func (*EventsRequest) GetReject 

func (x *EventsRequest) GetReject() *EventsRequest_Reject

func (*EventsRequest) GetRequest 

func (m *EventsRequest) GetRequest() isEventsRequest_Request

func (*EventsRequest) GetSubscribe 

func (x *EventsRequest) GetSubscribe() *EventsRequest_Subscribe

func (*EventsRequest) MarshalToSizedBufferVT 

func (m *EventsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest) MarshalToVT 

func (m *EventsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest) MarshalVT 

func (m *EventsRequest) MarshalVT() (dAtA []byte, err error)

func (*EventsRequest) ProtoMessage 

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) ProtoReflect 

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

func (*EventsRequest) Reset 

func (x *EventsRequest) Reset()

func (*EventsRequest) SizeVT 

func (m *EventsRequest) SizeVT() (n int)

func (*EventsRequest) String 

func (x *EventsRequest) String() string

func (*EventsRequest) UnmarshalVT 

func (m *EventsRequest) UnmarshalVT(dAtA []byte) error

type EventsRequest_Ack 

type EventsRequest_Ack struct {

	// The identifiers to acknowledge.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

Ack indicates that some events have been successfully processed.

func (*EventsRequest_Ack) Descriptor deprecated 

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

Deprecated: Use EventsRequest_Ack.ProtoReflect.Descriptor instead.

func (*EventsRequest_Ack) GetIds 

func (x *EventsRequest_Ack) GetIds() []uint64

func (*EventsRequest_Ack) MarshalToSizedBufferVT 

func (m *EventsRequest_Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Ack) MarshalToVT 

func (m *EventsRequest_Ack) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Ack) MarshalVT 

func (m *EventsRequest_Ack) MarshalVT() (dAtA []byte, err error)

func (*EventsRequest_Ack) ProtoMessage 

func (*EventsRequest_Ack) ProtoMessage()

func (*EventsRequest_Ack) ProtoReflect 

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

func (*EventsRequest_Ack) Reset 

func (x *EventsRequest_Ack) Reset()

func (*EventsRequest_Ack) SizeVT 

func (m *EventsRequest_Ack) SizeVT() (n int)

func (*EventsRequest_Ack) String 

func (x *EventsRequest_Ack) String() string

func (*EventsRequest_Ack) UnmarshalVT 

func (m *EventsRequest_Ack) UnmarshalVT(dAtA []byte) error

type EventsRequest_Ack_ 

type EventsRequest_Ack_ struct {
	// Acknowledge that some events have been successfully processed. When
	// an event is acknowledged a ConsumeResponse.AckConfirmation message
	// will be sent in response.
	Ack *EventsRequest_Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

func (*EventsRequest_Ack_) MarshalToSizedBufferVT 

func (m *EventsRequest_Ack_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Ack_) MarshalToVT 

func (m *EventsRequest_Ack_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Ack_) SizeVT 

func (m *EventsRequest_Ack_) SizeVT() (n int)

type EventsRequest_Ping 

type EventsRequest_Ping struct {

	// The identifiers of the events that are currently being processed.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

Ping events to indicate that they are still being processed. Pings should be sent regularly to indicate that the events are still being processed. It is recommended to send pings at half the interval of the processing timeout.

func (*EventsRequest_Ping) Descriptor deprecated 

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

Deprecated: Use EventsRequest_Ping.ProtoReflect.Descriptor instead.

func (*EventsRequest_Ping) GetIds 

func (x *EventsRequest_Ping) GetIds() []uint64

func (*EventsRequest_Ping) MarshalToSizedBufferVT 

func (m *EventsRequest_Ping) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Ping) MarshalToVT 

func (m *EventsRequest_Ping) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Ping) MarshalVT 

func (m *EventsRequest_Ping) MarshalVT() (dAtA []byte, err error)

func (*EventsRequest_Ping) ProtoMessage 

func (*EventsRequest_Ping) ProtoMessage()

func (*EventsRequest_Ping) ProtoReflect 

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

func (*EventsRequest_Ping) Reset 

func (x *EventsRequest_Ping) Reset()

func (*EventsRequest_Ping) SizeVT 

func (m *EventsRequest_Ping) SizeVT() (n int)

func (*EventsRequest_Ping) String 

func (x *EventsRequest_Ping) String() string

func (*EventsRequest_Ping) UnmarshalVT 

func (m *EventsRequest_Ping) UnmarshalVT(dAtA []byte) error

type EventsRequest_Ping_ 

type EventsRequest_Ping_ struct {
	// Ping events to indicate that they are still being processed. When
	// an event is pinged a ConsumeResponse.PingConfirmation message will
	// be sent in response.
	Ping *EventsRequest_Ping `protobuf:"bytes,4,opt,name=ping,proto3,oneof"`
}

func (*EventsRequest_Ping_) MarshalToSizedBufferVT 

func (m *EventsRequest_Ping_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Ping_) MarshalToVT 

func (m *EventsRequest_Ping_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Ping_) SizeVT 

func (m *EventsRequest_Ping_) SizeVT() (n int)

type EventsRequest_Reject 

type EventsRequest_Reject struct {

	// The identifiers to reject.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// Permanently reject the events, if not provided the events will be
	// retried after a timeout. If permanently is set to true, the events
	// will not be redelivered.
	//
	// Can not be combined with delay.
	Permanently *bool `protobuf:"varint,2,opt,name=permanently,proto3,oneof" json:"permanently,omitempty"`
	// Optional time to wait before redelivering the events. If not
	// provided the server will decide how long to wait.
	//
	// Can not be combined with permanently.
	Delay *durationpb.Duration `protobuf:"bytes,3,opt,name=delay,proto3,oneof" json:"delay,omitempty"`
	// contains filtered or unexported fields
}

Reject indicates that some events have failed to be processed.

func (*EventsRequest_Reject) Descriptor deprecated 

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

Deprecated: Use EventsRequest_Reject.ProtoReflect.Descriptor instead.

func (*EventsRequest_Reject) GetDelay 

func (x *EventsRequest_Reject) GetDelay() *durationpb.Duration

func (*EventsRequest_Reject) GetIds 

func (x *EventsRequest_Reject) GetIds() []uint64

func (*EventsRequest_Reject) GetPermanently 

func (x *EventsRequest_Reject) GetPermanently() bool

func (*EventsRequest_Reject) MarshalToSizedBufferVT 

func (m *EventsRequest_Reject) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Reject) MarshalToVT 

func (m *EventsRequest_Reject) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Reject) MarshalVT 

func (m *EventsRequest_Reject) MarshalVT() (dAtA []byte, err error)

func (*EventsRequest_Reject) ProtoMessage 

func (*EventsRequest_Reject) ProtoMessage()

func (*EventsRequest_Reject) ProtoReflect 

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

func (*EventsRequest_Reject) Reset 

func (x *EventsRequest_Reject) Reset()

func (*EventsRequest_Reject) SizeVT 

func (m *EventsRequest_Reject) SizeVT() (n int)

func (*EventsRequest_Reject) String 

func (x *EventsRequest_Reject) String() string

func (*EventsRequest_Reject) UnmarshalVT 

func (m *EventsRequest_Reject) UnmarshalVT(dAtA []byte) error

type EventsRequest_Reject_ 

type EventsRequest_Reject_ struct {
	// Acknowledge that some events have failed to be processed. When an
	// event is rejected a ConsumeResponse.RejectConfirmation message will
	// be sent in response.
	Reject *EventsRequest_Reject `protobuf:"bytes,3,opt,name=reject,proto3,oneof"`
}

func (*EventsRequest_Reject_) MarshalToSizedBufferVT 

func (m *EventsRequest_Reject_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Reject_) MarshalToVT 

func (m *EventsRequest_Reject_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Reject_) SizeVT 

func (m *EventsRequest_Reject_) SizeVT() (n int)

type EventsRequest_Subscribe 

type EventsRequest_Subscribe struct {

	// The name of the stream to subscribe to. The stream must already
	// exist.
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// The name of the consumer, should be an name previously created using
	// EnsureConsumer.
	Consumer string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// The maximum number of events to process at once.
	//
	// In most cases this should be set to approximately the number of
	// events that can be processed in parallel plus a small buffer. The
	// server will ramp up events to this limit, and will only send more
	// events once the client has acknowledged or rejected events.
	//
	// Defaults to 50 if not provided.
	MaxProcessingEvents *uint64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Subscribe to events, must be sent as the first message in the stream.

func (*EventsRequest_Subscribe) Descriptor deprecated 

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

Deprecated: Use EventsRequest_Subscribe.ProtoReflect.Descriptor instead.

func (*EventsRequest_Subscribe) GetConsumer 

func (x *EventsRequest_Subscribe) GetConsumer() string

func (*EventsRequest_Subscribe) GetMaxProcessingEvents 

func (x *EventsRequest_Subscribe) GetMaxProcessingEvents() uint64

func (*EventsRequest_Subscribe) GetStream 

func (x *EventsRequest_Subscribe) GetStream() string

func (*EventsRequest_Subscribe) MarshalToSizedBufferVT 

func (m *EventsRequest_Subscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Subscribe) MarshalToVT 

func (m *EventsRequest_Subscribe) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Subscribe) MarshalVT 

func (m *EventsRequest_Subscribe) MarshalVT() (dAtA []byte, err error)

func (*EventsRequest_Subscribe) ProtoMessage 

func (*EventsRequest_Subscribe) ProtoMessage()

func (*EventsRequest_Subscribe) ProtoReflect 

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

func (*EventsRequest_Subscribe) Reset 

func (x *EventsRequest_Subscribe) Reset()

func (*EventsRequest_Subscribe) SizeVT 

func (m *EventsRequest_Subscribe) SizeVT() (n int)

func (*EventsRequest_Subscribe) String 

func (x *EventsRequest_Subscribe) String() string

func (*EventsRequest_Subscribe) UnmarshalVT 

func (m *EventsRequest_Subscribe) UnmarshalVT(dAtA []byte) error

type EventsRequest_Subscribe_ 

type EventsRequest_Subscribe_ struct {
	// Subscribe to events, must be sent as the first message in the stream
	// to establish what events to listen to.
	//
	// A ConsumeResponse.Subscribed message will be sent in response to
	// this message. If the subscription fails, the stream will be closed.
	Subscribe *EventsRequest_Subscribe `protobuf:"bytes,1,opt,name=subscribe,proto3,oneof"`
}

func (*EventsRequest_Subscribe_) MarshalToSizedBufferVT 

func (m *EventsRequest_Subscribe_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsRequest_Subscribe_) MarshalToVT 

func (m *EventsRequest_Subscribe_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsRequest_Subscribe_) SizeVT 

func (m *EventsRequest_Subscribe_) SizeVT() (n int)

type EventsResponse 

type EventsResponse struct {

	// Types that are assignable to Response:
	//
	//	*EventsResponse_Event
	//	*EventsResponse_Subscribed_
	//	*EventsResponse_AckConfirmation_
	//	*EventsResponse_RejectConfirmation_
	//	*EventsResponse_PingConfirmation_
	Response isEventsResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*EventsResponse) Descriptor deprecated 

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

Deprecated: Use EventsResponse.ProtoReflect.Descriptor instead.

func (*EventsResponse) GetAckConfirmation 

func (x *EventsResponse) GetAckConfirmation() *EventsResponse_AckConfirmation

func (*EventsResponse) GetEvent 

func (x *EventsResponse) GetEvent() *Event

func (*EventsResponse) GetPingConfirmation 

func (x *EventsResponse) GetPingConfirmation() *EventsResponse_PingConfirmation

func (*EventsResponse) GetRejectConfirmation 

func (x *EventsResponse) GetRejectConfirmation() *EventsResponse_RejectConfirmation

func (*EventsResponse) GetResponse 

func (m *EventsResponse) GetResponse() isEventsResponse_Response

func (*EventsResponse) GetSubscribed 

func (x *EventsResponse) GetSubscribed() *EventsResponse_Subscribed

func (*EventsResponse) MarshalToSizedBufferVT 

func (m *EventsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse) MarshalToVT 

func (m *EventsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse) MarshalVT 

func (m *EventsResponse) MarshalVT() (dAtA []byte, err error)

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) ProtoReflect 

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

func (*EventsResponse) Reset 

func (x *EventsResponse) Reset()

func (*EventsResponse) SizeVT 

func (m *EventsResponse) SizeVT() (n int)

func (*EventsResponse) String 

func (x *EventsResponse) String() string

func (*EventsResponse) UnmarshalVT 

func (m *EventsResponse) UnmarshalVT(dAtA []byte) error

type EventsResponse_AckConfirmation 

type EventsResponse_AckConfirmation struct {

	// The identifiers that were acknowledged.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// Identifiers that were invalid, such as already being acknowledged or
	// rejected, should not be retried by the client.
	InvalidIds []uint64 `protobuf:"varint,2,rep,packed,name=invalid_ids,json=invalidIds,proto3" json:"invalid_ids,omitempty"`
	// Identifiers that could not be processed temporarily, should be
	// retried by the client.
	TemporaryFailedIds []uint64 `protobuf:"varint,3,rep,packed,name=temporary_failed_ids,json=temporaryFailedIds,proto3" json:"temporary_failed_ids,omitempty"`
	// contains filtered or unexported fields
}

Confirmation that some events were acknowledged.

func (*EventsResponse_AckConfirmation) Descriptor deprecated 

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

Deprecated: Use EventsResponse_AckConfirmation.ProtoReflect.Descriptor instead.

func (*EventsResponse_AckConfirmation) GetIds 

func (x *EventsResponse_AckConfirmation) GetIds() []uint64

func (*EventsResponse_AckConfirmation) GetInvalidIds 

func (x *EventsResponse_AckConfirmation) GetInvalidIds() []uint64

func (*EventsResponse_AckConfirmation) GetTemporaryFailedIds 

func (x *EventsResponse_AckConfirmation) GetTemporaryFailedIds() []uint64

func (*EventsResponse_AckConfirmation) MarshalToSizedBufferVT 

func (m *EventsResponse_AckConfirmation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_AckConfirmation) MarshalToVT 

func (m *EventsResponse_AckConfirmation) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_AckConfirmation) MarshalVT 

func (m *EventsResponse_AckConfirmation) MarshalVT() (dAtA []byte, err error)

func (*EventsResponse_AckConfirmation) ProtoMessage 

func (*EventsResponse_AckConfirmation) ProtoMessage()

func (*EventsResponse_AckConfirmation) ProtoReflect 

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

func (*EventsResponse_AckConfirmation) Reset 

func (x *EventsResponse_AckConfirmation) Reset()

func (*EventsResponse_AckConfirmation) SizeVT 

func (m *EventsResponse_AckConfirmation) SizeVT() (n int)

func (*EventsResponse_AckConfirmation) String 

func (x *EventsResponse_AckConfirmation) String() string

func (*EventsResponse_AckConfirmation) UnmarshalVT 

func (m *EventsResponse_AckConfirmation) UnmarshalVT(dAtA []byte) error

type EventsResponse_AckConfirmation_ 

type EventsResponse_AckConfirmation_ struct {
	// Confirmation that some events were acknowledged.
	AckConfirmation *EventsResponse_AckConfirmation `protobuf:"bytes,3,opt,name=ack_confirmation,json=ackConfirmation,proto3,oneof"`
}

func (*EventsResponse_AckConfirmation_) MarshalToSizedBufferVT 

func (m *EventsResponse_AckConfirmation_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_AckConfirmation_) MarshalToVT 

func (m *EventsResponse_AckConfirmation_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_AckConfirmation_) SizeVT 

func (m *EventsResponse_AckConfirmation_) SizeVT() (n int)

type EventsResponse_Event 

type EventsResponse_Event struct {
	// An event that was published.
	Event *Event `protobuf:"bytes,1,opt,name=event,proto3,oneof"`
}

func (*EventsResponse_Event) MarshalToSizedBufferVT 

func (m *EventsResponse_Event) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_Event) MarshalToVT 

func (m *EventsResponse_Event) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_Event) SizeVT 

func (m *EventsResponse_Event) SizeVT() (n int)

type EventsResponse_PingConfirmation 

type EventsResponse_PingConfirmation struct {

	// The identifiers of the events that are currently being processed.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// Identifiers that were invalid, such as already being acknowledged or
	// rejected, should not be retried by the client.
	InvalidIds []uint64 `protobuf:"varint,2,rep,packed,name=invalid_ids,json=invalidIds,proto3" json:"invalid_ids,omitempty"`
	// Identifiers that could not be processed temporarily, should be
	// retried by the client.
	TemporaryFailedIds []uint64 `protobuf:"varint,3,rep,packed,name=temporary_failed_ids,json=temporaryFailedIds,proto3" json:"temporary_failed_ids,omitempty"`
	// contains filtered or unexported fields
}

Confirmation that a ping was received.

func (*EventsResponse_PingConfirmation) Descriptor deprecated 

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

Deprecated: Use EventsResponse_PingConfirmation.ProtoReflect.Descriptor instead.

func (*EventsResponse_PingConfirmation) GetIds 

func (x *EventsResponse_PingConfirmation) GetIds() []uint64

func (*EventsResponse_PingConfirmation) GetInvalidIds 

func (x *EventsResponse_PingConfirmation) GetInvalidIds() []uint64

func (*EventsResponse_PingConfirmation) GetTemporaryFailedIds 

func (x *EventsResponse_PingConfirmation) GetTemporaryFailedIds() []uint64

func (*EventsResponse_PingConfirmation) MarshalToSizedBufferVT 

func (m *EventsResponse_PingConfirmation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_PingConfirmation) MarshalToVT 

func (m *EventsResponse_PingConfirmation) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_PingConfirmation) MarshalVT 

func (m *EventsResponse_PingConfirmation) MarshalVT() (dAtA []byte, err error)

func (*EventsResponse_PingConfirmation) ProtoMessage 

func (*EventsResponse_PingConfirmation) ProtoMessage()

func (*EventsResponse_PingConfirmation) ProtoReflect 

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

func (*EventsResponse_PingConfirmation) Reset 

func (x *EventsResponse_PingConfirmation) Reset()

func (*EventsResponse_PingConfirmation) SizeVT 

func (m *EventsResponse_PingConfirmation) SizeVT() (n int)

func (*EventsResponse_PingConfirmation) String 

func (x *EventsResponse_PingConfirmation) String() string

func (*EventsResponse_PingConfirmation) UnmarshalVT 

func (m *EventsResponse_PingConfirmation) UnmarshalVT(dAtA []byte) error

type EventsResponse_PingConfirmation_ 

type EventsResponse_PingConfirmation_ struct {
	// Confirmation that a ping was received.
	PingConfirmation *EventsResponse_PingConfirmation `protobuf:"bytes,5,opt,name=ping_confirmation,json=pingConfirmation,proto3,oneof"`
}

func (*EventsResponse_PingConfirmation_) MarshalToSizedBufferVT 

func (m *EventsResponse_PingConfirmation_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_PingConfirmation_) MarshalToVT 

func (m *EventsResponse_PingConfirmation_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_PingConfirmation_) SizeVT 

func (m *EventsResponse_PingConfirmation_) SizeVT() (n int)

type EventsResponse_RejectConfirmation 

type EventsResponse_RejectConfirmation struct {

	// The identifiers that were rejected.
	Ids []uint64 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// Identifiers that were invalid, such as already being acknowledged or
	// rejected, should not be retried by the client.
	InvalidIds []uint64 `protobuf:"varint,2,rep,packed,name=invalid_ids,json=invalidIds,proto3" json:"invalid_ids,omitempty"`
	// Identifiers that could not be processed temporarily, should be
	// retried by the client.
	TemporaryFailedIds []uint64 `protobuf:"varint,3,rep,packed,name=temporary_failed_ids,json=temporaryFailedIds,proto3" json:"temporary_failed_ids,omitempty"`
	// contains filtered or unexported fields
}

Confirmation that some events were rejected.

func (*EventsResponse_RejectConfirmation) Descriptor deprecated 

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

Deprecated: Use EventsResponse_RejectConfirmation.ProtoReflect.Descriptor instead.

func (*EventsResponse_RejectConfirmation) GetIds 

func (x *EventsResponse_RejectConfirmation) GetIds() []uint64

func (*EventsResponse_RejectConfirmation) GetInvalidIds 

func (x *EventsResponse_RejectConfirmation) GetInvalidIds() []uint64

func (*EventsResponse_RejectConfirmation) GetTemporaryFailedIds 

func (x *EventsResponse_RejectConfirmation) GetTemporaryFailedIds() []uint64

func (*EventsResponse_RejectConfirmation) MarshalToSizedBufferVT 

func (m *EventsResponse_RejectConfirmation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_RejectConfirmation) MarshalToVT 

func (m *EventsResponse_RejectConfirmation) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_RejectConfirmation) MarshalVT 

func (m *EventsResponse_RejectConfirmation) MarshalVT() (dAtA []byte, err error)

func (*EventsResponse_RejectConfirmation) ProtoMessage 

func (*EventsResponse_RejectConfirmation) ProtoMessage()

func (*EventsResponse_RejectConfirmation) ProtoReflect 

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

func (*EventsResponse_RejectConfirmation) Reset 

func (x *EventsResponse_RejectConfirmation) Reset()

func (*EventsResponse_RejectConfirmation) SizeVT 

func (m *EventsResponse_RejectConfirmation) SizeVT() (n int)

func (*EventsResponse_RejectConfirmation) String 

func (x *EventsResponse_RejectConfirmation) String() string

func (*EventsResponse_RejectConfirmation) UnmarshalVT 

func (m *EventsResponse_RejectConfirmation) UnmarshalVT(dAtA []byte) error

type EventsResponse_RejectConfirmation_ 

type EventsResponse_RejectConfirmation_ struct {
	// Confirmation that some events were rejected.
	RejectConfirmation *EventsResponse_RejectConfirmation `protobuf:"bytes,4,opt,name=reject_confirmation,json=rejectConfirmation,proto3,oneof"`
}

func (*EventsResponse_RejectConfirmation_) MarshalToSizedBufferVT 

func (m *EventsResponse_RejectConfirmation_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_RejectConfirmation_) MarshalToVT 

func (m *EventsResponse_RejectConfirmation_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_RejectConfirmation_) SizeVT 

func (m *EventsResponse_RejectConfirmation_) SizeVT() (n int)

type EventsResponse_Subscribed 

type EventsResponse_Subscribed struct {

	// The timeout for events, after which they will be resent if not
	// acknowledged or rejected. Can be used by the client to implements
	// features such as pings.
	ProcessingTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=processing_timeout,json=processingTimeout,proto3" json:"processing_timeout,omitempty"`
	// contains filtered or unexported fields
}

Confirmation that the client has subscribed to events.

func (*EventsResponse_Subscribed) Descriptor deprecated 

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

Deprecated: Use EventsResponse_Subscribed.ProtoReflect.Descriptor instead.

func (*EventsResponse_Subscribed) GetProcessingTimeout 

func (x *EventsResponse_Subscribed) GetProcessingTimeout() *durationpb.Duration

func (*EventsResponse_Subscribed) MarshalToSizedBufferVT 

func (m *EventsResponse_Subscribed) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_Subscribed) MarshalToVT 

func (m *EventsResponse_Subscribed) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_Subscribed) MarshalVT 

func (m *EventsResponse_Subscribed) MarshalVT() (dAtA []byte, err error)

func (*EventsResponse_Subscribed) ProtoMessage 

func (*EventsResponse_Subscribed) ProtoMessage()

func (*EventsResponse_Subscribed) ProtoReflect 

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

func (*EventsResponse_Subscribed) Reset 

func (x *EventsResponse_Subscribed) Reset()

func (*EventsResponse_Subscribed) SizeVT 

func (m *EventsResponse_Subscribed) SizeVT() (n int)

func (*EventsResponse_Subscribed) String 

func (x *EventsResponse_Subscribed) String() string

func (*EventsResponse_Subscribed) UnmarshalVT 

func (m *EventsResponse_Subscribed) UnmarshalVT(dAtA []byte) error

type EventsResponse_Subscribed_ 

type EventsResponse_Subscribed_ struct {
	// Confirmation that the client has subscribed to events.
	Subscribed *EventsResponse_Subscribed `protobuf:"bytes,2,opt,name=subscribed,proto3,oneof"`
}

func (*EventsResponse_Subscribed_) MarshalToSizedBufferVT 

func (m *EventsResponse_Subscribed_) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EventsResponse_Subscribed_) MarshalToVT 

func (m *EventsResponse_Subscribed_) MarshalToVT(dAtA []byte) (int, error)

func (*EventsResponse_Subscribed_) SizeVT 

func (m *EventsResponse_Subscribed_) SizeVT() (n int)

type EventsServiceClient 

type EventsServiceClient interface {
	// Ensure that a certain stream exists. Used to create streams to collect
	// events for certain subjects. Consumers can then be created to
	// for these streams.
	EnsureStream(ctx context.Context, in *EnsureStreamRequest, opts ...grpc.CallOption) (*EnsureStreamResponse, error)
	// Ensure that a certain consumer exists. Creates a consumer whose events
	// can be consumed by subscribers.
	//
	// Consumers are managed by the programs that use them, and this request
	// is commonly sent at the start of a program to ensure that the consumer
	// exists.
	EnsureConsumer(ctx context.Context, in *EnsureConsumerRequest, opts ...grpc.CallOption) (*EnsureConsumerResponse, error)
	// Delete a previously created consumer.
	DeleteConsumer(ctx context.Context, in *DeleteConsumerRequest, opts ...grpc.CallOption) (*DeleteConsumerResponse, error)
	// Publish an event.
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*PublishEventResponse, error)
	// Subscribes to events and returns them as they are published. This call is
	// bidirectional, so the client can acknowledge/reject events as they are
	// received.
	//
	// The first message sent on the stream must be a Subscribe message, after
	// which the server will respond with a Subscribed message. The client will
	// then receive events as they are published, and should acknowledge, reject
	// and ping as needed.
	Events(ctx context.Context, opts ...grpc.CallOption) (EventsService_EventsClient, error)
}

EventsServiceClient is the client API for EventsService 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 NewEventsServiceClient 

func NewEventsServiceClient(cc grpc.ClientConnInterface) EventsServiceClient

type EventsServiceServer 

type EventsServiceServer interface {
	// Ensure that a certain stream exists. Used to create streams to collect
	// events for certain subjects. Consumers can then be created to
	// for these streams.
	EnsureStream(context.Context, *EnsureStreamRequest) (*EnsureStreamResponse, error)
	// Ensure that a certain consumer exists. Creates a consumer whose events
	// can be consumed by subscribers.
	//
	// Consumers are managed by the programs that use them, and this request
	// is commonly sent at the start of a program to ensure that the consumer
	// exists.
	EnsureConsumer(context.Context, *EnsureConsumerRequest) (*EnsureConsumerResponse, error)
	// Delete a previously created consumer.
	DeleteConsumer(context.Context, *DeleteConsumerRequest) (*DeleteConsumerResponse, error)
	// Publish an event.
	PublishEvent(context.Context, *PublishEventRequest) (*PublishEventResponse, error)
	// Subscribes to events and returns them as they are published. This call is
	// bidirectional, so the client can acknowledge/reject events as they are
	// received.
	//
	// The first message sent on the stream must be a Subscribe message, after
	// which the server will respond with a Subscribed message. The client will
	// then receive events as they are published, and should acknowledge, reject
	// and ping as needed.
	Events(EventsService_EventsServer) error
	// contains filtered or unexported methods
}

EventsServiceServer is the server API for EventsService service. All implementations must embed UnimplementedEventsServiceServer for forward compatibility

type EventsService_EventsClient 

type EventsService_EventsClient interface {
	Send(*EventsRequest) error
	Recv() (*EventsResponse, error)
	grpc.ClientStream
}

type EventsService_EventsServer 

type EventsService_EventsServer interface {
	Send(*EventsResponse) error
	Recv() (*EventsRequest, error)
	grpc.ServerStream
}

type Headers 

type Headers struct {

	// Timestamp of the event. This is the time the event occurred, clients
	// may set this when publishing.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Key used to prevent duplicate events from being stored if a retry is
	// needed.
	IdempotencyKey *string `protobuf:"bytes,2,opt,name=idempotency_key,json=idempotencyKey,proto3,oneof" json:"idempotency_key,omitempty"`
	// Parent trace id in the W3C trace context format.
	TraceParent *string `protobuf:"bytes,3,opt,name=trace_parent,json=traceParent,proto3,oneof" json:"trace_parent,omitempty"`
	// Trace state in the W3C trace context format.
	TraceState *string `protobuf:"bytes,4,opt,name=trace_state,json=traceState,proto3,oneof" json:"trace_state,omitempty"`
	// contains filtered or unexported fields
}

func (*Headers) Descriptor deprecated 

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

Deprecated: Use Headers.ProtoReflect.Descriptor instead.

func (*Headers) GetIdempotencyKey 

func (x *Headers) GetIdempotencyKey() string

func (*Headers) GetTimestamp 

func (x *Headers) GetTimestamp() *timestamppb.Timestamp

func (*Headers) GetTraceParent 

func (x *Headers) GetTraceParent() string

func (*Headers) GetTraceState 

func (x *Headers) GetTraceState() string

func (*Headers) MarshalToSizedBufferVT 

func (m *Headers) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Headers) MarshalToVT 

func (m *Headers) MarshalToVT(dAtA []byte) (int, error)

func (*Headers) MarshalVT 

func (m *Headers) MarshalVT() (dAtA []byte, err error)

func (*Headers) ProtoMessage 

func (*Headers) ProtoMessage()

func (*Headers) ProtoReflect 

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

func (*Headers) Reset 

func (x *Headers) Reset()

func (*Headers) SizeVT 

func (m *Headers) SizeVT() (n int)

func (*Headers) String 

func (x *Headers) String() string

func (*Headers) UnmarshalVT 

func (m *Headers) UnmarshalVT(dAtA []byte) error

type PublishEventRequest 

type PublishEventRequest struct {

	// The subject of the event. Subjects are case-sensitive and should only
	// contain the following characters:
	//
	//   - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
	//   - `_` and `-` are allowed for separating words, but the use of camelCase
	//     is recommended.
	//   - `.` is allowed and used as a hierarchy separator, such as
	//     `time.us.east` and `time.eu.sweden`, which share the `time` prefix.
	//
	// If the subject is not bound to a stream the event will be rejected.
	//
	// See NATS concepts: https://docs.nats.io/nats-concepts/subjects
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// The event data. The data is dynamic and it is up to the publisher
	// and subscriber to agree on the Protobuf messages to support.
	//
	// Each subject can support several different types of data, which can be
	// useful to support different versions of the data. Subscribers should
	// ignore data they do not understand.
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Timestamp of the event.
	//
	// Defaults to the current time of the server if not provided.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
	// Key used to prevent duplicate events from being stored if a retry is
	// needed. Should be set to a unique value for each publish request of a
	// specific event.
	//
	// No default, events will not be deduplicated if not provided.
	IdempotencyKey *string `protobuf:"bytes,4,opt,name=idempotency_key,json=idempotencyKey,proto3,oneof" json:"idempotency_key,omitempty"`
	// The id of the event that is expected to be in the last published event in
	// the stream.
	//
	// Used for optimistic concurrency control, if the specified event id does
	// not match the current last event id, the publish will fail.
	//
	// No default, publish will not check the last event if not provided.
	ExpectedLastId *uint64 `protobuf:"varint,5,opt,name=expected_last_id,json=expectedLastId,proto3,oneof" json:"expected_last_id,omitempty"`
	// contains filtered or unexported fields
}

Request to publish an event.

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetData 

func (x *PublishEventRequest) GetData() *anypb.Any

func (*PublishEventRequest) GetExpectedLastId 

func (x *PublishEventRequest) GetExpectedLastId() uint64

func (*PublishEventRequest) GetIdempotencyKey 

func (x *PublishEventRequest) GetIdempotencyKey() string

func (*PublishEventRequest) GetSubject 

func (x *PublishEventRequest) GetSubject() string

func (*PublishEventRequest) GetTimestamp 

func (x *PublishEventRequest) GetTimestamp() *timestamppb.Timestamp

func (*PublishEventRequest) MarshalToSizedBufferVT 

func (m *PublishEventRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishEventRequest) MarshalToVT 

func (m *PublishEventRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PublishEventRequest) MarshalVT 

func (m *PublishEventRequest) MarshalVT() (dAtA []byte, err error)

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) SizeVT 

func (m *PublishEventRequest) SizeVT() (n int)

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

func (*PublishEventRequest) UnmarshalVT 

func (m *PublishEventRequest) UnmarshalVT(dAtA []byte) error

type PublishEventResponse 

type PublishEventResponse struct {

	// The id of the published event.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Response to publish an event.

func (*PublishEventResponse) Descriptor deprecated 

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

Deprecated: Use PublishEventResponse.ProtoReflect.Descriptor instead.

func (*PublishEventResponse) GetId 

func (x *PublishEventResponse) GetId() uint64

func (*PublishEventResponse) MarshalToSizedBufferVT 

func (m *PublishEventResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishEventResponse) MarshalToVT 

func (m *PublishEventResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PublishEventResponse) MarshalVT 

func (m *PublishEventResponse) MarshalVT() (dAtA []byte, err error)

func (*PublishEventResponse) ProtoMessage 

func (*PublishEventResponse) ProtoMessage()

func (*PublishEventResponse) ProtoReflect 

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

func (*PublishEventResponse) Reset 

func (x *PublishEventResponse) Reset()

func (*PublishEventResponse) SizeVT 

func (m *PublishEventResponse) SizeVT() (n int)

func (*PublishEventResponse) String 

func (x *PublishEventResponse) String() string

func (*PublishEventResponse) UnmarshalVT 

func (m *PublishEventResponse) UnmarshalVT(dAtA []byte) error

type StreamPointer 

type StreamPointer struct {

	// Types that are assignable to Pointer:
	//
	//	*StreamPointer_Start
	//	*StreamPointer_End
	//	*StreamPointer_Time
	//	*StreamPointer_Offset
	Pointer isStreamPointer_Pointer `protobuf_oneof:"pointer"`
	// contains filtered or unexported fields
}

A pointer to a position in a stream. Used to determine where to start consuming events from.

func (*StreamPointer) Descriptor deprecated 

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

Deprecated: Use StreamPointer.ProtoReflect.Descriptor instead.

func (*StreamPointer) GetEnd 

func (x *StreamPointer) GetEnd() bool

func (*StreamPointer) GetOffset 

func (x *StreamPointer) GetOffset() uint64

func (*StreamPointer) GetPointer 

func (m *StreamPointer) GetPointer() isStreamPointer_Pointer

func (*StreamPointer) GetStart 

func (x *StreamPointer) GetStart() bool

func (*StreamPointer) GetTime 

func (x *StreamPointer) GetTime() *timestamppb.Timestamp

func (*StreamPointer) MarshalToSizedBufferVT 

func (m *StreamPointer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPointer) MarshalToVT 

func (m *StreamPointer) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPointer) MarshalVT 

func (m *StreamPointer) MarshalVT() (dAtA []byte, err error)

func (*StreamPointer) ProtoMessage 

func (*StreamPointer) ProtoMessage()

func (*StreamPointer) ProtoReflect 

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

func (*StreamPointer) Reset 

func (x *StreamPointer) Reset()

func (*StreamPointer) SizeVT 

func (m *StreamPointer) SizeVT() (n int)

func (*StreamPointer) String 

func (x *StreamPointer) String() string

func (*StreamPointer) UnmarshalVT 

func (m *StreamPointer) UnmarshalVT(dAtA []byte) error

type StreamPointer_End 

type StreamPointer_End struct {
	// Receive only future events.
	End bool `protobuf:"varint,2,opt,name=end,proto3,oneof"`
}

func (*StreamPointer_End) MarshalToSizedBufferVT 

func (m *StreamPointer_End) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPointer_End) MarshalToVT 

func (m *StreamPointer_End) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPointer_End) SizeVT 

func (m *StreamPointer_End) SizeVT() (n int)

type StreamPointer_Offset 

type StreamPointer_Offset struct {
	// The id of the event to start receiving events from.
	Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3,oneof"`
}

func (*StreamPointer_Offset) MarshalToSizedBufferVT 

func (m *StreamPointer_Offset) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPointer_Offset) MarshalToVT 

func (m *StreamPointer_Offset) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPointer_Offset) SizeVT 

func (m *StreamPointer_Offset) SizeVT() (n int)

type StreamPointer_Start 

type StreamPointer_Start struct {
	// Receive all events currently available.
	Start bool `protobuf:"varint,1,opt,name=start,proto3,oneof"`
}

func (*StreamPointer_Start) MarshalToSizedBufferVT 

func (m *StreamPointer_Start) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPointer_Start) MarshalToVT 

func (m *StreamPointer_Start) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPointer_Start) SizeVT 

func (m *StreamPointer_Start) SizeVT() (n int)

type StreamPointer_Time 

type StreamPointer_Time struct {
	// The time to start receiving events from.
	Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3,oneof"`
}

func (*StreamPointer_Time) MarshalToSizedBufferVT 

func (m *StreamPointer_Time) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPointer_Time) MarshalToVT 

func (m *StreamPointer_Time) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPointer_Time) SizeVT 

func (m *StreamPointer_Time) SizeVT() (n int)

type UnimplementedEventsServiceServer 

type UnimplementedEventsServiceServer struct {
}

UnimplementedEventsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEventsServiceServer) DeleteConsumer 

func (UnimplementedEventsServiceServer) DeleteConsumer(context.Context, *DeleteConsumerRequest) (*DeleteConsumerResponse, error)

func (UnimplementedEventsServiceServer) EnsureConsumer 

func (UnimplementedEventsServiceServer) EnsureConsumer(context.Context, *EnsureConsumerRequest) (*EnsureConsumerResponse, error)

func (UnimplementedEventsServiceServer) EnsureStream 

func (UnimplementedEventsServiceServer) EnsureStream(context.Context, *EnsureStreamRequest) (*EnsureStreamResponse, error)

func (UnimplementedEventsServiceServer) Events 

func (UnimplementedEventsServiceServer) Events(EventsService_EventsServer) error

func (UnimplementedEventsServiceServer) PublishEvent 

func (UnimplementedEventsServiceServer) PublishEvent(context.Context, *PublishEventRequest) (*PublishEventResponse, error)

type UnsafeEventsServiceServer 

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

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

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.