run

Documentation

Index

• type Command
  • func New(config *Config) (*Command, error)
  • func (c *Command) Close() error
  • func (c *Command) Open() error
  • func (c *Command) WithLogger(logger *zap.Logger)
• type Config
  • func NewConfig() *Config

Types

type Command

type Command struct {
	Config *Config
	Logger *zap.Logger

	GRPCd    *grpcd.GRPCd
	Kafka    *kafka.Service
	Httpd    *httpd.Service
	Influxdb *influxdb.Service

	Closing chan struct{}
	Closed  chan struct{}
}

func New

func New(config *Config) (*Command, error)

func (*Command) Close

func (c *Command) Close() error

func (*Command) Open

func (c *Command) Open() error

func (*Command) WithLogger

func (c *Command) WithLogger(logger *zap.Logger)

type Config

type Config struct {
	GRPCDConfig    grpcd.Config     `yaml:"grpcd" mapstructure:"grpcd"`
	KafkaConfig    kafka.Config     `yaml:"kafka" mapstructure:"kafka"`
	HttpdConfig    util.HTTPdConfig `yaml:"httpd" mapstructure:"httpd"`
	InfluxdbConfig influxdb.Config  `yaml:"influxdb" mapstructure:"influxdb"`
}

func NewConfig

func NewConfig() *Config