simple

Documentation

Index

• type Inquirer
  • func NewTimestreamInquire(sdk timestreamsdk.TimestreamQueryIface) Inquirer
• type NewTimestreamRecorderInput
• type PerDayInput
• type RecordOfDay
• type Recorder
  • func NewTimestreamRecorder(in *NewTimestreamRecorderInput) Recorder

Types

type Inquirer

type Inquirer interface {
	PerDay(ctx context.Context, in PerDayInput) ([]RecordOfDay, error)
}

func NewTimestreamInquire

func NewTimestreamInquire(sdk timestreamsdk.TimestreamQueryIface) Inquirer

type NewTimestreamRecorderInput

type NewTimestreamRecorderInput struct {
	TimestreamWrite timestreamsdk.TimestreamWriteIface
	DatabaseName    string
	TableName       string
	MeasureName     string
}

type PerDayInput

type PerDayInput struct {
	Days         uint32
	Location     *time.Location
	DatabaseName string
	TableName    string
}

type RecordOfDay

type RecordOfDay struct {
	Date time.Time
	Sum  uint64
}

type Recorder

type Recorder interface {
	// Do writes one time series data.
	// MeasureValue: 1
	// MeasureValueType: BIGINT
	// TimeUnit: NANOSECONDS
	// Dimensions[0].Name: N
	// Dimensions[0].Value: N
	Do(ctx context.Context, t time.Time) error
}

Recorder provides simple recording functions for Amazon Timestream.

func NewTimestreamRecorder

func NewTimestreamRecorder(in *NewTimestreamRecorderInput) Recorder