topic

package
v0.1.0-alpha4 Latest Latest
Warning

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

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

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetConsumerRetentionPeriod

func (x *Topic) GetConsumerRetentionPeriod() *durationpb.Duration

func (*Topic) GetMessageRetentionPeriod

func (x *Topic) GetMessageRetentionPeriod() *durationpb.Duration

func (*Topic) GetName

func (x *Topic) GetName() string

func (*Topic) GetRequireVerifiedMessages

func (x *Topic) GetRequireVerifiedMessages() bool

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect

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

func (*Topic) Reset

func (x *Topic) Reset()

func (*Topic) String

func (x *Topic) String() string

Jump to

Keyboard shortcuts

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