discovery

package
v0.8.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2026 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewOrchestratorPool

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

func NewOrchestratorPoolWithConfig added in v0.8.8

func NewOrchestratorPoolWithConfig(cfg OrchestratorPoolConfig) (*orchestratorPool, error)

func NewOrchestratorPoolWithPred

func NewOrchestratorPoolWithPred(bcast common.Broadcaster, addresses []*url.URL,
	pred func(*net.OrchestratorInfo) bool, score float32, orchBlacklist []string, discoveryTimeout time.Duration) *orchestratorPool

func NewWebhookPool

func NewWebhookPool(bcast common.Broadcaster, callback *url.URL, discoveryTimeout time.Duration) *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, 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 (*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 added in v0.5.23

func (dbo *DBOrchestratorPoolCache) SizeWith(scorePred common.ScorePred) 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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL