cassandra

Documentation

Index

• Variables
• func Meta() *plugin.PluginMeta
• func NewCassaClient(co clientOptions, tagIndex string) *cassaClient
• type CassandraPublisher
  • func NewCassandraPublisher() *CassandraPublisher
  • func (cas *CassandraPublisher) Close()
  • func (cas *CassandraPublisher) GetConfigPolicy() (*cpolicy.ConfigPolicy, error)
  • func (cas *CassandraPublisher) Publish(contentType string, content []byte, config map[string]ctypes.ConfigValue) error

Variables

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