cassandra

Documentation

Overview

Package cassandra provides the functionality to use Cssandra as long term and distributed storage

Index

• Variables
• func CreateSchema()
• type Config
  • func NewConfig() Config
  • func (c *Config) Apply() error
  • func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
  • func (c *Config) Validate() error
• type Store
  • func CreateStore(config Config) (*Store, error)
  • func NewCassandraStore(config Config) (*Store, error)
  • func (store Store) QueryIntSeries(query common.Query) ([]common.IntSeries, error)
  • func (store Store) QueryIntSeriesBatch(queries []common.Query) ([]common.QueryResult, []common.IntSeries, error)
  • func (store Store) QuerySeries(queries []common.Query) ([]common.QueryResult, []common.Series, error)
  • func (store Store) Shutdown()
  • func (store Store) StoreType() string
  • func (store Store) WriteDoubleSeries(series []common.DoubleSeries) error
  • func (store Store) WriteIntSeries(series []common.IntSeries) error
• type StoreMap

Variables

var CassandraHost = "127.0.0.1"

Functions

func CreateSchema

func CreateSchema()

CreateSchema use naive with tag schema TODO: allow passing different configuration

Types

type Config

type Config struct {
	Host     string                 `yaml:"host" json:"host"`
	Port     int                    `yaml:"port" json:"port"`
	Keyspace string                 `yaml:"keyspace" json:"keyspace"`
	XXX      map[string]interface{} `yaml:",inline"`
}

TODO: keyspace

func NewConfig

func NewConfig() Config

func (*Config) Apply

func (c *Config) Apply() error

func (*Config) UnmarshalYAML

func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*Config) Validate

func (c *Config) Validate() error

type Store

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

Store contains a cassandra session

func CreateStore

func CreateStore(config Config) (*Store, error)

func NewCassandraStore

func NewCassandraStore(config Config) (*Store, error)

NewCassandraStore creates a new cassandra store connecting to localhost cassandra

func (Store) QueryIntSeries

func (store Store) QueryIntSeries(query common.Query) ([]common.IntSeries, error)

QueryIntSeries implements Store interface Deprecated: Use QueryIntSeriesBatch instead

func (Store) QueryIntSeriesBatch

func (store Store) QueryIntSeriesBatch(queries []common.Query) ([]common.QueryResult, []common.IntSeries, error)

QueryIntSeriesBatch implements Store interface

func (Store) QuerySeries

func (store Store) QuerySeries(queries []common.Query) ([]common.QueryResult, []common.Series, error)

func (Store) Shutdown

func (store Store) Shutdown()

func (Store) StoreType

func (store Store) StoreType() string

StoreType implements store interface

func (Store) WriteDoubleSeries

func (store Store) WriteDoubleSeries(series []common.DoubleSeries) error

WriteDoubleSeries implements Store interface

func (Store) WriteIntSeries

func (store Store) WriteIntSeries(series []common.IntSeries) error

WriteIntSeries implements Store interface

type StoreMap

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

StoreMap is used to allow multiple cassandra session, it is also used as a singleton when you are just using the default store. its methods use a RWMutex