pub_client

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

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

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

type PublisherConfiguration struct {
	Topic                     topic.Topic
	CreateTopic               bool
	CreateTopicPartitionCount int32
	Brokers                   []string
}

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