influxdbv2

Documentation

Index

• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Client
  • func NewClient(cfg *Config) *Client
  • func (c *Client) Close()
  • func (c *Client) ID() string
  • func (c *Client) Write(point monitor_entry.IPoint) error
• type Config

Functions

func Create

func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

func NewFactory

func NewFactory() eosc.IExtenderDriverFactory

NewFactory 创建service_http驱动工厂

func Register

func Register(register eosc.IExtenderDriverRegister)

Types

type Client

type Client struct {
	influxdb2.Client
	api.WriteAPI
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cfg *Config) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) ID

func (c *Client) ID() string

func (*Client) Write

func (c *Client) Write(point monitor_entry.IPoint) error

type Config

type Config struct {
	Scopes []string `json:"scopes" label:"作用域"`
	Url    string   `json:"url"`
	Org    string   `json:"org"`
	Bucket string   `json:"bucket"`
	Token  string   `json:"token"`
}