rollstore

func (*ConflictingRUError) Error ¶

func (c *ConflictingRUError) Error() string

func (ConsulStore) CreateRollingUpdateFromExistingRCs ¶

func (s ConsulStore) CreateRollingUpdateFromExistingRCs(
	ctx context.Context,
	u roll_fields.Update,
	newRCLabels klabels.Set,
	rollLabels klabels.Set,
) (roll_fields.Update, error)

CreateRollingUpdateFromExistingRCs creates a rolling update in consul, under the following conditions: 1) A lock can be acquired for both the old and new replication controllers.

• this is in lexicographical order by replication controller id so that identical update requests will not deadlock eachother

2. A rolling update does not already exist that refers to the same replication controllers (whether new or old). - This check is done while the locks are held, so that no new rolling update can be created referring to old and new while doing this query. - It naively searches every rolling update and checks its fields. While this introduces O(n) runtime complexity on the number of updates, since updates are short lived we don't anticipate it to be a scalability bottleneck. If scalability were a concern, an alternate approach would be to place labels on replication controllers referring back to the RUs that they refer to. Then a constant lookup can be done for those labels, and the operation can be aborted.

func (ConsulStore) CreateRollingUpdateFromOneExistingRCWithID ¶

func (s ConsulStore) CreateRollingUpdateFromOneExistingRCWithID(
	ctx context.Context,
	oldRCID rc_fields.ID,
	desiredReplicas int,
	minimumReplicas int,
	leaveOld bool,
	rollDelay time.Duration,
	availabilityZone pc_fields.AvailabilityZone,
	clusterName pc_fields.ClusterName,
	newRCManifest manifest.Manifest,
	newRCNodeSelector klabels.Selector,
	newRCPodLabels klabels.Set,
	newRCLabels klabels.Set,
	rollLabels klabels.Set,
	newAllocationStrategy rc_fields.Strategy,
) (roll_fields.Update, error)

CreateRollingUpdateFromOneExistingWithRCID is like CreateRollingUpdateFromExistingRCs except will create the new RC based on passed parameters, using oldRCID for the old RC. The new RC and new RU will be created transactionally (all or nothing)

func (ConsulStore) CreateRollingUpdateFromOneMaybeExistingWithLabelSelector ¶

func (s ConsulStore) CreateRollingUpdateFromOneMaybeExistingWithLabelSelector(
	ctx context.Context,
	oldRCSelector klabels.Selector,
	desiredReplicas int,
	minimumReplicas int,
	leaveOld bool,
	rollDelay time.Duration,
	availabilityZone pc_fields.AvailabilityZone,
	clusterName pc_fields.ClusterName,
	newRCManifest manifest.Manifest,
	newRCNodeSelector klabels.Selector,
	newRCPodLabels klabels.Set,
	newRCLabels klabels.Set,
	rollLabels klabels.Set,
	newAllocationStrategy rc_fields.Strategy,
) (roll_fields.Update, error)

CreateRollingUpdateFromOneMaybeExistingWithLabelSelector creates a rolling update that may or may not already have an existing old RC. If one matches the oldRCSelector, it will be used as the old RC in the new update. If one does not exist, a "dummy" old RC will be created that is identical to the specifications for the new RC. Returns an error if the old RC exists but is part of another RU, or if the label selector returns more than one match.

func (ConsulStore) Delete ¶

func (s ConsulStore) Delete(ctx context.Context, id roll_fields.ID) error

Delete deletes a rolling update based on its ID.

func (ConsulStore) Get ¶

func (s ConsulStore) Get(id roll_fields.ID) (roll_fields.Update, error)

Get retrieves a rolling update record by it ID.

func (ConsulStore) List ¶

func (s ConsulStore) List() ([]roll_fields.Update, error)

List returns all rolling update records.

func (ConsulStore) Lock ¶

func (s ConsulStore) Lock(id roll_fields.ID, session string) (bool, error)

Lock takes a lock on a rolling update by ID. Before taking ownership of an Update, its new RC ID, and old RC ID if any, should both be locked. If the error return is nil, then the boolean indicates whether the lock was successfully taken.

func (ConsulStore) Watch ¶

func (s ConsulStore) Watch(quit <-chan struct{}, jitterWindow time.Duration) (<-chan []roll_fields.Update, <-chan error)

Watch wtches for changes to the store and generate a list of Updates for each change. This function does not block.