collector

package
v0.9.71 Latest Latest
Warning

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

Go to latest
Published: Jun 29, 2020 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config interface {
	// contains filtered or unexported methods
}

type DbConfig

type DbConfig struct {
	Name     string `toml:"name" json:"name"`
	Host     string `toml:"host" json:"host"`
	Username string `toml:"username" json:"username"`
	Password string `toml:"password" json:"password"`
	Port     uint   `toml:"port" json:"port"`
	ServerId uint32
}

type Grpc

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

func (*Grpc) GetChan

func (s *Grpc) GetChan() chan *dcp.Message

func (*Grpc) Process

func (s *Grpc) Process(stream dcp.DCPService_ProcessServer) error

func (*Grpc) Start

func (s *Grpc) Start()

func (*Grpc) Stop

func (s *Grpc) Stop()

type GrpcConfig

type GrpcConfig struct {
	Port int
}

type Interface

type Interface interface {
	GetChan() chan *dcp.Message
	Start()
	Stop()
}

func NewGrpc

func NewGrpc(config *GrpcConfig) Interface

func NewMysqlCollector

func NewMysqlCollector(config *MysqlConfig) Interface

NewMysqlCollector creates a new collector. There should be ONE collector per mysql instance

type Mysql

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

func (*Mysql) GetChan

func (c *Mysql) GetChan() chan *dcp.Message

func (*Mysql) Start

func (c *Mysql) Start()

func (*Mysql) Stop

func (c *Mysql) Stop()

type MysqlConfig

type MysqlConfig struct {
	Db         DbConfig
	TagConfigs []TagConfig
}

type SchemaAndTable

type SchemaAndTable struct {
	Schema        string
	Table         string
	PrimaryKeyIdx int
}

type TagConfig

type TagConfig struct {
	Tag    string
	Tables []SchemaAndTable
}

Jump to

Keyboard shortcuts

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