consumer

package
v1.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 2, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL