Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.