config

Documentation

Index

• type Duration
  • func (d Duration) Duration() time.Duration
  • func (d *Duration) UnmarshalJSON(data []byte) error
  • func (d *Duration) UnmarshalYAML(value *yaml.Node) error
• type LoggingConfig
• type RuntimeConfig
• type RuntimeReconciliationConfig
  • func (c RuntimeReconciliationConfig) Validate() error
• type ServeConfig
  • func DefaultServeConfig() ServeConfig
  • func LoadServeConfig(path string) (ServeConfig, error)
  • func (c ServeConfig) Validate() error
• type ServerConfig
• type SinkConfig

Types

type Duration

type Duration time.Duration

func (Duration) Duration

func (d Duration) Duration() time.Duration

func (*Duration) UnmarshalJSON

func (d *Duration) UnmarshalJSON(data []byte) error

func (*Duration) UnmarshalYAML

func (d *Duration) UnmarshalYAML(value *yaml.Node) error

type LoggingConfig

type LoggingConfig struct {
	Structured bool `json:"structured" yaml:"structured"`
}

type RuntimeConfig

type RuntimeConfig struct {
	FlushInterval    Duration                    `json:"flush_interval" yaml:"flush_interval"`
	WindowSize       Duration                    `json:"window_size" yaml:"window_size"`
	MaxInMemorySpans int                         `json:"max_in_memory_spans" yaml:"max_in_memory_spans"`
	LateSpanPolicy   string                      `json:"late_span_policy" yaml:"late_span_policy"`
	Reconciliation   RuntimeReconciliationConfig `json:"reconciliation" yaml:"reconciliation"`
}

type RuntimeReconciliationConfig

type RuntimeReconciliationConfig struct {
	Enabled                        bool     `json:"enabled" yaml:"enabled"`
	StatePath                      string   `json:"state_path" yaml:"state_path"`
	ReportPath                     string   `json:"report_path" yaml:"report_path"`
	RawWindowPath                  string   `json:"raw_window_path" yaml:"raw_window_path"`
	StableCorePath                 string   `json:"stable_core_path" yaml:"stable_core_path"`
	DecayHalfLife                  Duration `json:"decay_half_life" yaml:"decay_half_life"`
	MinimumOpportunityWindows      int      `json:"minimum_opportunity_windows" yaml:"minimum_opportunity_windows"`
	TelemetryHealthFreezeThreshold float64  `json:"telemetry_health_freeze_threshold" yaml:"telemetry_health_freeze_threshold"`
	SoftGapMultiplier              float64  `json:"soft_gap_multiplier" yaml:"soft_gap_multiplier"`
	HardGapMultiplier              float64  `json:"hard_gap_multiplier" yaml:"hard_gap_multiplier"`
	MinimumSoftWindows             int      `json:"minimum_soft_windows" yaml:"minimum_soft_windows"`
	MinimumHardWindows             int      `json:"minimum_hard_windows" yaml:"minimum_hard_windows"`
	StableCoreMinBelief            float64  `json:"stable_core_min_belief" yaml:"stable_core_min_belief"`
	StableCoreMinActivity          float64  `json:"stable_core_min_activity" yaml:"stable_core_min_activity"`
	GuardrailUnionMinBelief        float64  `json:"guardrail_union_min_belief" yaml:"guardrail_union_min_belief"`
	RetirementMinBelief            float64  `json:"retirement_min_belief" yaml:"retirement_min_belief"`
	RetiredTTL                     Duration `json:"retired_ttl" yaml:"retired_ttl"`
	MaxRetainedRetiredEntities     int      `json:"max_retained_retired_entities" yaml:"max_retained_retired_entities"`
	CompactionInterval             Duration `json:"compaction_interval" yaml:"compaction_interval"`
}

func (RuntimeReconciliationConfig) Validate

func (c RuntimeReconciliationConfig) Validate() error

type ServeConfig

type ServeConfig struct {
	Server   ServerConfig  `json:"server" yaml:"server"`
	Runtime  RuntimeConfig `json:"runtime" yaml:"runtime"`
	Sink     SinkConfig    `json:"sink" yaml:"sink"`
	Logging  LoggingConfig `json:"logging" yaml:"logging"`
	Overlays []string      `json:"overlays" yaml:"overlays"`
}

func DefaultServeConfig

func DefaultServeConfig() ServeConfig

func LoadServeConfig

func LoadServeConfig(path string) (ServeConfig, error)

func (ServeConfig) Validate

func (c ServeConfig) Validate() error

type ServerConfig

type ServerConfig struct {
	ListenAddress     string `json:"listen_address" yaml:"listen_address"`
	GRPCListenAddress string `json:"grpc_listen_address" yaml:"grpc_listen_address"`
	MaxRequestBytes   int64  `json:"max_request_bytes" yaml:"max_request_bytes"`
}

type SinkConfig

type SinkConfig struct {
	Directory  string `json:"directory" yaml:"directory"`
	LatestPath string `json:"latest_path" yaml:"latest_path"`
}