predicate

Documentation

Index

• func ControllerRingCreatedOrUpdated() predicate.Predicate
• func IsShardLease() predicate.Predicate
• func ShardLeaseAvailabilityChanged(clock clock.PassiveClock) predicate.Predicate
• func ShardLeaseStateChanged(clock clock.PassiveClock) predicate.Predicate

Functions

func ControllerRingCreatedOrUpdated

func ControllerRingCreatedOrUpdated() predicate.Predicate

ControllerRingCreatedOrUpdated reacts on create and update events with generation changes but ignores delete events. On deletion, there is nothing to do for the sharding controllers.

func IsShardLease

func IsShardLease() predicate.Predicate

IsShardLease filters for events on Lease objects that have a non-empty label specifying the ControllerRing.

func ShardLeaseAvailabilityChanged

func ShardLeaseAvailabilityChanged(clock clock.PassiveClock) predicate.Predicate

ShardLeaseAvailabilityChanged reacts on lease events where the shard's availability changes.

func ShardLeaseStateChanged

func ShardLeaseStateChanged(clock clock.PassiveClock) predicate.Predicate

ShardLeaseStateChanged reacts on lease events where the shard's state changes.