event

Documentation

Index

• type Marshaller
• type ReindexRequestedProducer
  • func (p *ReindexRequestedProducer) Checker(ctx context.Context, state *healthcheck.CheckState) error
  • func (p ReindexRequestedProducer) Close(ctx context.Context) error
  • func (p ReindexRequestedProducer) ProduceReindexRequested(ctx context.Context, event models.ReindexRequested) error

Types

type Marshaller

type Marshaller interface {
	Marshal(s interface{}) ([]byte, error)
}

Marshaller defines a type for marshalling the requested object into a stream of bytes which can be sent to the kafka producer channel

type ReindexRequestedProducer

type ReindexRequestedProducer struct {
	Marshaller Marshaller
	Producer   kafka.IProducer
}

ReindexRequestedProducer is responsible for sending a ReindexRequested event object to the supplied kafka producer, as well as cleanly closing the producer and exposing health check information

func (*ReindexRequestedProducer) Checker

func (p *ReindexRequestedProducer) Checker(ctx context.Context, state *healthcheck.CheckState) error

Checker is called by the healthcheck library to check the health state of this kafka producer instance

func (ReindexRequestedProducer) Close

func (p ReindexRequestedProducer) Close(ctx context.Context) error

Close is called when the service shuts down gracefully

func (ReindexRequestedProducer) ProduceReindexRequested

func (p ReindexRequestedProducer) ProduceReindexRequested(ctx context.Context, event models.ReindexRequested) error

ProduceReindexRequested produce a kafka message for an instance which has been successfully processed.