natsx

Documentation

Index

• func Log(bc string) nats_protobuf.Filter
• func Url(c Config) string
• type Config
  • func (c Config) String() string
• type Func
  • func Singleton(nc *nats.Conn, subject string, interval time.Duration, fn Func) (<-chan struct{}, Func)

Functions

func Log

func Log(bc string) nats_protobuf.Filter

Log provides the standardized logging service for nats queries

func Url

func Url(c Config) string

Url provides a string usable for nats.Connect

Types

type Config

type Config struct {
	Url      string
	Username string
	Password string
}

Config provides common NATs configuraiton

func (Config) String

func (c Config) String() string

String returns configuration as a string (sans username and password)

type Func

type Func func(ctx context.Context) error

Func defines a function for use by Singleton

func Singleton

func Singleton(nc *nats.Conn, subject string, interval time.Duration, fn Func) (<-chan struct{}, Func)

Singleton ensures that only one instance of a long running function will be running at a time