nats

Documentation

Index

• func CreateAppJwt(seed string) (string, error)
• type Config
• type Handler
• type MultiError
  • func (me MultiError) Error() string
• type NatsService
  • func Connect(cfg Config) (*NatsService, error)
  • func MustConnect(cfg Config) *NatsService
  • func (sn *NatsService) AddHandler(subject string, handlerFn Handler)
  • func (sn *NatsService) CloseConnection()
  • func (sn *NatsService) Serve(ctx context.Context) (err error)
• type Payload

Functions

func CreateAppJwt

func CreateAppJwt(seed string) (string, error)

Types

type Config

type Config struct {
	URI  string
	Opts []nats.Option
}

type Handler

type Handler func([]byte) error

type MultiError

type MultiError []error

func (MultiError) Error

func (me MultiError) Error() string

type NatsService

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

func Connect

func Connect(cfg Config) (*NatsService, error)

func MustConnect

func MustConnect(cfg Config) *NatsService

func (*NatsService) AddHandler

func (sn *NatsService) AddHandler(subject string, handlerFn Handler)

func (*NatsService) CloseConnection

func (sn *NatsService) CloseConnection()

func (*NatsService) Serve

func (sn *NatsService) Serve(ctx context.Context) (err error)

type Payload

type Payload struct {
	Jti  string                 `json:"jti"`
	Iat  int64                  `json:"iat"`
	Iss  string                 `json:"iss"`
	Name string                 `json:"name"`
	Sub  string                 `json:"sub"`
	Nats map[string]interface{} `json:"nats"`
}