The highest tagged major version is v2.

trs_kafka

package

v1.5.3 Latest Latest Go to latest Published: Aug 10, 2021 License: MIT Imports: 7 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Cray-HPE/hms-trs-kafkalib

Links

Open Source Insights

Documentation ¶

Index ¶

func GenerateSendReceiveConsumerGroupName(appName, workerClass, consumerGroup string) (sendTopic string, rcvTopic string, cgroupName string)
type TRSKafka
type TRSKafkaClient
type TRSKafkaConsumer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GenerateSendReceiveConsumerGroupName ¶

func GenerateSendReceiveConsumerGroupName(appName, workerClass, consumerGroup string) (sendTopic string, rcvTopic string, cgroupName string)

Types ¶

type TRSKafka ¶

type TRSKafka struct {
	Client           *TRSKafkaClient
	ConsumerShutdown chan int
	RcvTopicNames    []string
	Mux              sync.Mutex
	Logger           *logrus.Logger
}

func (*TRSKafka) Init ¶

func (trsKafka *TRSKafka) Init(ctx context.Context,
	initialReceiveTopics []string,
	consumerGroup string,
	brokerSpec string,
	tasksChan chan *sarama.ConsumerMessage, logger *logrus.Logger) (err error)

func (*TRSKafka) SetTopics ¶

func (trsKafka *TRSKafka) SetTopics(topics []string) (err error)

func (*TRSKafka) Shutdown ¶

func (trsKafka *TRSKafka) Shutdown()

func (*TRSKafka) Write ¶

func (trsKafka *TRSKafka) Write(topic string, payload []byte)

type TRSKafkaClient ¶

type TRSKafkaClient struct {
	Config        *sarama.Config
	Producer      *sarama.AsyncProducer
	ConsumerGroup *sarama.ConsumerGroup
	Consumer      *TRSKafkaConsumer
	Logger        *logrus.Logger
}

type TRSKafkaConsumer ¶

type TRSKafkaConsumer struct {
	Errors    chan error
	Responses chan *sarama.ConsumerMessage
	Logger    *logrus.Logger
}

func (*TRSKafkaConsumer) Cleanup ¶

func (consumer *TRSKafkaConsumer) Cleanup(sarama.ConsumerGroupSession) error

func (*TRSKafkaConsumer) ConsumeClaim ¶

func (consumer *TRSKafkaConsumer) ConsumeClaim(session sarama.ConsumerGroupSession,
	claim sarama.ConsumerGroupClaim) error

func (*TRSKafkaConsumer) Setup ¶

func (consumer *TRSKafkaConsumer) Setup(sarama.ConsumerGroupSession) error

Source Files ¶

View all Source files

library.go

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