test_utils

package
v0.0.0-...-0e75ced Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2026 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildLocalKeyConfig 

func BuildLocalKeyConfig(key string, allowedIps []string, methods *config.AuthMethods, contracts *config.AuthContracts) *config.LocalKeyConfig

func CacheableMethod 

func CacheableMethod(name string) *specs.Method

CacheableMethod builds a spec method that is eligible for caching, for use as a request fixture in cache tests. The fallback constructors (specs.DefaultMethod) produce non-cacheable methods, so cache tests must construct a cacheable one.

func CreateChainSupervisor 

func CreateChainSupervisor() upstreams.ChainSupervisor

func CreateEvent 

func CreateEvent(id string, status protocol.AvailabilityStatus, head protocol.Block, methods methods.Methods) protocol.UpstreamEvent

func CreateEventWithBlockData 

func CreateEventWithBlockData(
	id string,
	status protocol.AvailabilityStatus,
	head protocol.Block,
	methods methods.Methods,
	blockInfo *protocol.BlockInfo,
) protocol.UpstreamEvent

func CreateExecutor 

func CreateExecutor() failsafe.Executor[*protocol.ResponseHolderWrapper]

func CreateRemoveEvent 

func CreateRemoveEvent(id string) protocol.UpstreamEvent

func CtxWithRemoteAddr 

func CtxWithRemoteAddr(remote string) context.Context

func CtxWithXFF 

func CtxWithXFF(xff string) context.Context

CtxWithXFF simulates a request that arrived through a trusted proxy, so the client IP is taken from X-Forwarded-For.

func ExpectEthValidationRequest 

func ExpectEthValidationRequest(
	connector *mocks.ConnectorMock,
	request protocol.RequestHolder,
	response protocol.ResponseHolder,
)

func GetMethodMockAndUpSupervisor 

func GetMethodMockAndUpSupervisor() (*mocks.MethodsMock, *mocks.UpstreamSupervisorMock)

func GetResultAsBytes 

func GetResultAsBytes(json []byte) []byte

func NewAlgorandChainSpecific 

func NewAlgorandChainSpecific(ctx context.Context, connector connectors.ApiConnector) *algorand_specific.AlgorandChainSpecificObject

func NewAptosChainSpecific 

func NewAptosChainSpecific(ctx context.Context, connector connectors.ApiConnector) *aptos_specific.AptosChainSpecificObject

func NewAztecChainSpecific 

func NewAztecChainSpecific(ctx context.Context, connector connectors.ApiConnector) *aztec_specific.AztecChainSpecificObject

func NewBeaconChainSpecific 

func NewBeaconChainSpecific(ctx context.Context, connector connectors.ApiConnector) *beacon_specific.BeaconChainSpecificObject

func NewBitcoinChainSpecific 

func NewBitcoinChainSpecific(ctx context.Context, connector connectors.ApiConnector) *bitcoin_specific.BitcoinChainSpecificObject

func NewEvmChainSpecific 

func NewEvmChainSpecific(connector connectors.ApiConnector) *evm_specific.EvmChainSpecificObject

func NewNearChainSpecific 

func NewNearChainSpecific(ctx context.Context, connector connectors.ApiConnector) *near_specific.NearChainSpecificObject

func NewPolkadotChainSpecific 

func NewPolkadotChainSpecific(ctx context.Context, connector connectors.ApiConnector) *polkadot_specific.PolkadotChainSpecificObject

func NewSolanaChainSpecific 

func NewSolanaChainSpecific(ctx context.Context, connector connectors.ApiConnector) *specific.SolanaChainSpecificObject

func NewStarknetChainSpecific 

func NewStarknetChainSpecific(ctx context.Context, connector connectors.ApiConnector) *starknet_specific.StarknetChainSpecificObject

func NewStellarHorizonChainSpecific 

func NewStellarHorizonChainSpecific(ctx context.Context, connector connectors.ApiConnector) *stellar_specific.StellarHorizonChainSpecificObject

func NewStellarRpcChainSpecific 

func NewStellarRpcChainSpecific(ctx context.Context, connector connectors.ApiConnector) *stellar_specific.StellarRpcChainSpecificObject

func NewUpstreamRequest 

func NewUpstreamRequest(t *testing.T, method string, params any) protocol.RequestHolder

func PolicyConfig 

func PolicyConfig(chain, method, connector, maxSize, ttl string, cacheEmpty bool) *config.CachePolicyConfig

func PolicyConfigBlockchainType 

func PolicyConfigBlockchainType(blockchainType, method, connector, maxSize, ttl string, cacheEmpty bool) *config.CachePolicyConfig

func PolicyConfigFinalized 

func PolicyConfigFinalized(chain, method, connector, maxSize, ttl string, cacheEmpty bool) *config.CachePolicyConfig

func PublishEvent 

func PublishEvent(chainSupervisor upstreams.ChainSupervisor, upId string, status protocol.AvailabilityStatus, caps mapset.Set[protocol.Cap])

func TestEvmUpstream 

func TestEvmUpstream(
	connector connectors.ApiConnector,
	upConfig *config.Upstream,
	upstreamMethods methods.Methods,
	processorAggregator *event_processors.UpstreamProcessorAggregator,
) *upstreams.GenericUpstream

func UpstreamJsonRpcRequestMatcher 

func UpstreamJsonRpcRequestMatcher(request protocol.RequestHolder) func(protocol.RequestHolder) bool

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.