influxdb

Documentation

Index

• Variables
• type Collector
  • func New(s string, conf_ interface{}, opts lib.Options) (*Collector, error)
  • func (c *Collector) Collect(samples []stats.Sample)
  • func (c *Collector) Init() error
  • func (c *Collector) IsReady() bool
  • func (c *Collector) Login(conf_ interface{}, in io.Reader, out io.Writer) (interface{}, error)
  • func (c *Collector) MakeConfig() interface{}
  • func (c *Collector) Run(ctx context.Context)
  • func (c *Collector) String() string
• type Config

Variables

var (
	ErrNoDatabase = errors.New("influxdb output: no database specified")
)

Types

type Collector

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

func New

func New(s string, conf_ interface{}, opts lib.Options) (*Collector, error)

func (*Collector) Collect

func (c *Collector) Collect(samples []stats.Sample)

func (*Collector) Init

func (c *Collector) Init() error

func (*Collector) IsReady

func (c *Collector) IsReady() bool

func (*Collector) Login

func (c *Collector) Login(conf_ interface{}, in io.Reader, out io.Writer) (interface{}, error)

func (*Collector) MakeConfig

func (c *Collector) MakeConfig() interface{}

func (*Collector) Run

func (c *Collector) Run(ctx context.Context)

func (*Collector) String

func (c *Collector) String() string

type Config

type Config struct {
	DefaultURL null.String `json:"default_url,omitempty"`
}