flow

type AvailabilityResponse struct {
}

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

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

type EthBlockNumberIntegrityHandler struct {
}

type EthGetBlockByNumberIntegrityHandler struct {
}

type ExecutionFlow interface {
	Execute(ctx context.Context, requests []protocol.RequestHolder)
	GetResponses() chan *protocol.ResponseHolderWrapper
	AddHooks(hooks ...any)
}

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

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

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

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

type IntegrityHandler interface {
	CanBeProcessed(ctx context.Context, request protocol.RequestHolder) bool
	// HandleResponse - Processes a response from an upstream and determines if additional actions are required to support integrity. Returns:
	//
	// bool – indicates whether an additional request should be sent.
	//
	//[]string – if true, contains the list of upstream IDs where the additional request should be executed.
	//
	//IntegrityBlock – an object used to update chain state manually (e.g., replacing the tracked head block or finalization data) when necessary.
	HandleResponse(
		ctx context.Context,
		chainSupervisor upstreams.ChainSupervisor,
		request protocol.RequestHolder,
		currentResponse *protocol.ResponseHolderWrapper,
	) (bool, []string, IntegrityBlock)
}

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

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

type MatchResponse interface {
	Cause() string
	Type() MatchResponseType
}

type MatchResponseType int

type Matcher interface {
	Match(string, *protocol.UpstreamState) MatchResponse
}

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

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

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

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

type NoopIntegrityHandler struct{}

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

type RateLimiterResponse struct {
}

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

type RequestProcessor interface {
	ProcessRequest(ctx context.Context, upstreamStrategy UpstreamStrategy, request protocol.RequestHolder) ProcessedResponse
}

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

type StatusMatcher struct{}

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

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

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

type SubscriptionResponse struct {
	ResponseWrappers chan *protocol.ResponseHolderWrapper
}

type SuccessResponse struct {
}

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

type UnaryResponse struct {
	ResponseWrapper *protocol.ResponseHolderWrapper
}

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

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

type UpstreamStrategy interface {
	SelectUpstream(request protocol.RequestHolder) (string, error)
}

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