consumer

Documentation

Index

• Variables
• type Consumer
  • func NewConsumer(r event.Receiver, exampleC *handler.ExampleConsumer) *Consumer
  • func (c *Consumer) Run() error
  • func (c *Consumer) Stop(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(NewConsumer, handler.NewExampleConsumer)

ProviderSet is cron providers.

Types

type Consumer

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

func NewConsumer

func NewConsumer(r event.Receiver, exampleC *handler.ExampleConsumer) *Consumer

func (*Consumer) Run

func (c *Consumer) Run() error

func (*Consumer) Stop

func (c *Consumer) Stop(ctx context.Context) error