workers

Documentation

Index

• func CreateFileReaderProps(context actor.Context, bootstrapServers string) *actor.PID
• type CoordinatorActor
  • func (parent *CoordinatorActor) Receive(context actor.Context)
• type Producer
  • func NewProducer(brokerList string) Producer
  • func (p Producer) Produce(value string)

Functions

func CreateFileReaderProps

func CreateFileReaderProps(context actor.Context, bootstrapServers string) *actor.PID

CreateFileReaderProps create and spawn and child here

Types

type CoordinatorActor

type CoordinatorActor struct {
	BootStrapServers string
	// contains filtered or unexported fields
}

CoordinatorActor to supervise other actors

func (*CoordinatorActor) Receive

func (parent *CoordinatorActor) Receive(context actor.Context)

Receive on a coordinator actor

type Producer

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

Producer ...

func NewProducer

func NewProducer(brokerList string) Producer

NewProducer creates a new Kafka producer brokerList is a comma separated list of Kakfa brokers for eg. "localhost:9092,localhost:9093"

func (Producer) Produce

func (p Producer) Produce(value string)

Produce produces a test message