reqctx

type EffectiveParallelism struct {
	// GrantedWorkers is the worker count the authentication layer allows for this
	// request, falling back to the server default when the trusted header is absent.
	GrantedWorkers uint64

	// RequestedWorkers is the worker count the client asked for through the untrusted
	// header, 0 when the client did not ask for anything.
	RequestedWorkers uint64

	// Workers is the effective worker count: min(GrantedWorkers, RequestedWorkers) when
	// the client asked for less than what it was granted, GrantedWorkers otherwise.
	Workers uint64

	// StageLayerExecutors is the number of modules that can be executed in parallel
	// within a single stage layer, derived from the plan tier.
	StageLayerExecutors uint64

	// PlanTier is the substreams plan tier reported by the authentication layer, empty
	// when the request is unauthenticated.
	PlanTier string

	// WorkersSource tells which of the three inputs determined Workers, one of
	// WorkersSourceDefault, WorkersSourceTrustedHeader or WorkersSourceClientHeader.
	WorkersSource string
}

type ISpan interface {
	// End completes the Span. The Span is considered complete and ready to be
	// delivered through the rest of the telemetry pipeline after this method
	// is called. Therefore, updates to the Span are not allowed after this
	// method has been called.
	End(options ...ttrace.SpanEndOption)

	// AddEvent adds an event with the provided name and options.
	AddEvent(name string, options ...ttrace.EventOption)

	// IsRecording returns the recording state of the Span. It will return
	// true if the Span is active and events can be recorded.
	IsRecording() bool

	// RecordError will record err as an exception span event for this span. An
	// additional call to SetStatus is required if the Status of the Span should
	// be set to Error, as this method does not change the Span status. If this
	// span is not being recorded or err is nil then this method does nothing.
	RecordError(err error, options ...ttrace.EventOption)

	// SpanContext returns the SpanContext of the Span. The returned SpanContext
	// is usable even after the End method has been called for the Span.
	SpanContext() ttrace.SpanContext

	// SetStatus sets the status of the Span in the form of a code and a
	// description, provided the status hasn't already been set to a higher
	// value before (OK > Error > Unset). The description is only included in a
	// status when the code is for an error.
	SetStatus(code codes.Code, description string)

	// SetName sets the Span name.
	SetName(name string)

	// SetAttributes sets kv as attributes of the Span. If a key from kv
	// already exists for an attribute of the Span it will be overwritten with
	// the value contained in kv.
	SetAttributes(kv ...attribute.KeyValue)

	// TracerProvider returns a TracerProvider that can be used to generate
	// additional Spans on the same telemetry pipeline as the current Span.
	TracerProvider() ttrace.TracerProvider

	EndWithErr(e *error)
}

type IsOutputModuleFunc func(name string) bool

type NoopSpan struct{}

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

type RemoteSquasher struct {
	Client         squash.Client
	StateStoreURL  string
	CacheTag       string
	StoreSizeLimit uint64
	Availability   *RemoteAvailability
}

type RequestDetails struct {
	Modules *pbsubstreams.Modules

	DebugInitialStoreSnapshotForModules []string
	OutputModule                        string
	// What the user requested, derived from either the Request.StartBlockNum or Request.Cursor
	ResolvedStartBlockNum uint64
	ResolvedCursor        string

	LinearHandoffBlockNum uint64
	LinearGateBlockNum    uint64
	StopBlockNum          uint64
	MaxParallelJobs       uint64
	// PlanTier is the substreams plan tier reported by the authentication layer, empty
	// when the request is unauthenticated.
	PlanTier                      string
	MaxStageLayerParallelExecutor uint64
	LimitProcessedBlocks          uint64
	UpdateInterval                time.Duration
	UniqueID                      uint64

	FromQuickload    bool
	ProductionMode   bool
	IsTier2Request   bool
	IsStreamingTier2 bool // special mode where tier2 will stream the data back to tier1, for the first segment
	Tier2Stage       int
}

type Tier2RequestParameters struct {
	MeteringConfig       string
	FirstStreamableBlock uint64

	MergedBlockStoreURL    string
	MergedBlocksBundleSize uint64 // number of blocks per merged-blocks file in MergedBlockStoreURL
	StateStoreURL          string
	StateBundleSize        uint64
	StateStoreDefaultTag   string

	BlockType string

	// StoreSizeLimit, if non-zero, overrides the default store size limit (in bytes)
	// for stores loaded on tier2. Set from the tier1 store-size-limit flag.
	StoreSizeLimit uint64

	WASMModules                map[string]string
	FoundationalStoreEndpoints map[string]string
}

type TracingConf struct {
	ModuleExecution bool
}