controllerhost

type Boolean bool

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

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

type ControllerDynamicConfig struct {
	NumPublisherExtentsByPath      []string `name:"numPublisherExtentsByPath" default:"/=4"`
	NumConsumerExtentsByPath       []string `name:"numConsumerExtentsByPath" default:"/=8"`
	NumRemoteConsumerExtentsByPath []string `name:"numRemoteConsumerExtentsByPath" default:"/=4"`
}

type Dfdd interface {
	common.Daemon

	// override the durations, used for testing
	OverrideHostDownPeriodForStage2(period time.Duration)
	OverrideHealthCheckInterval(period time.Duration)
}

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

type Event interface {
	// Handle is the handler for the event.
	Handle(context *Context) error
	// Done is a callback to indicate that the
	// event processing is done. This is
	// an opportunity to cleanup any state that
	// the event had. The err arg is set to the
	// error value from the last attempt. Nil
	// indicates the handler finished successfully.
	Done(context *Context, err error)
}

type EventPipeline interface {
	common.Daemon
	// Add adds an event to the event pipeline
	// returns true on success
	// returns false when the event queue is full
	Add(event Event) bool
	// GetRetryableEventExecutor returns the executor for
	// running retryable events
	GetRetryableEventExecutor() RetryableEventExecutor
}

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

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

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

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

type InputPlacementConfig struct {
	AdminStatus string `name:"adminStatus" default:"enabled"`
}

type LockMgr interface {
	// TryLock attempts to acquire the lock
	// identified by the given key. If it
	// cannot acquire the lock within the
	// timeout, returns false. On success,
	// returns true
	TryLock(key string, timeout time.Duration) bool
	// Unlock releases the lock identified
	// by the key
	Unlock(key string)
	// Size returns the number of
	// keys currently held by the
	// lockmgr
	Size() int64
}

type Mcp struct {
	*common.Service
	// contains filtered or unexported fields
}

type MetadataMgr interface {
	// ReadDestination returns the destination desc for the given uuid
	ReadDestination(dstID string, dstPath string) (*shared.DestinationDescription, error)
	// ReadExtentStats returns the extent stats for the given extent; it is not scalable, and therefore is to be used for debugging only
	ReadExtentStats(dstID string, extentID string) (*shared.ExtentStats, error)
	// ReadStoreExtentStats returns the extent stats for the given extent and store
	ReadStoreExtentStats(extentID string, storeID string) (*shared.ExtentStats, error)
	// ReadConsumerGroupExtent returns the consumer group extent stats corresponding to the given dst/cg/ext.
	ReadConsumerGroupExtent(dstID string, cgID string, extentID string) (*m.ConsumerGroupExtent, error)
	// ListDestinations returns an list of adestinations
	ListDestinations() ([]*shared.DestinationDescription, error)
	// ListDestinationsPage returns an list of adestinations
	ListDestinationsPage(mReq *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)
	// ListDestinationsByUUID returns an iterator to the destinations
	ListDestinationsByUUID() ([]*shared.DestinationDescription, error)
	// ListDestinationExtentsByStatus lists extents by dstID/status
	// The returned type is a list of DestinationExtent objects as
	// opposed to list of Extent objects
	ListDestinationExtentsByStatus(dstID string, filterByStatus []shared.ExtentStatus) ([]*m.DestinationExtent, error)
	// ListExtentsByDstIDStatus lists extents dstID/Status
	ListExtentsByDstIDStatus(dstID string, filterByStatus []shared.ExtentStatus) ([]*shared.ExtentStats, error)
	// ListExtentsByInputIDStatus lists extents for dstID/InputUUID/Status
	ListExtentsByInputIDStatus(inputID string, status *shared.ExtentStatus) ([]*shared.ExtentStats, error)
	// ListExtentsByStoreIDStatus lists extents by storeID/Status
	ListExtentsByStoreIDStatus(storeID string, status *shared.ExtentStatus) ([]*shared.ExtentStats, error)
	// ListExtentsByReplicationStatus lists extents by storeID/ReplicationStatus
	ListExtentsByReplicationStatus(storeID string, status *shared.ExtentReplicaReplicationStatus) ([]*shared.ExtentStats, error)
	// ListExtentsByConsumerGroup lists all extents for the given destination / consumer group
	ListExtentsByConsumerGroup(dstID string, cgID string, filterByStatus []m.ConsumerGroupExtentStatus) ([]*m.ConsumerGroupExtent, error)
	// ListExtentsByConsumerGroupLite lists all extents for the given destination / consumer group
	// this api only returns a few interesting columns for each consumer group extent in the
	// result. For detailed info, see ListExtentsByConsumerGroup
	ListExtentsByConsumerGroupLite(dstID string, cgID string, filterByStatus []m.ConsumerGroupExtentStatus) ([]*m.ConsumerGroupExtentLite, error)
	// CreateExtent creates a new extent for the given destination and marks the status as OPEN
	CreateExtent(dstID string, extentID string, inhostID string, storeIDs []string) (*shared.CreateExtentResult_, error)
	// CreateRemoteZoneExtent creates a new remote zone extent for the given destination and marks the status as OPEN
	CreateRemoteZoneExtent(dstID string, extentID string, inhostID string, storeIDs []string, originZone string, remoteExtentPrimaryStore string) (*shared.CreateExtentResult_, error)
	// AddExtentToConsumerGroup adds an open extent to consumer group for consumption
	AddExtentToConsumerGroup(dstID string, cgID string, extentID string, outHostID string, storeIDs []string) error
	// ListConsumerGroupsByDstID lists all consumer groups for a given destination uuid
	ListConsumerGroupsByDstID(dstID string) ([]*shared.ConsumerGroupDescription, error)
	// ListConsumerGroupsPage lists all consumer groups for a given destination uuid
	ListConsumerGroupsPage(mReq *m.ListConsumerGroupRequest) (*m.ListConsumerGroupResult_, error)
	// UpdateOutHost changes the out host for the consumer group extent
	UpdateOutHost(dstID string, cgID string, extentID string, outHostID string) error
	// DeleteConsumerGroup deletes the consumer group status
	DeleteConsumerGroup(dstID string, cgName string) error
	// SealExtent seals the extent if it was previously sealed
	SealExtent(dstID string, extentID string) error
	// UpdateDestinationDLQCursors updates the DLQCursor on a destination
	UpdateDestinationDLQCursors(dstID string, mergeBefore common.UnixNanoTime, purgeBefore common.UnixNanoTime) error
	// MoveExtent moves an extent
	MoveExtent(fromDstID, toDstID, extentID, cgUUID string) error
	// ReadConsumerGroup reads a consumer group
	ReadConsumerGroup(dstID, dstPath, cgUUID, cgName string) (*shared.ConsumerGroupDescription, error)
	// ReadConsumerGroupByUUID reads a consumer group by UUID
	ReadConsumerGroupByUUID(cgUUID string) (*shared.ConsumerGroupDescription, error)
	// UpdateExtentStatus updates the status of an extent
	UpdateExtentStatus(dstID, extID string, status shared.ExtentStatus) error
	// UpdateRemoteExtentPrimaryStore updates remoteExtentPrimaryStore
	UpdateRemoteExtentPrimaryStore(dstID string, extentID string, remoteExtentPrimaryStore string) (*m.UpdateExtentStatsResult_, error)
	// UpdateConsumerGroupExtentStatus updates the status of a consumer group extent
	UpdateConsumerGroupExtentStatus(cgID, extID string, status m.ConsumerGroupExtentStatus) error
	// DeleteDestination marks a destination to be deleted
	DeleteDestination(dstID string) error
}

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

