Documentation
¶
Index ¶
- func MustNewKafkaBackend(name string, bconf *config.Transport_kafka) newcore.Publication
- func NewFileBackend(name string, conf *config.Transport_file) (newcore.Publication, error)
- func NewInfluxdbBackend(name string, conf *config.Transport_influxdb) (newcore.Publication, error)
- func UseConfigCreateBackends(rconf config.RuntimeConfig) ([]newcore.Publication, error)
- type InfluxdbClient
- type InfluxdbClient_v088
- func (c *InfluxdbClient_v088) IsCompatibleVersion(v string) bool
- func (c *InfluxdbClient_v088) Ping() (time.Duration, string, error)
- func (c *InfluxdbClient_v088) Query(q client090.Query) (*client090.Results, error)
- func (c *InfluxdbClient_v088) Version() string
- func (c *InfluxdbClient_v088) Write(bp client090.BatchPoints) (*client090.Results, error)
- type InfluxdbClient_v090_rc7
- func (c *InfluxdbClient_v090_rc7) IsCompatibleVersion(v string) bool
- func (c *InfluxdbClient_v090_rc7) Ping() (time.Duration, string, error)
- func (c *InfluxdbClient_v090_rc7) Query(q client090.Query) (*client090.Results, error)
- func (c *InfluxdbClient_v090_rc7) Version() string
- func (c *InfluxdbClient_v090_rc7) Write(bp client090.BatchPoints) (*client090.Results, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustNewKafkaBackend ¶ added in v0.2.1
func MustNewKafkaBackend(name string, bconf *config.Transport_kafka) newcore.Publication
func NewFileBackend ¶ added in v0.2.0
func NewFileBackend(name string, conf *config.Transport_file) (newcore.Publication, error)
func NewInfluxdbBackend ¶ added in v0.2.0
func NewInfluxdbBackend(name string, conf *config.Transport_influxdb) (newcore.Publication, error)
func UseConfigCreateBackends ¶ added in v0.2.0
func UseConfigCreateBackends(rconf config.RuntimeConfig) ([]newcore.Publication, error)
Types ¶
type InfluxdbClient ¶
type InfluxdbClient interface {
Version() string
Ping() (time.Duration, string, error)
Write(client090.BatchPoints) (*client090.Results, error)
Query(client090.Query) (*client090.Results, error)
IsCompatibleVersion(v string) bool
}
func NewInfluxdbClient ¶
func NewInfluxdbClient(conf map[string]interface{}, version string) (InfluxdbClient, error)
type InfluxdbClient_v088 ¶
type InfluxdbClient_v088 struct {
// contains filtered or unexported fields
}
func NewInfluxdbClient_v088 ¶
func NewInfluxdbClient_v088(conf map[string]interface{}) (*InfluxdbClient_v088, error)
func (*InfluxdbClient_v088) IsCompatibleVersion ¶
func (c *InfluxdbClient_v088) IsCompatibleVersion(v string) bool
func (*InfluxdbClient_v088) Ping ¶
func (c *InfluxdbClient_v088) Ping() (time.Duration, string, error)
func (*InfluxdbClient_v088) Version ¶
func (c *InfluxdbClient_v088) Version() string
func (*InfluxdbClient_v088) Write ¶
func (c *InfluxdbClient_v088) Write(bp client090.BatchPoints) (*client090.Results, error)
type InfluxdbClient_v090_rc7 ¶
type InfluxdbClient_v090_rc7 struct {
// contains filtered or unexported fields
}
func NewInfluxdbClient_v090_rc7 ¶
func NewInfluxdbClient_v090_rc7(conf map[string]interface{}) (*InfluxdbClient_v090_rc7, error)
func (*InfluxdbClient_v090_rc7) IsCompatibleVersion ¶
func (c *InfluxdbClient_v090_rc7) IsCompatibleVersion(v string) bool
func (*InfluxdbClient_v090_rc7) Ping ¶
func (c *InfluxdbClient_v090_rc7) Ping() (time.Duration, string, error)
func (*InfluxdbClient_v090_rc7) Version ¶
func (c *InfluxdbClient_v090_rc7) Version() string
func (*InfluxdbClient_v090_rc7) Write ¶
func (c *InfluxdbClient_v090_rc7) Write(bp client090.BatchPoints) (*client090.Results, error)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.