provider

Documentation

Index

• Constants
• func RunLocalHostnameOperator(ctx context.Context, clientCtx cosmosclient.Context, listenPort int) (sdktest.BufferWriter, error)
• func RunLocalIPOperator(ctx context.Context, clientCtx cosmosclient.Context, listenPort int, ...) (sdktest.BufferWriter, error)
• func RunLocalProvider(ctx context.Context, clientCtx cosmosclient.Context, ...) (sdktest.BufferWriter, error)
• func RunProviderJWTServer(ctx context.Context, clientCtx cosmosclient.Context, ...) (sdktest.BufferWriter, error)
• func TestLeaseShell(ctx context.Context, clientCtx client.Context, extraArgs []string, ...) (sdktest.BufferWriter, error)
• func TestMigrateHostname(clientCtx client.Context, leaseID mtypes.LeaseID, dseq uint64, hostname string, ...) (sdktest.BufferWriter, error)
• func TestSendManifest(clientCtx client.Context, id mtypes.BidID, sdlPath string, extraArgs ...string) (sdktest.BufferWriter, error)

Constants

const (
	TestClusterPublicHostname   = "e2e.test"
	TestClusterNodePortQuantity = 100
)

Functions

func RunLocalHostnameOperator

func RunLocalHostnameOperator(ctx context.Context, clientCtx cosmosclient.Context, listenPort int) (sdktest.BufferWriter, error)

func RunLocalIPOperator

func RunLocalIPOperator(ctx context.Context, clientCtx cosmosclient.Context, listenPort int, providerAddress sdk.AccAddress) (sdktest.BufferWriter, error)

func RunLocalProvider

func RunLocalProvider(ctx context.Context, clientCtx cosmosclient.Context, chainID, nodeRPC, akashHome, from, gatewayListenAddress string, extraArgs ...string) (sdktest.BufferWriter,
	error)

RunLocalProvider wraps up the Provider cobra command for testing and supplies new default values to the flags. prev: akash provider run --from=foo --cluster-k8s --gateway-listen-address=localhost:39729 --home=/tmp/akash_integration_TestE2EApp_324892307/.akash --node=tcp://0.0.0.0:41863 --keyring-backend test

func RunProviderJWTServer

func RunProviderJWTServer(ctx context.Context, clientCtx cosmosclient.Context, from, jwtGatewayListenAddress string, extraArgs ...string) (sdktest.BufferWriter,
	error)

func TestLeaseShell

func TestLeaseShell(ctx context.Context, clientCtx client.Context, extraArgs []string, lID mtypes.LeaseID, replicaIndex int, tty bool, stdin bool, serviceName string, cmd ...string) (sdktest.BufferWriter, error)

func TestMigrateHostname

func TestMigrateHostname(clientCtx client.Context, leaseID mtypes.LeaseID, dseq uint64, hostname string, cmd ...string) (sdktest.BufferWriter, error)

func TestSendManifest

func TestSendManifest(clientCtx client.Context, id mtypes.BidID, sdlPath string, extraArgs ...string) (sdktest.BufferWriter, error)

TestSendManifest for integration testing this is similar to cli command exampled below

akash provider send-manifest --owner <address> \
	--dseq 7 \
	--provider <address> ./../_run/kube/deployment.yaml \
	--home=/tmp/akash_integration_TestE2EApp_324892307/.akashctl --node=tcp://0.0.0.0:41863