queue

package

Go to main page

Versions in this module

v1

v1.2.0

Jan 25, 2026

Changes in this version

+ var MessageRetentionPolicy_Mode_name = map[int32]string

+ var MessageRetentionPolicy_Mode_value = map[string]int32

+ type MessageRetentionPolicy struct

+ Mode MessageRetentionPolicy_Mode

+ RetentionSeconds int64

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

+ func (*MessageRetentionPolicy) ProtoMessage()

+ func (x *MessageRetentionPolicy) GetMode() MessageRetentionPolicy_Mode

+ func (x *MessageRetentionPolicy) GetRetentionSeconds() int64

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

+ func (x *MessageRetentionPolicy) Reset()

+ func (x *MessageRetentionPolicy) String() string

+ type MessageRetentionPolicy_Mode int32

+ const MessageRetentionPolicy_DELETE_IMMEDIATELY

+ const MessageRetentionPolicy_RETAIN_DURATION

+ const MessageRetentionPolicy_RETAIN_FOREVER

+ func (MessageRetentionPolicy_Mode) Descriptor() protoreflect.EnumDescriptor

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

+ func (MessageRetentionPolicy_Mode) Type() protoreflect.EnumType

+ func (x MessageRetentionPolicy_Mode) Enum() *MessageRetentionPolicy_Mode

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

+ func (x MessageRetentionPolicy_Mode) String() string

type QueueMetadata

+ MessageRetentionPolicy *MessageRetentionPolicy

+ func (x *QueueMetadata) GetMessageRetentionPolicy() *MessageRetentionPolicy

v1.1.1

Dec 7, 2025

Changes in this version

type QueueMetadata

+ LeasePolicy *v1.LeasePolicy

+ func (x *QueueMetadata) GetLeasePolicy() *v1.LeasePolicy

v1.1.0

Nov 16, 2025

v1.0.0

Nov 13, 2025

Changes in this version

+ var FairnessPolicy_name = map[int32]string

+ var FairnessPolicy_value = map[string]int32

+ var File_proto_queue_v1_queue_proto protoreflect.FileDescriptor

+ var QueueType_name = map[int32]string

+ var QueueType_value = map[string]int32

+ type FairnessPolicy int32

+ const FairnessPolicy_AGING

+ const FairnessPolicy_HYBRID

+ const FairnessPolicy_STRICT

+ const FairnessPolicy_WEIGHTED

+ func (FairnessPolicy) Descriptor() protoreflect.EnumDescriptor

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

+ func (FairnessPolicy) Type() protoreflect.EnumType

+ func (x FairnessPolicy) Enum() *FairnessPolicy

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

+ func (x FairnessPolicy) String() string

+ type PriorityConfig struct

+ AgeBoostMultiplier int32

+ AgeBoostThreshold *durationpb.Duration

+ Policy FairnessPolicy

+ PriorityWeights map[int32]int32

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

+ func (*PriorityConfig) ProtoMessage()

+ func (x *PriorityConfig) GetAgeBoostMultiplier() int32

+ func (x *PriorityConfig) GetAgeBoostThreshold() *durationpb.Duration

+ func (x *PriorityConfig) GetPolicy() FairnessPolicy

+ func (x *PriorityConfig) GetPriorityWeights() map[int32]int32

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

+ func (x *PriorityConfig) Reset()

+ func (x *PriorityConfig) String() string

+ type Queue struct

+ Metadata *QueueMetadata

+ Name string

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

+ func (*Queue) ProtoMessage()

+ func (x *Queue) GetMetadata() *QueueMetadata

+ func (x *Queue) GetName() string

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

+ func (x *Queue) Reset()

+ func (x *Queue) String() string

+ type QueueMetadata struct

+ AllowedContentTypes []string

+ AutoCreateDlq bool

+ DeadLetterQueueName string

+ DefaultMaxAttempts int32

+ ExclusivityKey string

+ LeaseDuration *durationpb.Duration

+ MaxPayloadSize int32

+ PriorityConfig *PriorityConfig

+ SchemaId string

+ SchemaRequired bool

+ Type QueueType

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

+ func (*QueueMetadata) ProtoMessage()

+ func (x *QueueMetadata) GetAllowedContentTypes() []string

+ func (x *QueueMetadata) GetAutoCreateDlq() bool

+ func (x *QueueMetadata) GetDeadLetterQueueName() string

+ func (x *QueueMetadata) GetDefaultMaxAttempts() int32

+ func (x *QueueMetadata) GetExclusivityKey() string

+ func (x *QueueMetadata) GetLeaseDuration() *durationpb.Duration

+ func (x *QueueMetadata) GetMaxPayloadSize() int32

+ func (x *QueueMetadata) GetPriorityConfig() *PriorityConfig

+ func (x *QueueMetadata) GetSchemaId() string

+ func (x *QueueMetadata) GetSchemaRequired() bool

+ func (x *QueueMetadata) GetType() QueueType

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

+ func (x *QueueMetadata) Reset()

+ func (x *QueueMetadata) String() string

+ type QueueType int32

+ const QueueType_EXCLUSIVE

+ const QueueType_SIMPLE

+ func (QueueType) Descriptor() protoreflect.EnumDescriptor

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

+ func (QueueType) Type() protoreflect.EnumType

+ func (x QueueType) Enum() *QueueType

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

+ func (x QueueType) String() string

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