consumer

Documentation

Index

• type EventConsumer
  • func NewEventConsumer(timePeriod int, timeUnit time.Duration, ctx context.Context) *EventConsumer
  • func (e *EventConsumer) Start()

Types

type EventConsumer

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

func NewEventConsumer

func NewEventConsumer(timePeriod int, timeUnit time.Duration, ctx context.Context) *EventConsumer

func (*EventConsumer) Start

func (e *EventConsumer) Start()