window

Documentation

Index

• Constants
• type Config
  • func NewConfig(size, shiftBy, location, truncateTo string) (Config, error)
  • func NewCustomConfig(w models.Window) Config
  • func NewCustomConfigWithTimezone(c SimpleConfig) Config
  • func NewIncrementalConfig() Config
  • func NewPresetConfig(preset string) (Config, error)
  • func (c Config) GetOffset() string
  • func (c Config) GetSimpleConfig() SimpleConfig
  • func (c Config) GetSize() string
  • func (c Config) GetTruncateTo() string
  • func (c Config) GetVersion() int
  • func (c Config) Type() Type
• type CustomWindow
  • func FromCustomConfig(c SimpleConfig) (CustomWindow, error)
  • func NewCustomWindow(size, shiftBy duration.Duration, location *time.Location, truncateTo string) CustomWindow
  • func (w CustomWindow) GetEnd(ref time.Time) (time.Time, error)
  • func (w CustomWindow) GetInterval(ref time.Time) (interval.Interval, error)
• type IncrementalWindow
  • func FromSchedule(schedule string) (IncrementalWindow, error)
  • func (w IncrementalWindow) GetInterval(referenceTime time.Time) (interval.Interval, error)
• type OldWindow
  • func FromBaseWindow(w models.Window) OldWindow
  • func (w OldWindow) GetInterval(referenceTime time.Time) (interval.Interval, error)
• type SimpleConfig
  • func NewSimpleConfig(size, shiftBy, location, truncateTo string) (SimpleConfig, error)
• type Type
• type Window
  • func From[T WithConfig](config Config, schedule string, getter func(string) (T, error)) (Window, error)
• type WithConfig

Constants

const NewWindowVersion = 3

Types

type Config

type Config struct {
	Preset string
	// kept for backward compatibility, will be removed later
	Window models.Window
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(size, shiftBy, location, truncateTo string) (Config, error)

func NewCustomConfig

func NewCustomConfig(w models.Window) Config

func NewCustomConfigWithTimezone

func NewCustomConfigWithTimezone(c SimpleConfig) Config

func NewIncrementalConfig

func NewIncrementalConfig() Config

func NewPresetConfig

func NewPresetConfig(preset string) (Config, error)

func (Config) GetOffset

func (c Config) GetOffset() string

func (Config) GetSimpleConfig

func (c Config) GetSimpleConfig() SimpleConfig

func (Config) GetSize

func (c Config) GetSize() string

func (Config) GetTruncateTo

func (c Config) GetTruncateTo() string

func (Config) GetVersion

func (c Config) GetVersion() int

func (Config) Type

func (c Config) Type() Type

type CustomWindow

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

func FromCustomConfig

func FromCustomConfig(c SimpleConfig) (CustomWindow, error)

func NewCustomWindow

func NewCustomWindow(size, shiftBy duration.Duration, location *time.Location, truncateTo string) CustomWindow

TODO: this function is not used anywhere at the moment, consider removing it

func (CustomWindow) GetEnd

func (w CustomWindow) GetEnd(ref time.Time) (time.Time, error)

func (CustomWindow) GetInterval

func (w CustomWindow) GetInterval(ref time.Time) (interval.Interval, error)

type IncrementalWindow

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

func FromSchedule

func FromSchedule(schedule string) (IncrementalWindow, error)

func (IncrementalWindow) GetInterval

func (w IncrementalWindow) GetInterval(referenceTime time.Time) (interval.Interval, error)

type OldWindow

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

func FromBaseWindow

func FromBaseWindow(w models.Window) OldWindow

func (OldWindow) GetInterval

func (w OldWindow) GetInterval(referenceTime time.Time) (interval.Interval, error)

type SimpleConfig

type SimpleConfig struct {
	Size       string
	ShiftBy    string
	Location   string
	TruncateTo string // TODO: remove later if unused
}

func NewSimpleConfig

func NewSimpleConfig(size, shiftBy, location, truncateTo string) (SimpleConfig, error)

type Type

type Type string

const (
	Incremental Type = "incremental"
	Preset      Type = "preset"
	Custom      Type = "custom"
)

type Window

type Window interface {
	GetInterval(referenceTime time.Time) (interval.Interval, error)
}

func From

func From[T WithConfig](config Config, schedule string, getter func(string) (T, error)) (Window, error)

type WithConfig

type WithConfig interface {
	Config() SimpleConfig
}