GetDrainExtentTimeout returns the current drainExtentTimeout.

NewConsGroupUpdatedEvent creates and returns a ConsGroupUpdatedEvent.

NewController creates and returns a new instance of Mcp controller.

NewDfdd creates and returns an instance of discovery and failure detection daemon.

NewDistancePlacement initializes a new placement topology.

NewEventPipeline creates a new instance of EventPipeline The returned pipeline will have nWorkers number of concurrent worker routines that handle events in the background.

NewExtentCreatedEvent creates and returns a ExtentCreatedEvent.

NewExtentDownEvent creates and returns an ExtentDownEvent.

NewInputHostFailedEvent creates and returns a InputHostFailedEvent.

NewInputHostNotificationEvent creates and returns a InputHostNotificationEvent.

NewLockMgr creates and returns a new instance of LockMgr.

NewMetadataMgr creates and returns a new instance of MetadataMgr.

NewOutputHostNotificationEvent creates and returns a OutputHostNotificationEvent.

NewRemoteExtentPrimaryStoreDownEvent creates and returns an RemoteExtentPrimaryStoreDownEvent.

NewRetryableEventExecutor returns a new instance of RetryableEventExecutor This executor spins up a separate go routine for processing every event that's submitted.

NewStartReplicationForRemoteZoneExtent creates and returns a StartReplicationForRemoteZoneExtent.

NewStoreExtentStatusOutOfSyncEvent creates and returns a NewStoreExtentStatusOutOfSyncEvent.

NewStoreHostFailedEvent creates and returns a StoreHostFailedEvent.

SetDrainExtentTimeout overrides the drain extent timeout to the given value.

QueueDepthTabulationString can be added to a destination or CG owner email to request queue depth tabulation Note that Google allows something like this: [email protected] The above is still a valid email and will be delivered to [email protected].

ErrConsumerGroupDisabled is returned after a consumer group is deleted.

ErrConsumerGroupNotExists is returned for a missing consumer group.

ErrDestinationDisabled is returned after a destination is deleted.

ErrDestinationNotExists is returned for a missing destination.

ErrEventQueueFull is returned when the internal event queue is full and as a result, some action cannot be taken by the controller.

ErrMalformedUUID is returned when the UUID in the request is malformed.

ErrNoHealthyExtent is returned where there are no healthy extents in the system.

ErrPublishToKafkaDestination is returned on invoking GetInputHosts on a Kafka destination.

ErrPublishToReceiveOnlyDestination is returned on invoking GetInputHosts on a receive-only destination.

ErrTooManyUnHealthy is returned when there are too many open but unhealthy extents for a destination.

ErrTryLock is a temporary error that is thrown by the API when it loses the race to do the computation needed to refreh the API result cache.

ErrUnavailable indicates any kind of intermittent service error, most likely, metadata read/write errors.

IntervalBtwnScans is the time that the scanner will sleep between scans.

DistancePlacement holds the context and distance map.

Placement is the placement strategy interface for picking hosts.