package strategy

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

Index ¶

• type Debounce
• func NewDebounce(maxWaitDuration, quiesceDuration time.Duration) *Debounce
• func NewDebounceWithDefaults() *Debounce
• func (d *Debounce) OnChange()
• func (d *Debounce) Start(fn OnSnapshotFn)
• func (d *Debounce) Stop()
• type Immediate
• func NewImmediate() *Immediate
• func (i *Immediate) OnChange()
• func (i *Immediate) Start(handler OnSnapshotFn)
• func (i *Immediate) Stop()
• type Instance
• func Create(name string) (Instance, error)
• type OnSnapshotFn

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