service

Documentation

Index

• type Stream
  • func InitStream(env *environment.Environment, notification notification.ServiceNotification, ...) *Stream
  • func (stream *Stream) Run(doneChannel chan bool)

Types

type Stream

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

func InitStream

func InitStream(env *environment.Environment, notification notification.ServiceNotification, saramaConfig *sarama.Config) *Stream

InitStream populate and return a *Stream struct.

func (*Stream) Run

func (stream *Stream) Run(doneChannel chan bool)

Run reads messages from kafka and send to a notification service.