tally

Documentation

Index

• type Connector
• type Option
  • func Component(c string) Option
  • func Connection(c Connector) Option
  • func Debug() Option
  • func Election(name string) Option
  • func Logger(l *logrus.Entry) Option
  • func StatsPrefix(p string) Option
• type Recorder
  • func New(opts ...Option) (recorder *Recorder, err error)
  • func (r *Recorder) Run(ctx context.Context) (err error)

Types

type Connector

type Connector interface {
	QueueSubscribe(ctx context.Context, name string, subject string, group string, output chan inter.ConnectorMessage) error
	Nats() *nats.Conn
}

Connector is a connection to the middleware

type Option

type Option func(*options)

Option configures Options

func Component

func Component(c string) Option

Component sets the component to tally

func Connection

func Connection(c Connector) Option

Connection is the middleware to receive events on

func Debug

func Debug() Option

Debug enable debug logging

func Election

func Election(name string) Option

Election enables leader election between tally instances

func Logger

func Logger(l *logrus.Entry) Option

Logger is the logger to use

func StatsPrefix

func StatsPrefix(p string) Option

StatsPrefix is the space to create stat entries in

type Recorder

type Recorder struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Recorder listens for alive events and records the versions and expose the results to Prometheus

func New

func New(opts ...Option) (recorder *Recorder, err error)

New creates a new Recorder

func (*Recorder) Run

func (r *Recorder) Run(ctx context.Context) (err error)

Run starts listening for events and record statistics about it in prometheus