harness

Dec 14, 2023

Changes in this version

type Node

+ func (n *Node) StartDaemonWithAuthorization(secret string, ipfsArgs ...string) *Node

May 9, 2023

Changes in this version

+ func CreatePeerNodes(t *testing.T, n int, peerings []Peering) (*Harness, Nodes)

+ func NewRandPort() int

type CmdOpt

+ func RunWithStderr(writer io.Writer) CmdOpt

+ func RunWithStdout(writer io.Writer) CmdOpt

type Node

+ func (n *Node) ConfigFile() string

+ func (n *Node) IPFSDagImport(content io.Reader, cid string, args ...string) error

+ func (n *Node) ReadFile(filename string) string

+ func (n *Node) StartDaemonWithReq(req RunRequest) *Node

+ type Peering struct

+ From int

+ To int

Mar 20, 2023

Changes in this version

type Harness

+ func (h *Harness) ExtractPeerID(m multiaddr.Multiaddr) peer.ID

type Node

+ func (n *Node) Disconnect(other *Node)

+ func (n *Node) PeerWith(other *Node)

+ func (n *Node) ReadUserResourceOverrides() *rcmgr.PartialLimitConfig

+ func (n *Node) SwarmAddrsWithPeerIDs() []multiaddr.Multiaddr

+ func (n *Node) SwarmAddrsWithoutPeerIDs() []multiaddr.Multiaddr

+ func (n *Node) UpdateUserSuppliedResourceManagerOverrides(f func(overrides *rcmgr.PartialLimitConfig))

+ func (n *Node) WriteBytes(filename string, b []byte)

+ func (n *Node) WriteUserSuppliedResourceOverrides(c *rcmgr.PartialLimitConfig)

type Nodes

+ func (n Nodes) ForEachPar(f func(*Node))

type RunResult

+ func (r *RunResult) ExitCode() int

+ type TestLogger struct

+ func NewTestLogger(t *testing.T) *TestLogger

+ func (t *TestLogger) AddPrefix(prefix string) *TestLogger

+ func (t *TestLogger) EnableLogs()

+ func (t *TestLogger) Fatal(args ...any)

+ func (t *TestLogger) Fatalf(format string, args ...any)

+ func (t *TestLogger) Log(args ...any)

+ func (t *TestLogger) Logf(format string, args ...any)

Jan 23, 2023

Changes in this version

+ var RunFuncStart = (*exec.Cmd).Start

+ func EnableDebugLogging()

+ func WaitForFile(path string, timeout time.Duration) error

+ type Buffer struct

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) Lines() []string

+ func (b *Buffer) String() string

+ func (b *Buffer) Trimmed() string

+ func (b *Buffer) Write(p []byte) (n int, err error)

+ type CmdOpt func(*exec.Cmd)

+ func RunWithEnv(env map[string]string) CmdOpt

+ func RunWithPath(path string) CmdOpt

+ func RunWithStdin(reader io.Reader) CmdOpt

+ func RunWithStdinStr(s string) CmdOpt

+ type HTTPClient struct

+ BaseURL string

+ Client *http.Client

+ TemplateData any

+ Timeout time.Duration

+ func (c *HTTPClient) BuildURL(urlPath string) string

+ func (c *HTTPClient) DisableRedirects() *HTTPClient

+ func (c *HTTPClient) Do(req *http.Request) *HTTPResponse

+ func (c *HTTPClient) Get(urlPath string, opts ...func(*http.Request)) *HTTPResponse

+ func (c *HTTPClient) Head(urlPath string, opts ...func(*http.Request)) *HTTPResponse

+ func (c *HTTPClient) Post(urlPath string, body io.Reader, opts ...func(*http.Request)) *HTTPResponse

+ func (c *HTTPClient) PostStr(urlpath, body string, opts ...func(*http.Request)) *HTTPResponse

+ func (c *HTTPClient) WithHeader(k, v string) func(h *http.Request)

+ type HTTPResponse struct

+ Body string

