view

Documentation

Index

• type MappingRule
  • func (m *MappingRule) Equal(other *MappingRule) bool
• type MappingRuleSnapshots
• type MappingRules
• type MappingRulesByNameAsc
  • func (a MappingRulesByNameAsc) Len() int
  • func (a MappingRulesByNameAsc) Less(i, j int) bool
  • func (a MappingRulesByNameAsc) Swap(i, j int)
• type Namespace
• type Namespaces
• type RollupRule
  • func (r *RollupRule) Equal(other *RollupRule) bool
• type RollupRuleSnapshots
• type RollupRules
• type RollupRulesByNameAsc
  • func (a RollupRulesByNameAsc) Len() int
  • func (a RollupRulesByNameAsc) Less(i, j int) bool
  • func (a RollupRulesByNameAsc) Swap(i, j int)
• type RollupTarget
  • func (t *RollupTarget) Equal(other *RollupTarget) bool
• type RuleSet
  • func (r *RuleSet) Sort()
• type RuleSets
  • func (rss RuleSets) Sort()

Types

type MappingRule

type MappingRule struct {
	ID                  string                 `json:"id,omitempty"`
	Name                string                 `json:"name" validate:"required"`
	Tombstoned          bool                   `json:"tombstoned"`
	CutoverMillis       int64                  `json:"cutoverMillis,omitempty"`
	Filter              string                 `json:"filter" validate:"required"`
	AggregationID       aggregation.ID         `json:"aggregation"`
	StoragePolicies     policy.StoragePolicies `json:"storagePolicies"`
	DropPolicy          policy.DropPolicy      `json:"dropPolicy"`
	LastUpdatedBy       string                 `json:"lastUpdatedBy"`
	LastUpdatedAtMillis int64                  `json:"lastUpdatedAtMillis"`
}

MappingRule is a mapping rule model at a given point in time.

func (*MappingRule) Equal

func (m *MappingRule) Equal(other *MappingRule) bool

Equal determines whether two mapping rules are equal.

type MappingRuleSnapshots

type MappingRuleSnapshots struct {
	MappingRules []MappingRule `json:"mappingRules"`
}

MappingRuleSnapshots contains a list of mapping rule snapshots.

type MappingRules

type MappingRules map[string][]MappingRule

MappingRules belonging to a ruleset indexed by uuid. Each value contains the entire snapshot history of the rule.

type MappingRulesByNameAsc

type MappingRulesByNameAsc []MappingRule

MappingRulesByNameAsc sorts mapping rules by name in ascending order.

func (MappingRulesByNameAsc) Len

func (a MappingRulesByNameAsc) Len() int

func (MappingRulesByNameAsc) Less

func (a MappingRulesByNameAsc) Less(i, j int) bool

func (MappingRulesByNameAsc) Swap

func (a MappingRulesByNameAsc) Swap(i, j int)

type Namespace

type Namespace struct {
	ID                  string `json:"id" validate:"required"`
	ForRuleSetVersion   int    `json:"forRuleSetVersion"`
	Tombstoned          bool   `json:"tombstoned"`
	LastUpdatedBy       string `json:"lastUpdatedBy"`
	LastUpdatedAtMillis int64  `json:"lastUpdatedAtMillis"`
}

Namespace is a common json serializable namespace.

type Namespaces

type Namespaces struct {
	Version    int         `json:"version"`
	Namespaces []Namespace `json:"namespaces"`
}

Namespaces is a common json serializable list of namespaces.

type RollupRule

type RollupRule struct {
	ID                  string         `json:"id,omitempty"`
	Name                string         `json:"name" validate:"required"`
	Tombstoned          bool           `json:"tombstoned"`
	CutoverMillis       int64          `json:"cutoverMillis,omitempty"`
	Filter              string         `json:"filter" validate:"required"`
	Targets             []RollupTarget `json:"targets" validate:"required,dive,required"`
	LastUpdatedBy       string         `json:"lastUpdatedBy"`
	LastUpdatedAtMillis int64          `json:"lastUpdatedAtMillis"`
}

RollupRule is rollup rule model.

func (*RollupRule) Equal

func (r *RollupRule) Equal(other *RollupRule) bool

Equal determines whether two rollup rules are equal.

type RollupRuleSnapshots

type RollupRuleSnapshots struct {
	RollupRules []RollupRule `json:"rollupRules"`
}

RollupRuleSnapshots contains a list of rollup rule snapshots.

type RollupRules

type RollupRules map[string][]RollupRule

RollupRules belong to a ruleset indexed by uuid. Each value contains the entire snapshot history of the rule.

type RollupRulesByNameAsc

type RollupRulesByNameAsc []RollupRule

RollupRulesByNameAsc sorts rollup rules by name in ascending order.

func (RollupRulesByNameAsc) Len

func (a RollupRulesByNameAsc) Len() int

func (RollupRulesByNameAsc) Less

func (a RollupRulesByNameAsc) Less(i, j int) bool

func (RollupRulesByNameAsc) Swap

func (a RollupRulesByNameAsc) Swap(i, j int)

type RollupTarget

type RollupTarget struct {
	Pipeline        pipeline.Pipeline      `json:"pipeline" validate:"required"`
	StoragePolicies policy.StoragePolicies `json:"storagePolicies" validate:"required"`
}

RollupTarget is a rollup target model.

func (*RollupTarget) Equal

func (t *RollupTarget) Equal(other *RollupTarget) bool

Equal determines whether two rollup targets are equal.

type RuleSet

type RuleSet struct {
	Namespace     string        `json:"id"`
	Version       int           `json:"version"`
	CutoverMillis int64         `json:"cutoverMillis"`
	MappingRules  []MappingRule `json:"mappingRules"`
	RollupRules   []RollupRule  `json:"rollupRules"`
}

RuleSet is a snapshot of the rule set at a given point in time.

func (*RuleSet) Sort

func (r *RuleSet) Sort()

Sort sorts the rules in the ruleset.

type RuleSets

type RuleSets map[string]*RuleSet

RuleSets is a collection of rulesets.

func (RuleSets) Sort

func (rss RuleSets) Sort()

Sort sorts each ruleset based on it's own sort method.