Documentation
¶
Overview ¶
Package download implements low-level OPA bundle downloading.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Polling PollingConfig `json:"polling"`
}
Config represents the configuration for the downloader.
func (*Config) ValidateAndInjectDefaults ¶
ValidateAndInjectDefaults checks for configuration errors and ensures all values are set on the Config object.
type Downloader ¶
type Downloader struct {
// contains filtered or unexported fields
}
Downloader implements low-level OPA bundle downloading. Downloader can be started and stopped. After starting, the downloader will request bundle updates from the remote HTTP endpoint that the client is configured to connect to.
func New ¶
func New(config Config, client rest.Client, path string) *Downloader
New returns a new Downloader that can be started.
func (*Downloader) Start ¶
func (d *Downloader) Start(ctx context.Context)
Start tells the Downloader to begin downloading bundles.
func (*Downloader) Stop ¶
func (d *Downloader) Stop(ctx context.Context)
Stop tells the Downloader to stop begin downloading bundles.
func (*Downloader) WithCallback ¶
func (d *Downloader) WithCallback(f func(context.Context, Update)) *Downloader
WithCallback registers a function f to be called when download updates occur.
func (*Downloader) WithLogAttrs ¶
func (d *Downloader) WithLogAttrs(attrs [][2]string) *Downloader
WithLogAttrs sets an optional set of key/value pair attributes to include in log messages emitted by the downloader.
type PollingConfig ¶
type PollingConfig struct {
MinDelaySeconds *int64 `json:"min_delay_seconds,omitempty"` // min amount of time to wait between successful poll attempts
MaxDelaySeconds *int64 `json:"max_delay_seconds,omitempty"` // max amount of time to wait between poll attempts
}
PollingConfig represents polling configuration for the downloader.
Source Files