test

package

v0.1.0 Latest Latest Go to latest Published: Jan 25, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func StartEtcd() *v1alpha1.EtcdStorageSpec

type Environment struct {
	Logger *slog.Logger

	TestBin string
	// contains filtered or unexported fields
}

func (e *Environment) Start() error

func (e *Environment) StartEtcd() (*v1alpha1.EtcdStorageSpec, error)

FIXME: set the ports to freeports

func (e *Environment) StartJetstream() (*v1alpha1.JetStreamStorageSpec, error)

func (e *Environment) Stop(cause ...string) error

type Session interface {
	G() (*gexec.Session, bool)
	Wait() error
}

func StartCmd(cmd *exec.Cmd) (Session, error)