upstreams

type AddChainSupervisorEvent struct {
	ChainSupervisor ChainSupervisor
}

type AggregatedLabels struct {
	Amount int
	Labels map[string]string
}

type BaseChainSupervisor struct {
	// contains filtered or unexported fields
}

type BaseUpstream struct {
	// contains filtered or unexported fields
}

type BaseUpstreamSupervisor struct {
	// contains filtered or unexported fields
}

type BlocksWrapper struct {
	Blocks map[protocol.BlockType]protocol.Block
}

type ChainHeadData struct {
	Head       protocol.Block
	UpstreamId string
}

type ChainSupervisor interface {
	Start()

	GetChain() chains.Chain
	GetChainState() ChainSupervisorState
	GetMethod(methodName string) *specs.Method
	GetMethods() []string
	GetUpstreamState(upstreamId string) *protocol.UpstreamState
	GetSortedUpstreamIds(filterFunc FilterUpstream, sortFunc SortUpstream) []string
	GetUpstreamIds() []string

	PublishUpstreamEvent(event protocol.UpstreamEvent)
	SubscribeState(name string) *utils.Subscription[*ChainSupervisorStateWrapperEvent]
}

type ChainSupervisorEvent interface {
	// contains filtered or unexported methods
}

type ChainSupervisorState struct {
	Status      protocol.AvailabilityStatus
	HeadData    ChainHeadData
	Methods     methods.Methods
	Blocks      map[protocol.BlockType]protocol.Block
	LowerBounds map[protocol.LowerBoundType]protocol.LowerBoundData
	ChainLabels []AggregatedLabels
	SubMethods  mapset.Set[string]
}

type ChainSupervisorStateWrapper interface {
	// contains filtered or unexported methods
}

type ChainSupervisorStateWrapperEvent struct {
	Wrappers []ChainSupervisorStateWrapper
}

type FilterUpstream func(id string, state *protocol.UpstreamState) bool

type HeadWrapper struct {
	Head protocol.Block
}

type LabelsWrapper struct {
	Labels []AggregatedLabels
}

type LowerBoundsWrapper struct {
	LowerBounds []protocol.LowerBoundData
}

type MethodsWrapper struct {
	Methods []string
}

type SortUpstream func(entry1, entry2 lo.Tuple2[string, *protocol.UpstreamState]) int

type StatusWrapper struct {
	Status protocol.AvailabilityStatus
}

type SubMethodsWrapper struct {
	SubMethods []string
}

type Upstream interface {
	Start()
	Resume()
	PartialStop()
	Stop()
	Running() bool

	Subscribe(name string) *utils.Subscription[protocol.UpstreamEvent]

	GetId() string
	GetChain() chains.Chain
	GetVendorType() UpstreamVendor
	GetUpstreamState() protocol.UpstreamState
	GetConnector(connectorType protocol.ApiConnectorType) connectors.ApiConnector
	GetHashIndex() string

	UpdateHead(height, slot uint64)
	UpdateBlock(block protocol.Block, blockType protocol.BlockType)
	BanMethod(method string)
}

type UpstreamStatsService interface {
	AddRequestResults(requestResults []protocol.RequestResult)
}

type UpstreamSupervisor interface {
	GetChainSupervisor(chain chains.Chain) ChainSupervisor
	GetChainSupervisors() []ChainSupervisor
	GetUpstream(string) Upstream
	GetExecutor() failsafe.Executor[*protocol.ResponseHolderWrapper]
	StartUpstreams()

	SubscribeChainSupervisor(name string) *utils.Subscription[ChainSupervisorEvent]
}

type UpstreamVendor int