go_kafka_integrator

package module
v0.1.10 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventConsumerType = eventConsumerTypes{
	JSON: "json",
	AVRO: "avro",
}
View Source 
var EventProducerType = eventProducerTypes{
	JSON: "json",
	AVRO: "avro",
}

Functions

This section is empty.

Types

type ConsumerOptionsBuilder added in v0.1.5 

type ConsumerOptionsBuilder struct {
	// contains filtered or unexported fields
}

ConsumerOptionsBuilder is the builder for consumerOptions

func NewConsumerOptionsBuilder added in v0.1.5 

func NewConsumerOptionsBuilder() *ConsumerOptionsBuilder

NewConsumerOptionsBuilder creates a new builder instance

func (*ConsumerOptionsBuilder) Build added in v0.1.5 

func (b *ConsumerOptionsBuilder) Build() consumerOptions

Build constructs the final consumerOptions

func (*ConsumerOptionsBuilder) WithBootstrapServers added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithBootstrapServers(servers string) *ConsumerOptionsBuilder

WithBootstrapServers sets the BootstrapServers field

func (*ConsumerOptionsBuilder) WithClusterPassword added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithClusterPassword(password string) *ConsumerOptionsBuilder

WithClusterPassword sets the ClusterPassword field

func (*ConsumerOptionsBuilder) WithClusterUsername added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithClusterUsername(username string) *ConsumerOptionsBuilder

WithClusterUsername sets the ClusterUsername field

func (*ConsumerOptionsBuilder) WithConsumerGroupId added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithConsumerGroupId(groupId string) *ConsumerOptionsBuilder

WithConsumerGroupId sets the ConsumerGroupId field

func (*ConsumerOptionsBuilder) WithEventConsumerType added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithEventConsumerType(consumerType string) *ConsumerOptionsBuilder

WithEventConsumerType sets the EventConsumerType field

func (*ConsumerOptionsBuilder) WithKafkaAutoResetConfig added in v0.1.6 

func (b *ConsumerOptionsBuilder) WithKafkaAutoResetConfig(kafkaAutoResetConfig string) *ConsumerOptionsBuilder

WithKafkaAutoResetConfig sets the KafkaAutoResetConfig field

func (*ConsumerOptionsBuilder) WithLogger added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithLogger(logger logger.Logger) *ConsumerOptionsBuilder

WithLogger sets the Logger field

func (*ConsumerOptionsBuilder) WithSchemaRegistryPassword added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithSchemaRegistryPassword(password string) *ConsumerOptionsBuilder

WithSchemaRegistryPassword sets the SchemaRegistryPassword field

func (*ConsumerOptionsBuilder) WithSchemaRegistryURL added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithSchemaRegistryURL(url string) *ConsumerOptionsBuilder

WithSchemaRegistryURL sets the SchemaRegistryURL field

func (*ConsumerOptionsBuilder) WithSchemaRegistryUsername added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithSchemaRegistryUsername(username string) *ConsumerOptionsBuilder

WithSchemaRegistryUsername sets the SchemaRegistryUsername field

func (*ConsumerOptionsBuilder) WithStatsDHost added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithStatsDHost(host string) *ConsumerOptionsBuilder

WithStatsDHost sets the StatsDHost field

func (*ConsumerOptionsBuilder) WithStatsDPort added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithStatsDPort(port string) *ConsumerOptionsBuilder

WithStatsDPort sets the StatsDPort field

func (*ConsumerOptionsBuilder) WithStatsDPrefix added in v0.1.5 

func (b *ConsumerOptionsBuilder) WithStatsDPrefix(prefix string) *ConsumerOptionsBuilder

WithStatsDPrefix sets the StatsDPrefix field

type EventConsumer added in v0.1.6 

type EventConsumer interface {
	DeserializeInto(topic string, serdeType serde.Type, payload []byte, message interface{}) error
	GetMessageDataFormat() string
	SubscribeTopics(topicNames []string, messageChan chan kafka.Message) error
}

func NewEventConsumer 

func NewEventConsumer(options consumerOptions) (EventConsumer, error)

type EventProducer added in v0.1.6 

type EventProducer interface {
	ProduceEvent(topic string, key interface{}, value interface{}) error
	Close()
	InvokeDeliveryChannel()
	GetMessageDataFormat() string
}

func NewEventProducer 

func NewEventProducer(options producerOptions) (EventProducer, error)

type ProducerOptionsBuilder added in v0.1.5 

type ProducerOptionsBuilder struct {
	// contains filtered or unexported fields
}

ProducerOptionsBuilder is the builder for producerOptions

func NewProducerOptionsBuilder added in v0.1.5 

func NewProducerOptionsBuilder() *ProducerOptionsBuilder

NewProducerOptionsBuilder creates a new builder instance

func (*ProducerOptionsBuilder) Build added in v0.1.5 

func (b *ProducerOptionsBuilder) Build() producerOptions

Build constructs the final producerOptions

func (*ProducerOptionsBuilder) WithBootstrapServers added in v0.1.5 

func (b *ProducerOptionsBuilder) WithBootstrapServers(servers string) *ProducerOptionsBuilder

WithBootstrapServers sets the BootstrapServers field

func (*ProducerOptionsBuilder) WithClusterPassword added in v0.1.5 

func (b *ProducerOptionsBuilder) WithClusterPassword(password string) *ProducerOptionsBuilder

WithClusterPassword sets the ClusterPassword field

func (*ProducerOptionsBuilder) WithClusterUsername added in v0.1.5 

func (b *ProducerOptionsBuilder) WithClusterUsername(username string) *ProducerOptionsBuilder

WithClusterUsername sets the ClusterUsername field

func (*ProducerOptionsBuilder) WithEventProducerType added in v0.1.5 

func (b *ProducerOptionsBuilder) WithEventProducerType(producerType string) *ProducerOptionsBuilder

WithEventProducerType sets the EventProducerType field

func (*ProducerOptionsBuilder) WithLogger added in v0.1.5 

func (b *ProducerOptionsBuilder) WithLogger(logger logger.Logger) *ProducerOptionsBuilder

WithLogger sets the Logger field

func (*ProducerOptionsBuilder) WithSchemaRegistryPassword added in v0.1.5 

func (b *ProducerOptionsBuilder) WithSchemaRegistryPassword(password string) *ProducerOptionsBuilder

WithSchemaRegistryPassword sets the SchemaRegistryPassword field

func (*ProducerOptionsBuilder) WithSchemaRegistryURL added in v0.1.5 

func (b *ProducerOptionsBuilder) WithSchemaRegistryURL(url string) *ProducerOptionsBuilder

WithSchemaRegistryURL sets the SchemaRegistryURL field

func (*ProducerOptionsBuilder) WithSchemaRegistryUsername added in v0.1.5 

func (b *ProducerOptionsBuilder) WithSchemaRegistryUsername(username string) *ProducerOptionsBuilder

WithSchemaRegistryUsername sets the SchemaRegistryUsername field

func (*ProducerOptionsBuilder) WithStatsDHost added in v0.1.5 

func (b *ProducerOptionsBuilder) WithStatsDHost(host string) *ProducerOptionsBuilder

WithStatsDHost sets the StatsDHost field

func (*ProducerOptionsBuilder) WithStatsDPort added in v0.1.5 

func (b *ProducerOptionsBuilder) WithStatsDPort(port string) *ProducerOptionsBuilder

WithStatsDPort sets the StatsDPort field

func (*ProducerOptionsBuilder) WithStatsDPrefix added in v0.1.5 

func (b *ProducerOptionsBuilder) WithStatsDPrefix(prefix string) *ProducerOptionsBuilder

WithStatsDPrefix sets the StatsDPrefix field

Source Files

View all Source files

Directories

Path Synopsis
utils
logger
logger/zap
monitors/statsDConnector

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.