testutils

Documentation

Index

• Constants
• func CreateComputeEventStore(t *testing.T) watcher.EventStore
• func CreateJobEventStore(t *testing.T) watcher.EventStore
• func CreateNatsClient(t *testing.T, url string) *nats.Conn
• func CreateStringEventStore(t *testing.T) (watcher.EventStore, *envelope.Registry)
• func GetJobFromTestOutput(ctx context.Context, t *testing.T, c clientv2.API, out string) *models.Job
• func IsIPFSEnabled(ipfsConnect string) bool
• func MustHaveIPFS(t testing.TB, cfg types.Bacalhau)
• func RestartNatsServer(t *testing.T, natsServer *natsserver.Server) (*natsserver.Server, *nats.Conn)
• func SkipIfArm(_ *testing.T, _ string)
• func StartNats(t *testing.T) (*natsserver.Server, *nats.Conn)
• func StartNatsServer(t *testing.T) *natsserver.Server

Constants

const (
	TypeString = "string"
)

Functions

func CreateComputeEventStore

func CreateComputeEventStore(t *testing.T) watcher.EventStore

func CreateJobEventStore

func CreateJobEventStore(t *testing.T) watcher.EventStore

func CreateNatsClient

func CreateNatsClient(t *testing.T, url string) *nats.Conn

func CreateStringEventStore

func CreateStringEventStore(t *testing.T) (watcher.EventStore, *envelope.Registry)

CreateStringEventStore creates a new event store for string events using BoltDB and returns both the event store and an envelope registry. The returned EventStore must be closed by the caller when no longer needed.

func GetJobFromTestOutput

func GetJobFromTestOutput(ctx context.Context, t *testing.T, c clientv2.API, out string) *models.Job

func IsIPFSEnabled

func IsIPFSEnabled(ipfsConnect string) bool

IsIPFSEnabled will return true if the test is running in an environment that can support IPFS.

func MustHaveIPFS

func MustHaveIPFS(t testing.TB, cfg types.Bacalhau)

MustHaveIPFS will skip the test if the test is running in an environment that cannot support IPFS. Otherwise it returns an IPFS connect string

func RestartNatsServer

func RestartNatsServer(t *testing.T, natsServer *natsserver.Server) (*natsserver.Server, *nats.Conn)

RestartNatsServer will restart the NATS server and return a new server and client using the same port

func SkipIfArm

func SkipIfArm(_ *testing.T, _ string)

func StartNats

func StartNats(t *testing.T) (*natsserver.Server, *nats.Conn)

StartNats will start a NATS server on a random port and return a server and client instances

func StartNatsServer

func StartNatsServer(t *testing.T) *natsserver.Server