config

Documentation

Index

• type Config
• type Dataset
• type DurationThreshold
  • func (d DurationThreshold) MarshalText() (text []byte, err error)
  • func (d *DurationThreshold) UnmarshalText(text []byte) error
• type FreshnessResult
  • func CheckFreshness(config Config, current time.Time, opts ...option.ClientOption) (oldTables []FreshnessResult, err error)
• type Project
• type TableConfig
• type TimeThreshold
  • func (t TimeThreshold) MarshalText() (text []byte, err error)
  • func (t *TimeThreshold) UnmarshalText(text []byte) error

Types

type Config

type Config struct {
	Project []Project
}

type Dataset

type Dataset struct {
	ID          string
	TableConfig []TableConfig
}

type DurationThreshold

type DurationThreshold struct {
	time.Duration
}

func (DurationThreshold) MarshalText

func (d DurationThreshold) MarshalText() (text []byte, err error)

func (*DurationThreshold) UnmarshalText

func (d *DurationThreshold) UnmarshalText(text []byte) error

type FreshnessResult

type FreshnessResult struct {
	Table  string
	Reason []string
}

func CheckFreshness

func CheckFreshness(config Config, current time.Time, opts ...option.ClientOption) (oldTables []FreshnessResult, err error)

CheckFreshness returns old tables whose last modified time is oldeer than time threshold on the config file.

type Project

type Project struct {
	ID      string
	Dataset []Dataset
}

type TableConfig

type TableConfig struct {
	Table             string
	DateForShards     string
	TimeThreshold     *TimeThreshold
	DurationThreshold *DurationThreshold
}

type TimeThreshold

type TimeThreshold struct {
	time.Time
}

func (TimeThreshold) MarshalText

func (t TimeThreshold) MarshalText() (text []byte, err error)

func (*TimeThreshold) UnmarshalText

func (t *TimeThreshold) UnmarshalText(text []byte) error