broker

package
v0.0.17 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker

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

func NewBroker added in v0.0.6

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

type Redis added in v0.0.6

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

func NewRedis added in v0.0.6

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

func (*Redis) Run added in v0.0.6

func (b *Redis) Run()

type Runner added in v0.0.6

type Runner interface {
	Run()
}

type Server

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

func NewServer added in v0.0.6

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

func (*Server) Run

func (b *Server) Run()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL