Documentation ¶
Index ¶
- type Channel
- type DataPoint
- type GCTSDBServer
- func (c *GCTSDBServer) AddDataPoints(channel *Channel, points []DataPoint) error
- func (c *GCTSDBServer) CreateChannel(channel *Channel) error
- func (c *GCTSDBServer) DeleteChannel(channel string) error
- func (c *GCTSDBServer) GetCSession() *gocql.Session
- func (c *GCTSDBServer) GetChannel(name string) (*Channel, error)
- func (c *GCTSDBServer) GetChannels(prefix string) []Channel
- func (c *GCTSDBServer) GetDataPoints(channelName string, t1, t2 time.Time) ([]DataPoint, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GCTSDBServer ¶
type GCTSDBServer struct {
// contains filtered or unexported fields
}
func CreateGCTSDBServer ¶
func CreateGCTSDBServer(cassandraClient *cassandra.CassandraClient) (*GCTSDBServer, error)
func (*GCTSDBServer) AddDataPoints ¶
func (c *GCTSDBServer) AddDataPoints(channel *Channel, points []DataPoint) error
func (*GCTSDBServer) CreateChannel ¶
func (c *GCTSDBServer) CreateChannel(channel *Channel) error
func (*GCTSDBServer) DeleteChannel ¶
func (c *GCTSDBServer) DeleteChannel(channel string) error
func (*GCTSDBServer) GetCSession ¶
func (c *GCTSDBServer) GetCSession() *gocql.Session
func (*GCTSDBServer) GetChannel ¶
func (c *GCTSDBServer) GetChannel(name string) (*Channel, error)
func (*GCTSDBServer) GetChannels ¶
func (c *GCTSDBServer) GetChannels(prefix string) []Channel
func (*GCTSDBServer) GetDataPoints ¶
Click to show internal directories.
Click to hide internal directories.