consumer

Documentation

Index

• type Consumer
  • func NewConsumer(logger zerolog.Logger, stanConn stan.Conn, ...) Consumer
  • func (c Consumer) GracefulStop()
  • func (c Consumer) ProcessAsync(id primitive.ObjectID, req *parser.GetListRequest) (err error)
  • func (c Consumer) Serve() (err error)
  • func (c Consumer) Subscribe() (err error)
• type ProcessAsync

Types

type Consumer

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

func NewConsumer

func NewConsumer(
	logger zerolog.Logger,
	stanConn stan.Conn,
	exporterBucket exporter_bucket.ExporterBucket,
	companyClient parser.CompanyClient,
	fileModel file.Model,
	rowModel row.Model,
	cachedExportModel cached_export.Model,
	processingExportModel processing_export.Model,
	serviceName string,
) Consumer

func (Consumer) GracefulStop

func (c Consumer) GracefulStop()

func (Consumer) ProcessAsync

func (c Consumer) ProcessAsync(id primitive.ObjectID, req *parser.GetListRequest) (err error)

func (Consumer) Serve

func (c Consumer) Serve() (err error)

func (Consumer) Subscribe

func (c Consumer) Subscribe() (err error)

type ProcessAsync

type ProcessAsync func(primitive.ObjectID, *parser.GetListRequest) error