type OutputPlacementConfig struct {
	AdminStatus string `name:"adminStatus" default:"enabled"`
}

type Placement interface {
	// PickInputHost picks an input host with certain distance from the store hosts
	PickInputHost(storeHosts []*common.HostInfo) (*common.HostInfo, error)
	// PickOutputHost picks an output host with certain distance from the store hosts
	PickOutputHost(storeHosts []*common.HostInfo) (*common.HostInfo, error)
	// PickStoreHosts picks n store hosts with certain distance between store replicas
	PickStoreHosts(count int) ([]*common.HostInfo, error)
}

type QueueDepthCacheEntry struct {
	// Time is the cache entry time
	Time common.UnixNanoTime
	// BacklogAvailable is the available backlog
	BacklogAvailable int64
	// BacklogUnavailable is the unavailable backlog (only useful for timer queues)
	BacklogUnavailable int64
	// BacklogInflight is the in flight message count
	BacklogInflight int64
	// BacklogDLQ is the number of messages in DLQ
	BacklogDLQ int64
}

type QueueDepthCacheJSONFields struct {
	CacheTime          common.UnixNanoTime `json:"cache_time,omitempty"`
	BacklogAvailable   int64               `json:"backlog_available"`
	BacklogUnavailable int64               `json:"backlog_unavailable"`
	BacklogInflight    int64               `json:"backlog_inflight"`
	BacklogDLQ         int64               `json:"backlog_dlq"`
}

type RetryableEventExecutor interface {
	// Submit takes a retryable event for
	// executing in the background. Returns
	// true on success, false otherwise
	Submit(event Event) bool
	// Stop stops the executor
	Stop()
}

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

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

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

type StorePlacementConfig struct {
	AdminStatus string `name:"adminStatus" default:"enabled"`
	// MinFreeDiskSpaceBytes represents the min
	// required free disk space on a store host
	// to host an extent. The default value
	// translates to 40GB which is 2 percent
	// for a 2TB drive
	MinFreeDiskSpaceBytes int64 `name:"minFreeDiskSpaceBytes" default:"40000000000"`
}