Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidDataType = errors.New("Invalid data type value found - %v")
)
Functions ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.