cassandra

package
v0.0.0-...-cc24bb4 Latest Latest
Warning

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

Go to latest
Published: Nov 18, 2016 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidDataType = errors.New("Invalid data type value found - %v")
)

Functions

func Meta

func Meta() *plugin.PluginMeta

Meta returns a plugin meta data

func NewCassaClient

func NewCassaClient(co clientOptions, tagIndex string) *cassaClient

NewCassaClient creates a new instance of a cassandra client.

Types

type CassandraPublisher

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

CassandraPublisher defines Cassandra publisher

func NewCassandraPublisher

func NewCassandraPublisher() *CassandraPublisher

NewCassandraPublisher returns an instance of the Cassandra publisher Client is not initiated until the first data publish happends.

func (*CassandraPublisher) Close

func (cas *CassandraPublisher) Close()

Close closes the Cassandra client session

func (*CassandraPublisher) GetConfigPolicy

func (cas *CassandraPublisher) GetConfigPolicy() (*cpolicy.ConfigPolicy, error)

GetConfigPolicy returns plugin mandatory fields as the config policy

func (*CassandraPublisher) Publish

func (cas *CassandraPublisher) Publish(contentType string, content []byte, config map[string]ctypes.ConfigValue) error

Publish publishes metric data to Cassandra

Jump to

Keyboard shortcuts

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