Documentation
¶
Index ¶
- func NewOrchestratorPool(bcast common.Broadcaster, uris []*url.URL, score float32, ...) *orchestratorPool
- func NewOrchestratorPoolWithConfig(cfg OrchestratorPoolConfig) (*orchestratorPool, error)
- func NewOrchestratorPoolWithPred(bcast common.Broadcaster, addresses []*url.URL, ...) *orchestratorPool
- func NewWebhookPool(bcast common.Broadcaster, callback *url.URL, discoveryTimeout time.Duration) *webhookPool
- func StubOrchestratorPool(addresses []string) *stubOrchestratorPool
- func StubOrchestrators(addresses []string) []*lpTypes.Transcoder
- type DBOrchestratorPoolCache
- func (dbo *DBOrchestratorPoolCache) Broadcaster() common.Broadcaster
- func (dbo *DBOrchestratorPoolCache) GetInfos() []common.OrchestratorLocalInfo
- func (dbo *DBOrchestratorPoolCache) GetOrchestrators(ctx context.Context, numOrchestrators int, suspender common.Suspender, ...) (common.OrchestratorDescriptors, error)
- func (dbo *DBOrchestratorPoolCache) Size() int
- func (dbo *DBOrchestratorPoolCache) SizeWith(scorePred common.ScorePred) int
- type DBOrchestratorPoolCacheConfig
- type OrchestratorPoolConfig
- type WebhookPoolConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewOrchestratorPool ¶
func NewOrchestratorPoolWithConfig ¶ added in v0.8.8
func NewOrchestratorPoolWithConfig(cfg OrchestratorPoolConfig) (*orchestratorPool, error)
func NewWebhookPool ¶
func StubOrchestratorPool ¶ added in v0.5.1
func StubOrchestratorPool(addresses []string) *stubOrchestratorPool
func StubOrchestrators ¶ added in v0.5.1
func StubOrchestrators(addresses []string) []*lpTypes.Transcoder
Types ¶
type DBOrchestratorPoolCache ¶
type DBOrchestratorPoolCache struct {
// contains filtered or unexported fields
}
func NewDBOrchestratorPoolCache ¶
func NewDBOrchestratorPoolCache(ctx context.Context, node *core.LivepeerNode, rm common.RoundsManager, orchBlacklist []string, discoveryTimeout time.Duration, liveAICapReportInterval time.Duration) (*DBOrchestratorPoolCache, error)
func (*DBOrchestratorPoolCache) Broadcaster ¶ added in v0.8.6
func (dbo *DBOrchestratorPoolCache) Broadcaster() common.Broadcaster
func (*DBOrchestratorPoolCache) GetInfos ¶ added in v0.5.23
func (dbo *DBOrchestratorPoolCache) GetInfos() []common.OrchestratorLocalInfo
func (*DBOrchestratorPoolCache) GetOrchestrators ¶
func (dbo *DBOrchestratorPoolCache) GetOrchestrators(ctx context.Context, numOrchestrators int, suspender common.Suspender, caps common.CapabilityComparator, scorePred common.ScorePred) (common.OrchestratorDescriptors, error)
func (*DBOrchestratorPoolCache) Size ¶
func (dbo *DBOrchestratorPoolCache) Size() int
type DBOrchestratorPoolCacheConfig ¶ added in v0.8.10
type DBOrchestratorPoolCacheConfig struct {
Ctx context.Context
Node *core.LivepeerNode
RoundsManager common.RoundsManager
OrchBlacklist []string
DiscoveryTimeout time.Duration
LiveAICapReportInterval time.Duration
IgnoreCapacityCheck bool
}
func (DBOrchestratorPoolCacheConfig) New ¶ added in v0.8.10
func (cfg DBOrchestratorPoolCacheConfig) New() (*DBOrchestratorPoolCache, error)
type OrchestratorPoolConfig ¶ added in v0.8.8
type OrchestratorPoolConfig struct {
Broadcaster common.Broadcaster
URIs []*url.URL
Pred func(*net.OrchestratorInfo) bool
Score float32
OrchBlacklist []string
DiscoveryTimeout time.Duration
IgnoreCapacityCheck bool
// Limits the number of additional nodes an orchestrator
// can advertise within the GetOrchestratorInfo response.
// Default 0.
ExtraNodes int
}
OrchestratorPoolConfig groups options used to construct an orchestratorPool.
type WebhookPoolConfig ¶ added in v0.8.10
type WebhookPoolConfig struct {
Broadcaster common.Broadcaster
Callback *url.URL
DiscoveryTimeout time.Duration
IgnoreCapacityCheck bool
}
func (WebhookPoolConfig) New ¶ added in v0.8.10
func (cfg WebhookPoolConfig) New() *webhookPool
Click to show internal directories.
Click to hide internal directories.