discovery

Documentation

Index

• func NewOrchestratorPool(bcast common.Broadcaster, uris []*url.URL) *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) GetOrchestrators(numOrchestrators int, suspender common.Suspender, ...) ([]*net.OrchestratorInfo, error)
  • func (dbo *DBOrchestratorPoolCache) GetURLs() []*url.URL
  • func (dbo *DBOrchestratorPoolCache) Size() int

Functions

func NewOrchestratorPool

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

func NewOrchestratorPoolWithPred

func NewOrchestratorPoolWithPred(bcast common.Broadcaster, addresses []*url.URL, pred func(*net.OrchestratorInfo) bool) *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) (*DBOrchestratorPoolCache, error)

func (*DBOrchestratorPoolCache) GetOrchestrators

func (dbo *DBOrchestratorPoolCache) GetOrchestrators(numOrchestrators int, suspender common.Suspender, caps common.CapabilityComparator) ([]*net.OrchestratorInfo, error)

func (*DBOrchestratorPoolCache) GetURLs

func (dbo *DBOrchestratorPoolCache) GetURLs() []*url.URL

func (*DBOrchestratorPoolCache) Size

func (dbo *DBOrchestratorPoolCache) Size() int