testutil

package

v0.4.0 Latest Latest Go to latest Published: Apr 8, 2019 License: Apache-2.0 Imports: 25 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/akash-network/node

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Address(t *testing.T) []byte
func AfterThreadStart(t *testing.T) <-chan time.Time
func CloseDeployment(t *testing.T, st state.State, app apptypes.Application, deployment *base.Bytes, ...)
func CloseFulfillment(t *testing.T, st state.State, app apptypes.Application, key crypto.PrivKey, ...)
func CloseLease(t *testing.T, st state.State, app apptypes.Application, id types.LeaseID, ...)
func CreateAccount(t *testing.T, state state.State) (*types.Account, crypto.PrivKey)
func CreateDeployment(t *testing.T, st state.State, app apptypes.Application, account *types.Account, ...) (*types.Deployment, *types.DeploymentGroups)
func CreateFulfillment(t *testing.T, st state.State, app apptypes.Application, provider base.Bytes, ...) *types.Fulfillment
func CreateLease(t *testing.T, st state.State, app apptypes.Application, provider base.Bytes, ...) *types.Lease
func CreateOrder(t *testing.T, st state.State, app apptypes.Application, account *types.Account, ...) *types.Order
func CreateProvider(t *testing.T, st state.State, app apptypes.Application, account *types.Account, ...) *types.Provider
func Deployment(tenant base.Bytes, nonce uint64, version ...[]byte) *types.Deployment
func DeploymentAddress(t *testing.T) []byte
func DeploymentGroup(daddr []byte, nonce uint64) *types.DeploymentGroup
func DeploymentGroups(deployment base.Bytes, nonce uint64) *types.DeploymentGroups
func Fulfillment(provider base.Bytes, deplyment base.Bytes, group, order uint64, price uint64) *types.Fulfillment
func HexAddress(t *testing.T) string
func HexDeploymentAddress(t *testing.T) string
func KeyManager(t *testing.T) keys.Keybase
func Lease(provider base.Bytes, deplyment base.Bytes, group, order uint64, price uint64) *types.Lease
func Logger() log.Logger
func ManifestGroupsForDeploymentGroups(t *testing.T, dgroups []*types.DeploymentGroup) []*types.ManifestGroup
func NewApp(t *testing.T, gen *types.Genesis) abci_types.Application
func NewNamedKey(t *testing.T) (keys.Info, keys.Keybase)
func NewState(t *testing.T, gen *types.Genesis) (state.CommitState, state.CacheState)
func Order(deploymentAddress base.Bytes, groupSeq, orderSeq uint64) *types.Order
func PrivateKey(t *testing.T) crypto.PrivKey
func PrivateKeySigner(t *testing.T) (txutil.Signer, crypto.PrivKey)
func Provider(account base.Bytes, nonce uint64) *types.Provider
func ProviderTx(account *types.Account, key crypto.PrivKey, nonce uint64) *types.Tx
func PublicKey(t *testing.T) crypto.PubKey
func ResourceGroup() types.ResourceGroup
func ResourceUnit() types.ResourceUnit
func Shrug(t *testing.T, issue int)
func Signer(t *testing.T, kmgr keys.Keybase) txutil.Signer
func SleepForThreadStart(t *testing.T)
func TempDir(t *testing.T) string
func UpdateDeployment(t *testing.T, st state.State, app apptypes.Application, key crypto.PrivKey, ...) *types.TxUpdateDeployment
func WaitReady(t *testing.T, ch <-chan struct{})
func WithAkashDir(t *testing.T, fn func(string))
func WithTempDir(t *testing.T, fn func(string))
func WithTempDirEnv(t *testing.T, key string, fn func(string))
type MockGRPCStreamServer
- func (s MockGRPCStreamServer) Context() context.Context
- func (s MockGRPCStreamServer) RecvMsg(m interface{}) error
- func (s MockGRPCStreamServer) SendHeader(metadata.MD) error
- func (s MockGRPCStreamServer) SendMsg(m interface{}) error
- func (s MockGRPCStreamServer) SetHeader(metadata.MD) error
- func (s MockGRPCStreamServer) SetTrailer(metadata.MD)
type ReadCloser
- func (r ReadCloser) Close() error

Constants ¶

View Source

const (
	KeyPasswd = "0123456789"
	KeyAlgo   = keys.Secp256k1
	KeyName   = "test"
	Language  = keys.English
)

Variables ¶

This section is empty.

Functions ¶

func Address ¶ added in v0.0.3

func Address(t *testing.T) []byte

func AfterThreadStart ¶ added in v0.0.7

func AfterThreadStart(t *testing.T) <-chan time.Time

func CloseDeployment ¶ added in v0.0.2

func CloseDeployment(t *testing.T, st state.State, app apptypes.Application, deployment *base.Bytes, key crypto.PrivKey)

func CloseFulfillment ¶ added in v0.0.4

func CloseFulfillment(t *testing.T, st state.State, app apptypes.Application, key crypto.PrivKey, fulfillment *types.Fulfillment)

func CloseLease ¶ added in v0.0.5

func CloseLease(t *testing.T, st state.State, app apptypes.Application, id types.LeaseID, key crypto.PrivKey)

func CreateAccount ¶

func CreateAccount(t *testing.T, state state.State) (*types.Account, crypto.PrivKey)

func CreateDeployment ¶

func CreateDeployment(t *testing.T, st state.State, app apptypes.Application, account *types.Account, key crypto.PrivKey, nonce uint64) (*types.Deployment, *types.DeploymentGroups)

func CreateFulfillment ¶

