Documentation ¶
Overview ¶
Package service contains the controllers to consume and process kafka messages.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct { Consumer *consumer.GroupConsumer Producer *producer.Producer RefundRequestSchema string InitialOffset int64 HandleError func(err error, offset int64, str interface{}) error Topic string Retry *resilience.ServiceRetry IsErrorConsumer bool BrokerAddr []string Payments payment.Payments PaymentsAPIURL string Client *http.Client ApiKey string }
Service represents service config for refund-request-consumer.
func New ¶
func New(consumerTopic, consumerGroupName string, InitialOffset int64, cfg *config.Config, retry *resilience.ServiceRetry) (*Service, error)
New creates a new instance of service with a given consumerGroup name, consumerTopic, throttleRate and refund-request-consumer config.
Click to show internal directories.
Click to hide internal directories.