consumers

Documentation

Index

• type StateConsumer
  • func NewStateConsumer() (*StateConsumer, error)
  • func (sc *StateConsumer) Close() error
• type TaskConsumer
  • func NewTaskConsumer() (*TaskConsumer, error)
  • func (tc *TaskConsumer) Close() error

Types

type StateConsumer

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

StateConsumer consumed states messages from Kafka to maintain the state database.

func NewStateConsumer

func NewStateConsumer() (*StateConsumer, error)

NewStateConsumer returns a new state consumer.

func (*StateConsumer) Close

func (sc *StateConsumer) Close() error

Close the consumer.

type TaskConsumer

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

TaskConsumer consumed tasks messages from a Kafka topic to maintain the tasks database.

func NewTaskConsumer

func NewTaskConsumer() (*TaskConsumer, error)

NewTaskConsumer returns a new task consumer.

func (*TaskConsumer) Close

func (tc *TaskConsumer) Close() error

Close the consumer.