func CreateFulfillment(t *testing.T, st state.State, app apptypes.Application, provider base.Bytes, key crypto.PrivKey, deployment base.Bytes, group, order, price uint64) *types.Fulfillment

func CreateLease ¶

func CreateLease(t *testing.T, st state.State, app apptypes.Application, provider base.Bytes, key crypto.PrivKey, deployment base.Bytes, group, order, price uint64) *types.Lease

func CreateOrder ¶

func CreateOrder(t *testing.T, st state.State, app apptypes.Application, account *types.Account, key crypto.PrivKey, deploymentAddress base.Bytes, groupSeq, orderSeq uint64) *types.Order

func CreateProvider ¶

func CreateProvider(t *testing.T, st state.State, app apptypes.Application, account *types.Account, key crypto.PrivKey, nonce uint64) *types.Provider

func Deployment ¶

func Deployment(tenant base.Bytes, nonce uint64, version ...[]byte) *types.Deployment

func DeploymentAddress ¶ added in v0.0.3

func DeploymentAddress(t *testing.T) []byte

func DeploymentGroup ¶ added in v0.3.0

func DeploymentGroup(daddr []byte, nonce uint64) *types.DeploymentGroup

func DeploymentGroups ¶ added in v0.0.2

func DeploymentGroups(deployment base.Bytes, nonce uint64) *types.DeploymentGroups

func Fulfillment ¶

func Fulfillment(provider base.Bytes, deplyment base.Bytes, group, order uint64, price uint64) *types.Fulfillment

func HexAddress ¶ added in v0.0.3

func HexAddress(t *testing.T) string

func HexDeploymentAddress ¶ added in v0.0.3

func HexDeploymentAddress(t *testing.T) string

func KeyManager ¶

func KeyManager(t *testing.T) keys.Keybase

func Lease ¶

func Lease(provider base.Bytes, deplyment base.Bytes, group, order uint64, price uint64) *types.Lease

func Logger ¶

func Logger() log.Logger

func ManifestGroupsForDeploymentGroups ¶ added in v0.3.0

func ManifestGroupsForDeploymentGroups(t *testing.T, dgroups []*types.DeploymentGroup) []*types.ManifestGroup

func NewApp ¶

func NewApp(t *testing.T, gen *types.Genesis) abci_types.Application

func NewNamedKey ¶

func NewNamedKey(t *testing.T) (keys.Info, keys.Keybase)

func NewState ¶

func NewState(t *testing.T, gen *types.Genesis) (state.CommitState, state.CacheState)

NewState used only for testing

func Order ¶

func Order(deploymentAddress base.Bytes, groupSeq, orderSeq uint64) *types.Order

func PrivateKey ¶

func PrivateKey(t *testing.T) crypto.PrivKey

func PrivateKeySigner ¶

func PrivateKeySigner(t *testing.T) (txutil.Signer, crypto.PrivKey)

func Provider ¶

func Provider(account base.Bytes, nonce uint64) *types.Provider

func ProviderTx ¶

func ProviderTx(account *types.Account, key crypto.PrivKey, nonce uint64) *types.Tx

func PublicKey ¶ added in v0.0.3

func PublicKey(t *testing.T) crypto.PubKey

func ResourceGroup ¶ added in v0.3.0

func ResourceGroup() types.ResourceGroup

func ResourceUnit ¶ added in v0.3.0

func ResourceUnit() types.ResourceUnit

func Shrug ¶ added in v0.0.3

func Shrug(t *testing.T, issue int)

func Signer ¶ added in v0.0.6

func Signer(t *testing.T, kmgr keys.Keybase) txutil.Signer

func SleepForThreadStart ¶

func SleepForThreadStart(t *testing.T)

func TempDir ¶

func TempDir(t *testing.T) string

func UpdateDeployment ¶ added in v0.3.0

func UpdateDeployment(t *testing.T,
	st state.State,
	app apptypes.Application,
	key crypto.PrivKey,
	nonce uint64,
	daddr []byte) *types.TxUpdateDeployment

func WaitReady ¶ added in v0.3.0

func WaitReady(t *testing.T, ch <-chan struct{})

func WithAkashDir ¶ added in v0.0.3

func WithAkashDir(t *testing.T, fn func(string))

func WithTempDir ¶ added in v0.0.3

func WithTempDir(t *testing.T, fn func(string))

func WithTempDirEnv ¶ added in v0.0.3

func WithTempDirEnv(t *testing.T, key string, fn func(string))

Types ¶

type MockGRPCStreamServer ¶ added in v0.2.2

type MockGRPCStreamServer struct{}

func (MockGRPCStreamServer) Context ¶ added in v0.2.2

func (s MockGRPCStreamServer) Context() context.Context

func (MockGRPCStreamServer) RecvMsg ¶ added in v0.2.2

func (s MockGRPCStreamServer) RecvMsg(m interface{}) error

func (MockGRPCStreamServer) SendHeader ¶ added in v0.2.2

func (s MockGRPCStreamServer) SendHeader(metadata.MD) error

func (MockGRPCStreamServer) SendMsg ¶ added in v0.2.2

func (s MockGRPCStreamServer) SendMsg(m interface{}) error

func (MockGRPCStreamServer) SetHeader ¶ added in v0.2.2

func (s MockGRPCStreamServer) SetHeader(metadata.MD) error

func (MockGRPCStreamServer) SetTrailer ¶ added in v0.2.2

func (s MockGRPCStreamServer) SetTrailer(metadata.MD)

type ReadCloser ¶ added in v0.2.2

type ReadCloser struct {
	io.Reader
}

func (ReadCloser) Close ¶ added in v0.2.2

func (r ReadCloser) Close() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL