grpc

Documentation

Index

• type PublisherGrpcService
  • func (p *PublisherGrpcService) PublishMessage(topic string, partition models.Partition, data string) error

Types

type PublisherGrpcService

type PublisherGrpcService struct {
	Id     string
	Client pb.BrokerClient
	Config *models.PublisherConfig
}

func (*PublisherGrpcService) PublishMessage

func (p *PublisherGrpcService) PublishMessage(topic string, partition models.Partition, data string) error

PublishMessage publishes a data to a topic via a broker