service

Documentation

Index

• type Config
• type MsgHandler
• type Service
  • func NewService(clientID string, handlers ...map[models.EventType]MsgHandler) *Service
  • func (s *Service) ReplyWithError(request *nats.Msg, err error, msg string) error
  • func (s *Service) Start(config *Config) error

Types

type Config

type Config struct {
	RedisURL      string
	NatsURL       string
	NatsUserCreds string
	NatsKeyFile   string
}

type MsgHandler

type MsgHandler func(*Service, *nats.Msg) error

type Service

type Service struct {
	ClientID string
	Nats     f3nats.NatsConn
	Redis    redis.Conn
	PreRun   []func(*Service, *Config) error
	PostRun  []func(*Service)
	Handlers map[models.EventType]MsgHandler
	// contains filtered or unexported fields
}

func NewService

func NewService(clientID string, handlers ...map[models.EventType]MsgHandler) *Service

func (*Service) ReplyWithError

func (s *Service) ReplyWithError(request *nats.Msg, err error, msg string) error

ReplyWithError publish the error to the reply channel and returns the wrapped error.

func (*Service) Start

func (s *Service) Start(config *Config) error