Documentation ¶
Overview ¶
Package cassandra implements vulcan storage interfaces for persisting and reading datapoints.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupTables ¶
SetupTables sets up the provided keyspace and creates table `uncompressed` on the provided Cassandra hosts.
Types ¶
type DatapointReader ¶
type DatapointReader struct {
// contains filtered or unexported fields
}
DatapointReader represents an object that queries on the target Cassandra server and transforms the result to a Vulcan Datapoint.
func NewDatapointReader ¶
func NewDatapointReader(config *DatapointReaderConfig) (*DatapointReader, error)
NewDatapointReader creates a new instance of DatapointReader.
func (*DatapointReader) ReadDatapoints ¶
func (dpr *DatapointReader) ReadDatapoints(fqmn string, after, before bus.Timestamp) ([]bus.Datapoint, error)
ReadDatapoints implements storage.DatapointReader interface.
type DatapointReaderConfig ¶
DatapointReaderConfig represents the configuration of a DatapointReader.
type SampleWriter ¶
type SampleWriter struct {
// contains filtered or unexported fields
}
SampleWriter represents an object that writes bus messages to the target Cassandra database.
func NewSampleWriter ¶
func NewSampleWriter(config *SampleWriterConfig) (*SampleWriter, error)
NewSampleWriter creates a new instance of SampleWriter.
func (*SampleWriter) WriteSample ¶
func (sw *SampleWriter) WriteSample(s *bus.Sample) error
WriteSample implements the storage.WriteSample interface.