egress

type AdapterPool struct {
	Pool map[string]v1.AdapterClient
	// contains filtered or unexported fields
}

type BindingReader interface {
	FetchBindings() (appBindings []v1.Binding, invalid int, err error)
}

type Communicator interface {
	// List returns the workload from the given adapter.
	List(ctx context.Context, adapter interface{}) ([]interface{}, error)

	// Add adds the given task to the worker. The error only logged (for now).
	// It is assumed that if the worker returns an error trying to update, the
	// next term will fix the problem and move the task elsewhere.
	Add(ctx context.Context, adapter, binding interface{}) error

	// Removes the given task from the worker. The error is only logged (for
	// now). It is assumed that if the worker is returning an error, then it
	// is either not doing the task because the worker is down, or there is a
	// network partition and a future term will fix the problem.
	Remove(ctx context.Context, adapter, binding interface{}) error
}

type HealthEmitter interface {
	SetCounter(c map[string]int)
}

type MetricEmitter interface {
	NewGaugeMetric(name, unit string, opts ...pulseemitter.MetricOption) pulseemitter.GaugeMetric
	NewCounterMetric(name string, opts ...pulseemitter.MetricOption) pulseemitter.CounterMetric
}

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