plugin

Documentation

Index

• type Plugin
  • func New(repo repository) *Plugin
  • func (p *Plugin) CheckHealth(ctx context.Context) error
  • func (p *Plugin) Dispose()
  • func (p *Plugin) ExecQuery(ctx context.Context, q *cassandra.Query) (data.Frames, error)
  • func (p *Plugin) GetColumns(keyspace, table, needType string) ([]string, error)
  • func (p *Plugin) GetKeyspaces(ctx context.Context) ([]string, error)
  • func (p *Plugin) GetTables(keyspace string) ([]string, error)

Types

type Plugin

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

Plugin represents grafana datasource plugin.

func New

func New(repo repository) *Plugin

New returns configured Plugin.

func (*Plugin) CheckHealth

func (p *Plugin) CheckHealth(ctx context.Context) error

CheckHealth executes repository Ping method to check database health.

func (*Plugin) Dispose

func (p *Plugin) Dispose()

Dispose closes all connections to Cassandra cluster.

func (*Plugin) ExecQuery

func (p *Plugin) ExecQuery(ctx context.Context, q *cassandra.Query) (data.Frames, error)

ExecQuery executes metric query based on provided query type.

func (*Plugin) GetColumns

func (p *Plugin) GetColumns(keyspace, table, needType string) ([]string, error)

GetColumns fetches and returns Cassandra's list of columns of given type for provided keyspace and table.

func (*Plugin) GetKeyspaces

func (p *Plugin) GetKeyspaces(ctx context.Context) ([]string, error)

GetKeyspaces fetches and returns Cassandra's list of keyspaces.

func (*Plugin) GetTables

func (p *Plugin) GetTables(keyspace string) ([]string, error)

GetTables fetches and returns Cassandra's list of tables for provided keyspace.