discovery

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 NewDBOrchestratorPoolCache(ctx context.Context, node *core.LivepeerNode, rm common.RoundsManager, ...) (*DBOrchestratorPoolCache, error)
  • 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

Functions

func NewOrchestratorPool

func NewOrchestratorPool(bcast common.Broadcaster, uris []*url.URL, score float32, orchBlacklist []string) *orchestratorPool

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

func StubOrchestratorPool(addresses []string) *stubOrchestratorPool

func StubOrchestrators

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

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

func (*DBOrchestratorPoolCache) SizeWith

func (dbo *DBOrchestratorPoolCache) SizeWith(scorePred common.ScorePred) int