Documentation
¶
Index ¶
- func NewOrchestratorPool(bcast common.Broadcaster, uris []*url.URL, score float32, ...) *orchestratorPool
- func NewOrchestratorPoolWithPred(bcast common.Broadcaster, addresses []*url.URL, ...) *orchestratorPool
- func NewWebhookPool(bcast common.Broadcaster, callback *url.URL) *webhookPool
- func StubOrchestratorPool(addresses []string) *stubOrchestratorPool
- func StubOrchestrators(addresses []string) []*lpTypes.Transcoder
- type DBOrchestratorPoolCache
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewOrchestratorPool ¶
func NewOrchestratorPoolWithPred ¶
func NewOrchestratorPoolWithPred(bcast common.Broadcaster, addresses []*url.URL, pred func(*net.OrchestratorInfo) bool, score float32, orchBlacklist []string) *orchestratorPool
func NewWebhookPool ¶
func NewWebhookPool(bcast common.Broadcaster, callback *url.URL) *webhookPool
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) (*DBOrchestratorPoolCache, error)
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
Source Files
Click to show internal directories.
Click to hide internal directories.