services

Documentation

Index

• Constants
• type KafkaService
• type KafkaServiceImpl
  • func NewKafkaService() KafkaServiceImpl
  • func (kSvc *KafkaServiceImpl) Init(cfg *config.Config) error
  • func (kSvc *KafkaServiceImpl) SendMessage(topic, data, contextId string, isDelete bool) error

Constants

const (
	SchemaName = "chs-delta"
)

Types

type KafkaService

type KafkaService interface {
	Init(cfg *config.Config) error
	SendMessage(topic, data, contextId string, isDelete bool) error
}

KafkaService defines all Methods needed to successfully send a message onto a Kafka topic.

type KafkaServiceImpl

type KafkaServiceImpl struct {
	P *producer.Producer
	// contains filtered or unexported fields
}

KafkaServiceImpl is a concrete implementation of the KafkaService interface.

func NewKafkaService

func NewKafkaService() KafkaServiceImpl

NewKafkaService returns a KafkaServiceImpl that isn't configured.

func (*KafkaServiceImpl) Init

func (kSvc *KafkaServiceImpl) Init(cfg *config.Config) error

Init initialises a KafkaService using a provided config.

func (*KafkaServiceImpl) SendMessage

func (kSvc *KafkaServiceImpl) SendMessage(topic, data, contextId string, isDelete bool) error

SendMessage publishes a given data string retrieved from a REST request onto a chosen Kafka topic.