pub_client

Documentation

Index

• type EachPartitionError
• type EachPartitionPublishJob
• type PublishClient
• type PublisherConfiguration
• type TopicPublisher
  • func NewTopicPublisher(config *PublisherConfiguration) *TopicPublisher
  • func (p *TopicPublisher) FinishPublish() error
  • func (p *TopicPublisher) Publish(key, value []byte) error
  • func (p *TopicPublisher) PublishRecord(key []byte, recordValue *schema_pb.RecordValue) error
  • func (p *TopicPublisher) Shutdown() error

Types

type EachPartitionError

type EachPartitionError struct {
	*mq_pb.BrokerPartitionAssignment
	Err error
	// contains filtered or unexported fields
}

type EachPartitionPublishJob

type EachPartitionPublishJob struct {
	*mq_pb.BrokerPartitionAssignment
	// contains filtered or unexported fields
}

type PublishClient

type PublishClient struct {
	mq_pb.SeaweedMessaging_PublishMessageClient
	Broker string
	Err    error
}

type PublisherConfiguration

type PublisherConfiguration struct {
	Topic          topic.Topic
	PartitionCount int32
	Brokers        []string
	PublisherName  string // for debugging
	RecordType     *schema_pb.RecordType
}

type TopicPublisher

type TopicPublisher struct {
	sync.Mutex // protects grpc
	// contains filtered or unexported fields
}

func NewTopicPublisher

func NewTopicPublisher(config *PublisherConfiguration) *TopicPublisher

func (*TopicPublisher) FinishPublish

func (p *TopicPublisher) FinishPublish() error

func (*TopicPublisher) Publish

func (p *TopicPublisher) Publish(key, value []byte) error

func (*TopicPublisher) PublishRecord

func (p *TopicPublisher) PublishRecord(key []byte, recordValue *schema_pb.RecordValue) error

func (*TopicPublisher) Shutdown

func (p *TopicPublisher) Shutdown() error