reconciliation

Documentation

Index

• type Reconciliation
  • func New(ctx context.Context, cli calls.Caller, stor storage) *Reconciliation
  • func (rec *Reconciliation) HandleTaskStateUpdate(status *mesos.TaskStatus)
  • func (rec *Reconciliation) Run()

Types

type Reconciliation

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

Reconciliation implements explicit reconciliation algorithm as defined on https://mesos.apache.org/documentation/latest/reconciliation/#algorithm

func New

func New(ctx context.Context, cli calls.Caller, stor storage) *Reconciliation

New returns fresh instance of reconciler.

func (*Reconciliation) HandleTaskStateUpdate

func (rec *Reconciliation) HandleTaskStateUpdate(status *mesos.TaskStatus)

HandleTaskStateUpdate process changes of tasks statuses.

func (*Reconciliation) Run

func (rec *Reconciliation) Run()

Run starts reconciler in separate goroutine and exits.