Documentation ¶ Index ¶ type Consumer func NewConsumer(logger zerolog.Logger, stanConn stan.Conn, serviceName string, ...) Consumer func (c Consumer) GracefulStop() func (c Consumer) Serve() (err error) func (c Consumer) Subscribe() (err error) 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, serviceName string, dadataClient dadata.Client, orgModel org.Model, areaModel area.Model, locationModel location.Model, managerModel manager.Model, okvedModel okved.Model, metroModel metro.Model, ) Consumer func (Consumer) GracefulStop ¶ func (c Consumer) GracefulStop() func (Consumer) Serve ¶ func (c Consumer) Serve() (err error) func (Consumer) Subscribe ¶ func (c Consumer) Subscribe() (err error) Source Files ¶ View all Source files consumer.go consumer_cb.go consumer_graceful_stop.go consumer_poll_sub_is_valid.go consumer_serve.go consumer_subscribe.go new_consumer.go Click to show internal directories. Click to hide internal directories.