Documentation ¶
Index ¶
- type Query
- type Session
- func (s *Session) Close()
- func (s *Session) ExecRawQuery(ctx context.Context, q *Query) (map[string][]*TimeSeriesPoint, error)
- func (s *Session) ExecStrictQuery(ctx context.Context, q *Query) ([]*TimeSeriesPoint, error)
- func (s *Session) GetColumns(keyspace, table, needType string) ([]string, error)
- func (s *Session) GetKeyspaces(ctx context.Context) ([]string, error)
- func (s *Session) GetTables(keyspace string) ([]string, error)
- func (s *Session) Ping(ctx context.Context) error
- type Settings
- type TimeSeriesPoint
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
Session is a convenience wrapper for the gocql.Session.
func (*Session) ExecRawQuery ¶
func (s *Session) ExecRawQuery(ctx context.Context, q *Query) (map[string][]*TimeSeriesPoint, error)
ExecRawQuery queries cassandra with a Query.Target query and returns a map of time series points grouped by a key column name.
func (*Session) ExecStrictQuery ¶
ExecStrictQuery queries cassandra with passed Query parameters and returns a slice of time series points.
func (*Session) GetColumns ¶
GetColumns queries the cassandra cluster for a list of an existing columns of a given type for a given keyspace, table.
func (*Session) GetKeyspaces ¶
GetKeyspaces queries the cassandra cluster for a list of existing keyspaces.
type TimeSeriesPoint ¶
Click to show internal directories.
Click to hide internal directories.