kafka

Documentation

Index

• type KafkaLibrary
  • func KafkaLibraryHandler() *KafkaLibrary
  • func (kafka *KafkaLibrary) GetStateFull() *StateFullFormat
  • func (kafka *KafkaLibrary) InitConsumer(group string) (sarama.ConsumerGroup, error)
  • func (kafka *KafkaLibrary) InitNewConsumer() (sarama.Consumer, error)
  • func (kafka *KafkaLibrary) SendEvent(topic string, payload *StateFullFormat) (*StateFullFormat, int64, error)
• type KafkaLibraryInterface
• type StateFullFormat

Types

type KafkaLibrary

type KafkaLibrary struct{}

KafkaLibrary ...

func KafkaLibraryHandler

func KafkaLibraryHandler() *KafkaLibrary

KafkaLibraryHandler ...

func (*KafkaLibrary) GetStateFull

func (kafka *KafkaLibrary) GetStateFull() *StateFullFormat

GetStateFull ...

func (*KafkaLibrary) InitConsumer

func (kafka *KafkaLibrary) InitConsumer(group string) (sarama.ConsumerGroup, error)

InitConsumer ...

func (*KafkaLibrary) InitNewConsumer

func (kafka *KafkaLibrary) InitNewConsumer() (sarama.Consumer, error)

InitNewConsumer ...

func (*KafkaLibrary) SendEvent

func (kafka *KafkaLibrary) SendEvent(topic string, payload *StateFullFormat) (*StateFullFormat, int64, error)

SendEvent ...

type KafkaLibraryInterface

type KafkaLibraryInterface interface {
	GetStateFull() *StateFullFormat
	SendEvent(topic string, payload *StateFullFormat) (*StateFullFormat, int64, error)
	InitConsumer(group string) (sarama.ConsumerGroup, error)
	InitNewConsumer() (sarama.Consumer, error)
}

KafkaLibraryInterface ...

type StateFullFormat

type StateFullFormat struct {
	UUID      string                 `json:"__uuid" bson:"__uuid"`
	Action    string                 `json:"__action" bson:"__action"`
	Data      map[string]interface{} `json:"data" bson:"data"`
	CreatedAt *time.Time             `json:"created_at" bson:"created_at"`
}

ProducersMessageFormat ...