broker

Documentation

Index

• type Broker
  • func NewBroker(v *viper.Viper, logger *zap.Logger, influx influxdb2.Client) (*Broker, error)
• type Redis
  • func NewRedis(broker *Broker, rdb *redis.Client) (*Redis, error)
  • func (b *Redis) Run()
• type Runner
• type Server
  • func NewServer(broker *Broker) (*Server, error)
  • func (b *Server) Run()

Types

type Broker

type Broker struct {
	Org    string
	Bucket string
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker(v *viper.Viper, logger *zap.Logger, influx influxdb2.Client) (*Broker, error)

type Redis

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

func NewRedis

func NewRedis(broker *Broker, rdb *redis.Client) (*Redis, error)

func (*Redis) Run

func (b *Redis) Run()

type Runner

type Runner interface {
	Run()
}

type Server

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

func NewServer

func NewServer(broker *Broker) (*Server, error)

func (*Server) Run

func (b *Server) Run()