common

Documentation

Index

• Variables
• type AggregateFunction
• type Option
  • func AggregateOverTimeFunc(f AggregateFunction) Option
  • func EndTime(t *time.Time) Option
  • func StartTime(t *time.Time) Option
  • func StepTime(d *time.Duration) Option
  • func Timeout(t *time.Time) Option
• type Options
  • func NewDefaultOptions() Options
• type Order
• type QueryCondition
  • func BuildQueryCondition(condition *Common.QueryCondition) QueryCondition
  • func BuildQueryConditionV1(condition *DatahubV1alpha1.QueryCondition) *QueryCondition
  • func NewQueryCondition(days, hours, seconds, steps int) *QueryCondition

Variables

var (
	AggregationOverTime = map[AggregateFunction]string{
		MaxOverTime: "max_over_time",
	}

	TimeRange2AggregationOverTime = map[Common.TimeRange_AggregateFunction]AggregateFunction{
		Common.TimeRange_NONE: None,
		Common.TimeRange_MAX:  MaxOverTime,
	}
)

var (
	DefaultStepTime, _ = time.ParseDuration("30s")
)

Types

type AggregateFunction

type AggregateFunction = int

Aggregate function enumerator

const (
	None        AggregateFunction = 0
	MaxOverTime AggregateFunction = 1
)

Aggregation function definition

type Option

type Option func(*Options)

func AggregateOverTimeFunc

func AggregateOverTimeFunc(f AggregateFunction) Option

func EndTime

func EndTime(t *time.Time) Option

func StartTime

func StartTime(t *time.Time) Option

func StepTime

func StepTime(d *time.Duration) Option

func Timeout

func Timeout(t *time.Time) Option

type Options

type Options struct {
	StartTime             *time.Time
	EndTime               *time.Time
	Timeout               *time.Time
	StepTime              *time.Duration
	AggregateOverTimeFunc AggregateFunction
}

func NewDefaultOptions

func NewDefaultOptions() Options

type Order

type Order = int

Order enumerator

const (
	// Represent ascending order
	Asc Order = 0
	// Represent descending order
	Desc Order = 1
)

Sort order definition

type QueryCondition

type QueryCondition struct {
	StartTime                 *time.Time
	EndTime                   *time.Time
	Timeout                   *time.Time
	StepTime                  *time.Duration
	TimestampOrder            Order
	Limit                     int
	AggregateOverTimeFunction AggregateFunction
}

QueryCondition Others query condition

func BuildQueryCondition

func BuildQueryCondition(condition *Common.QueryCondition) QueryCondition

func BuildQueryConditionV1

func BuildQueryConditionV1(condition *DatahubV1alpha1.QueryCondition) *QueryCondition

func NewQueryCondition

func NewQueryCondition(days, hours, seconds, steps int) *QueryCondition