reconciler

Documentation

Index

• func NewComponentReconciler(o *Options, reconcilerName string, ...) (*service.ComponentReconciler, error)
• type Options
  • func NewOptions(o *cli.Options) *Options
  • func (o *Options) Validate() error
• type RecurringTaskConfig
• type RetryConfig
• type ServerConfig
• type WorkerConfig

Functions

func NewComponentReconciler

func NewComponentReconciler(o *Options, reconcilerName string, reconcilerMetricsSet *metrics.ReconcilerMetricsSet) (*service.ComponentReconciler, error)

Types

type Options

type Options struct {
	*cli.Options
	Workspace             string
	ServerConfig          *ServerConfig
	WorkerConfig          *WorkerConfig
	RetryConfig           *RetryConfig
	HeartbeatSenderConfig *RecurringTaskConfig
	ProgressTrackerConfig *RecurringTaskConfig
	DryRun                bool
}

func NewOptions

func NewOptions(o *cli.Options) *Options

func (*Options) Validate

func (o *Options) Validate() error

type RecurringTaskConfig

type RecurringTaskConfig struct {
	Interval time.Duration
	Timeout  time.Duration
}

type RetryConfig

type RetryConfig struct {
	MaxRetries int
	RetryDelay time.Duration
}

type ServerConfig

type ServerConfig struct {
	Port       int
	SSLCrtFile string
	SSLKeyFile string
}

type WorkerConfig

type WorkerConfig struct {
	Workers int
	Timeout time.Duration
}