+ Headers http.Header

+ Resp *http.Response

+ StatusCode int

+ type Harness struct

+ Dir string

+ IPFSBin string

+ Nodes Nodes

+ NodesRoot string

+ Runner *Runner

+ func New(options ...func(h *Harness)) *Harness

+ func NewT(t *testing.T, options ...func(h *Harness)) *Harness

+ func (h *Harness) Cleanup()

+ func (h *Harness) Mkdirs(paths ...string)

+ func (h *Harness) NewNode() *Node

+ func (h *Harness) NewNodes(count int) Nodes

+ func (h *Harness) Sh(expr string) RunResult

+ func (h *Harness) TempFile() *os.File

+ func (h *Harness) WriteFile(filename, contents string)

+ func (h *Harness) WriteToTemp(contents string) string

+ type Node struct

+ APIListenAddr multiaddr.Multiaddr

+ Daemon *RunResult

+ Dir string

+ EnableMDNS bool

+ GatewayListenAddr multiaddr.Multiaddr

+ ID int

+ IPFSBin string

+ Runner *Runner

+ SwarmAddr multiaddr.Multiaddr

+ func BuildNode(ipfsBin, baseDir string, id int) *Node

+ func (n *Node) APIAddr() multiaddr.Multiaddr

+ func (n *Node) APIClient() *HTTPClient

+ func (n *Node) APIURL() string

+ func (n *Node) Connect(other *Node) *Node

+ func (n *Node) GatewayClient() *HTTPClient

+ func (n *Node) GatewayURL() string

+ func (n *Node) GetIPFSConfig(key string, val interface{})

+ func (n *Node) IPFS(args ...string) RunResult

+ func (n *Node) IPFSAdd(content io.Reader, args ...string) string

+ func (n *Node) IPFSAddStr(content string, args ...string) string

+ func (n *Node) IPFSCommands() []string

+ func (n *Node) Init(ipfsArgs ...string) *Node

+ func (n *Node) IsAlive() bool

+ func (n *Node) PeerID() peer.ID

+ func (n *Node) Peers() []multiaddr.Multiaddr

+ func (n *Node) PipeStrToIPFS(s string, args ...string) RunResult

+ func (n *Node) PipeToIPFS(reader io.Reader, args ...string) RunResult

+ func (n *Node) ReadConfig() *config.Config

+ func (n *Node) RunIPFS(args ...string) RunResult

+ func (n *Node) RunPipeToIPFS(reader io.Reader, args ...string) RunResult

+ func (n *Node) SetIPFSConfig(key string, val interface{}, flags ...string)

+ func (n *Node) StartDaemon(ipfsArgs ...string) *Node

+ func (n *Node) StopDaemon() *Node

+ func (n *Node) SwarmAddrs() []multiaddr.Multiaddr

+ func (n *Node) TryAPIAddr() (multiaddr.Multiaddr, error)

+ func (n *Node) UpdateConfig(f func(cfg *config.Config))

+ func (n *Node) WaitOnAPI() *Node

+ func (n *Node) WriteConfig(c *config.Config)

+ type Nodes []*Node

+ func (n Nodes) Connect() Nodes

+ func (n Nodes) Init(args ...string) Nodes

+ func (n Nodes) StartDaemons() Nodes

+ func (n Nodes) StopDaemons() Nodes

+ type RunFunc func(*exec.Cmd) error

+ type RunRequest struct

+ Args []string

+ CmdOpts []CmdOpt

+ Path string

+ RunFunc func(*exec.Cmd) error

+ Verbose bool

+ type RunResult struct

+ Cmd *exec.Cmd

+ Err error

+ ExitErr *exec.ExitError

+ Stderr *Buffer

+ Stdout *Buffer

+ type Runner struct

+ Dir string

+ Env map[string]string

+ Verbose bool

+ func (r *Runner) AssertNoError(result RunResult)

+ func (r *Runner) MustRun(req RunRequest) RunResult

+ func (r *Runner) Run(req RunRequest) RunResult