istio: istio.io/istio/galley/pkg/config/processing/snapshotter/strategy Index | Files

package strategy

import "istio.io/istio/galley/pkg/config/processing/snapshotter/strategy"

Index

Package Files

create.go debounce.go immediate.go instance.go scope.go

type Debounce Uses

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

Debounce is a heuristic model for deciding when to publish snapshots. It tries to detect quiesce points for events with a total bounded wait time.

func NewDebounce Uses

func NewDebounce(maxWaitDuration, quiesceDuration time.Duration) *Debounce

NewDebounce creates a new debounce strategy with the given values.

func NewDebounceWithDefaults Uses

func NewDebounceWithDefaults() *Debounce

NewDebounceWithDefaults creates a new debounce strategy with default values.

func (*Debounce) OnChange Uses

func (d *Debounce) OnChange()

OnChange implements Instance

func (*Debounce) Start Uses

func (d *Debounce) Start(fn OnSnapshotFn)

Start implements Instance

func (*Debounce) Stop Uses

func (d *Debounce) Stop()

Stop implements Instance

type Immediate Uses

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

Immediate is a snapshotting strategy for creating snapshots immediately, as events arrive.

func NewImmediate Uses

func NewImmediate() *Immediate

NewImmediate returns a new Immediate.

func (*Immediate) OnChange Uses

func (i *Immediate) OnChange()

OnChange implements processing.Debounce

func (*Immediate) Start Uses

func (i *Immediate) Start(handler OnSnapshotFn)

Start implements processing.Debounce

func (*Immediate) Stop Uses

func (i *Immediate) Stop()

Stop implements processing.Debounce

type Instance Uses

type Instance interface {
    Start(fn OnSnapshotFn)
    OnChange()
    Stop()
}

Instance is a strategy for publishing snapshots. It listens to to the given snapshotters and creates snapshots that get published to the given Distributor.

func Create Uses

func Create(name string) (Instance, error)

Create a strategy with the given name.

type OnSnapshotFn Uses

type OnSnapshotFn func()

OnSnapshotFn is called to indicate that the snapshot

Package strategy imports 6 packages (graph) and is imported by 2 packages. Updated 2019-09-26. Refresh now. Tools for package owners.