Documentation ¶
Index ¶
- Variables
- type Topic
- func (*Topic) Descriptor() ([]byte, []int)deprecated
- func (x *Topic) GetConsumerRetentionPeriod() *durationpb.Duration
- func (x *Topic) GetMessageRetentionPeriod() *durationpb.Duration
- func (x *Topic) GetName() string
- func (x *Topic) GetRequireVerifiedMessages() bool
- func (*Topic) ProtoMessage()
- func (x *Topic) ProtoReflect() protoreflect.Message
- func (x *Topic) Reset()
- func (x *Topic) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_arrebato_topic_v1_topic_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Topic ¶
type Topic struct { // The name of the topic. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The amount of time a message will exist on a topic until it is deleted. MessageRetentionPeriod *durationpb.Duration `` /* 129-byte string literal not displayed */ // The amount of time a consumer will exist on a topic without updating its index until it is deleted. ConsumerRetentionPeriod *durationpb.Duration `` /* 132-byte string literal not displayed */ // Determines whether or not unverified messages are rejected for this topic. RequireVerifiedMessages bool `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
The Topic message describes a single topic within the cluster.
func (*Topic) Descriptor
deprecated
func (*Topic) GetConsumerRetentionPeriod ¶
func (x *Topic) GetConsumerRetentionPeriod() *durationpb.Duration
func (*Topic) GetMessageRetentionPeriod ¶
func (x *Topic) GetMessageRetentionPeriod() *durationpb.Duration
func (*Topic) GetRequireVerifiedMessages ¶
func (*Topic) ProtoMessage ¶
func (*Topic) ProtoMessage()
func (*Topic) ProtoReflect ¶
func (x *Topic) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.