cache

Documentation

Index

• Constants
• Variables
• func ConvertNamedParams(sql string, namedArgs map[string]interface{}) (string, []interface{})
• func ConvertNamedParamsDebug(sql string, namedArgs map[string]interface{}) string
• func NewPostgresCache(pool *pgxpool.Pool) *postgresCache
• type Cache
• type Querier
• type QueryParams
  • func ParseQuery(c echo.Context) (*QueryParams, error)
  • func (q QueryParams) ExecuteDetails(ctx context.Context, db Querier) ([]pkg.Timeseries, error)
  • func (q QueryParams) ExecuteSummary(db Querier) (pkg.Checks, error)
  • func (q QueryParams) GetEndTime() *time.Time
  • func (q QueryParams) GetStartTime() *time.Time
  • func (q QueryParams) GetWhereClause() (string, map[string]interface{}, error)
  • func (q QueryParams) String() string
  • func (q QueryParams) Validate() error

Constants

const AllStatuses = -1

Variables

var DefaultCacheCount int

var DefaultWindow string

var PostgresCache = &postgresCache{}

Functions

func ConvertNamedParams

func ConvertNamedParams(sql string, namedArgs map[string]interface{}) (string, []interface{})

func ConvertNamedParamsDebug

func ConvertNamedParamsDebug(sql string, namedArgs map[string]interface{}) string

func NewPostgresCache

func NewPostgresCache(pool *pgxpool.Pool) *postgresCache

Types

type Cache

type Cache interface {
	Add(check pkg.Check, status ...pkg.CheckStatus)
	GetDetails(checkkey string, time string) interface{}
	RemoveChecks(canary v1.Canary)
	Query(q QueryParams) (pkg.Checks, error)
	QueryStatus(q QueryParams) ([]pkg.Timeseries, error)
	RemoveCheckByKey(key string)
}

type Querier

type Querier interface {
	Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
}

type QueryParams

type QueryParams struct {
	Check           string
	CanaryID        string
	Start, End      string
	Window          string
	IncludeMessages bool
	IncludeDetails  bool

	StatusCount    int
	Labels         map[string]string
	Trace          bool
	WindowDuration time.Duration
	// contains filtered or unexported fields
}

func ParseQuery

func ParseQuery(c echo.Context) (*QueryParams, error)

func (QueryParams) ExecuteDetails

func (q QueryParams) ExecuteDetails(ctx context.Context, db Querier) ([]pkg.Timeseries, error)

func (QueryParams) ExecuteSummary

func (q QueryParams) ExecuteSummary(db Querier) (pkg.Checks, error)

func (QueryParams) GetEndTime

func (q QueryParams) GetEndTime() *time.Time

func (QueryParams) GetStartTime

func (q QueryParams) GetStartTime() *time.Time

func (QueryParams) GetWhereClause

func (q QueryParams) GetWhereClause() (string, map[string]interface{}, error)

func (QueryParams) String

func (q QueryParams) String() string

func (QueryParams) Validate

func (q QueryParams) Validate() error