servicesconn

Documentation

Index

• func NewQuietStream() *health.Stream
• func NewRedisConn(opts *redis.Options) (*redis.Client, error)
• func NewStream() *health.Stream
• func NewStreamDBDups() *health.Stream
• type Connections
  • func NewConnections(s *health.Stream, quietStream *health.Stream, streamDBDedup *health.Stream, ...) *Connections
  • func NewConnectionsFromConfig(conf cfg.Services, ro bool) (*Connections, error)
  • func NewDBFromConfig(conf cfg.Services, ro bool) (*Connections, error)
  • func (c Connections) Cache() cache.Cache
  • func (c Connections) Close() error
  • func (c Connections) DB() *db.Conn
  • func (c Connections) QuietStream() *health.Stream
  • func (c Connections) Redis() *redis.Client
  • func (c Connections) Stream() *health.Stream
  • func (c Connections) StreamDBDedup() *health.Stream
• type WriterSinkExcludeDBDups
  • func (s *WriterSinkExcludeDBDups) EmitComplete(job string, status health.CompletionStatus, nanos int64, kvs map[string]string)
  • func (s *WriterSinkExcludeDBDups) EmitEvent(job string, event string, kvs map[string]string)
  • func (s *WriterSinkExcludeDBDups) EmitEventErr(job string, event string, inputErr error, kvs map[string]string)
  • func (s *WriterSinkExcludeDBDups) EmitGauge(job string, event string, value float64, kvs map[string]string)
  • func (s *WriterSinkExcludeDBDups) EmitTiming(job string, event string, nanos int64, kvs map[string]string)

Functions

func NewQuietStream

func NewQuietStream() *health.Stream

func NewRedisConn

func NewRedisConn(opts *redis.Options) (*redis.Client, error)

func NewStream

func NewStream() *health.Stream

func NewStreamDBDups

func NewStreamDBDups() *health.Stream

Types

type Connections

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

func NewConnections

func NewConnections(s *health.Stream, quietStream *health.Stream, streamDBDedup *health.Stream, db *db.Conn, r *redis.Client) *Connections

func NewConnectionsFromConfig

func NewConnectionsFromConfig(conf cfg.Services, ro bool) (*Connections, error)

func NewDBFromConfig

func NewDBFromConfig(conf cfg.Services, ro bool) (*Connections, error)

func (Connections) Cache

func (c Connections) Cache() cache.Cache

func (Connections) Close

func (c Connections) Close() error

func (Connections) DB

func (c Connections) DB() *db.Conn

func (Connections) QuietStream

func (c Connections) QuietStream() *health.Stream

func (Connections) Redis

func (c Connections) Redis() *redis.Client

func (Connections) Stream

func (c Connections) Stream() *health.Stream

func (Connections) StreamDBDedup

func (c Connections) StreamDBDedup() *health.Stream

type WriterSinkExcludeDBDups

type WriterSinkExcludeDBDups struct {
	io.Writer
}

func (*WriterSinkExcludeDBDups) EmitComplete

func (s *WriterSinkExcludeDBDups) EmitComplete(job string, status health.CompletionStatus, nanos int64, kvs map[string]string)

func (*WriterSinkExcludeDBDups) EmitEvent

func (s *WriterSinkExcludeDBDups) EmitEvent(job string, event string, kvs map[string]string)

func (*WriterSinkExcludeDBDups) EmitEventErr

func (s *WriterSinkExcludeDBDups) EmitEventErr(job string, event string, inputErr error, kvs map[string]string)

func (*WriterSinkExcludeDBDups) EmitGauge

func (s *WriterSinkExcludeDBDups) EmitGauge(job string, event string, value float64, kvs map[string]string)

func (*WriterSinkExcludeDBDups) EmitTiming

func (s *WriterSinkExcludeDBDups) EmitTiming(job string, event string, nanos int64, kvs map[string]string)