stats

Documentation

Index

• Constants
• type Client
  • func NewClient(ctx context.Context, projectID, instanceID, databaseID, credentialFile string) (*Client, error)
• type LockStat
• type QueryStat
• type TransactionStat
• type Worker
  • func NewWorker(client *Client, statType statDuration, writer Writer) *Worker
  • func (w *Worker) Start(ctx context.Context)
  • func (w *Worker) Stop()
• type Writer
  • func NewOpenTelemetryWriter() Writer
  • func NewZapWriter(logger *zap.Logger) Writer

Constants

const (
	// StatDurationMin focus 1 minute
	StatDurationMin statDuration = iota
	// StatDuration10Min focus 10 minutes
	StatDuration10Min
	// StatDurationHour focus 1 hour
	StatDurationHour
)

Types

type Client

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

Client wrapped *spanner.Client for easy to use stats collect

func NewClient

func NewClient(ctx context.Context, projectID, instanceID, databaseID, credentialFile string) (*Client, error)

NewClient is constructor of Client

type LockStat

type LockStat struct {
	IntervalEnd        time.Time `spanner:"INTERVAL_END"`
	RowRangeStartKey   []byte    `spanner:"ROW_RANGE_START_KEY"`
	LockWaitSeconds    float64   `spanner:"LOCK_WAIT_SECONDS"`
	SampleLockRequests []struct {
		LockMode string `spanner:"lock_mode"`
		Column   string `spanner:"column"`
	} `spanner:"SAMPLE_LOCK_REQUESTS"`
}

LockStat track the lock columns during a specific time period followed https://cloud.google.com/spanner/docs/introspection/lock-statistics

type QueryStat

type QueryStat struct {
	IntervalEnd       time.Time `spanner:"INTERVAL_END"`
	Text              string    `spanner:"TEXT"`
	TextTruncated     bool      `spanner:"TEXT_TRUNCATED"`
	TextFingerprint   int64     `spanner:"TEXT_FINGERPRINT"`
	ExecutionCount    int64     `spanner:"EXECUTION_COUNT"`
	AvgLatencySeconds float64   `spanner:"AVG_LATENCY_SECONDS"`
	AvgRows           float64   `spanner:"AVG_ROWS"`
	AvgBytes          float64   `spanner:"AVG_BYTES"`
	AvgRowsScanned    float64   `spanner:"AVG_ROWS_SCANNED"`
	AvgCPUSeconds     float64   `spanner:"AVG_CPU_SECONDS"`
}

QueryStat track the queries with the highest CPU usage during a specific time period followed https://cloud.google.com/spanner/docs/query-stats-tables

type TransactionStat

type TransactionStat struct {
	IntervalEnd                   time.Time `spanner:"INTERVAL_END"`
	Fprint                        int64     `spanner:"FPRINT"`
	ReadColumns                   []string  `spanner:"READ_COLUMNS"`
	WriteConstructiveColumns      []string  `spanner:"WRITE_CONSTRUCTIVE_COLUMNS"`
	WriteDeleteTables             []string  `spanner:"WRITE_DELETE_TABLES"`
	CommitAttemptCount            int64     `spanner:"COMMIT_ATTEMPT_COUNT"`
	CommitFailedPreconditionCount int64     `spanner:"COMMIT_FAILED_PRECONDITION_COUNT"`
	CommitAbortCount              int64     `spanner:"COMMIT_ABORT_COUNT"`
	AvgParticipants               float64   `spanner:"AVG_PARTICIPANTS"`
	AvgTotalLatencySeconds        float64   `spanner:"AVG_TOTAL_LATENCY_SECONDS"`
	AvgCommitLatencySeconds       float64   `spanner:"AVG_COMMIT_LATENCY_SECONDS"`
	AvgBytes                      float64   `spanner:"AVG_BYTES"`
}

TransactionStat track the transactions during a specific time period followed https://cloud.google.com/spanner/docs/introspection/transaction-statistics

type Worker

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

Worker of stats collector

func NewWorker

func NewWorker(client *Client, statType statDuration, writer Writer) *Worker

NewWorker returns the new stats collector

func (*Worker) Start

func (w *Worker) Start(ctx context.Context)

Start the stats collector

func (*Worker) Stop

func (w *Worker) Stop()

Stop the stats collector

type Writer

type Writer interface {
	// Write stats collection to anything
	Write([]stat)
}

Writer for stats collection

func NewOpenTelemetryWriter

func NewOpenTelemetryWriter() Writer

NewOpenTelemetryWriter return new Writer of OpenTelemetry

func NewZapWriter

func NewZapWriter(logger *zap.Logger) Writer

NewZapWriter return new Writer of *zap.Logger