mocks

Documentation

Index

• type BinaryChecker
  • func (_m *BinaryChecker) ExistsWithLatestVersion(name string, binaryPrefix string) (bool, string, error)
• type Client
  • func (_m *Client) AddNode(ctx context.Context, name string, execPath string, opts ...client.OpOption) (*rpcpb.AddNodeResponse, error)
  • func (_m *Client) AttachPeer(ctx context.Context, nodeName string) (*rpcpb.AttachPeerResponse, error)
  • func (_m *Client) Close() error
  • func (_m *Client) CreateBlockchains(ctx context.Context, blockchainSpecs []*rpcpb.BlockchainSpec) (*rpcpb.CreateBlockchainsResponse, error)
  • func (_m *Client) CreateSubnets(ctx context.Context, opts ...client.OpOption) (*rpcpb.CreateSubnetsResponse, error)
  • func (_m *Client) GetSnapshotNames(ctx context.Context) ([]string, error)
  • func (_m *Client) Health(ctx context.Context) (*rpcpb.HealthResponse, error)
  • func (_m *Client) LoadSnapshot(ctx context.Context, snapshotName string, opts ...client.OpOption) (*rpcpb.LoadSnapshotResponse, error)
  • func (_m *Client) Ping(ctx context.Context) (*rpcpb.PingResponse, error)
  • func (_m *Client) RemoveNode(ctx context.Context, name string) (*rpcpb.RemoveNodeResponse, error)
  • func (_m *Client) RemoveSnapshot(ctx context.Context, snapshotName string) (*rpcpb.RemoveSnapshotResponse, error)
  • func (_m *Client) RestartNode(ctx context.Context, name string, opts ...client.OpOption) (*rpcpb.RestartNodeResponse, error)
  • func (_m *Client) SaveSnapshot(ctx context.Context, snapshotName string) (*rpcpb.SaveSnapshotResponse, error)
  • func (_m *Client) SendOutboundMessage(ctx context.Context, nodeName string, peerID string, op uint32, msgBody []byte) (*rpcpb.SendOutboundMessageResponse, error)
  • func (_m *Client) Start(ctx context.Context, execPath string, opts ...client.OpOption) (*rpcpb.StartResponse, error)
  • func (_m *Client) Status(ctx context.Context) (*rpcpb.StatusResponse, error)
  • func (_m *Client) Stop(ctx context.Context) (*rpcpb.StopResponse, error)
  • func (_m *Client) StreamStatus(ctx context.Context, pushInterval time.Duration) (<-chan *rpcpb.ClusterInfo, error)
  • func (_m *Client) URIs(ctx context.Context) ([]string, error)
• type PluginBinaryDownloader
  • func (_m *PluginBinaryDownloader) Download(vmID ids.ID, pluginDir string, binDir string) error
• type ProcessChecker
  • func (_m *ProcessChecker) IsServerProcessRunning() (bool, error)

Types

type BinaryChecker

type BinaryChecker struct {
	mock.Mock
}

BinaryChecker is an autogenerated mock type for the BinaryChecker type

func (*BinaryChecker) ExistsWithLatestVersion

func (_m *BinaryChecker) ExistsWithLatestVersion(name string, binaryPrefix string) (bool, string, error)

ExistsWithLatestVersion provides a mock function with given fields: name, binaryPrefix

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) AddNode

func (_m *Client) AddNode(ctx context.Context, name string, execPath string, opts ...client.OpOption) (*rpcpb.AddNodeResponse, error)

AddNode provides a mock function with given fields: ctx, name, execPath, opts

func (*Client) AttachPeer

func (_m *Client) AttachPeer(ctx context.Context, nodeName string) (*rpcpb.AttachPeerResponse, error)

AttachPeer provides a mock function with given fields: ctx, nodeName

func (*Client) Close

func (_m *Client) Close() error

Close provides a mock function with given fields:

func (*Client) CreateBlockchains

func (_m *Client) CreateBlockchains(ctx context.Context, blockchainSpecs []*rpcpb.BlockchainSpec) (*rpcpb.CreateBlockchainsResponse, error)

CreateBlockchains provides a mock function with given fields: ctx, blockchainSpecs

func (*Client) CreateSubnets

func (_m *Client) CreateSubnets(ctx context.Context, opts ...client.OpOption) (*rpcpb.CreateSubnetsResponse, error)

CreateSubnets provides a mock function with given fields: ctx, opts

func (*Client) GetSnapshotNames

func (_m *Client) GetSnapshotNames(ctx context.Context) ([]string, error)

GetSnapshotNames provides a mock function with given fields: ctx

func (*Client) Health

func (_m *Client) Health(ctx context.Context) (*rpcpb.HealthResponse, error)

Health provides a mock function with given fields: ctx

func (*Client) LoadSnapshot

func (_m *Client) LoadSnapshot(ctx context.Context, snapshotName string, opts ...client.OpOption) (*rpcpb.LoadSnapshotResponse, error)

LoadSnapshot provides a mock function with given fields: ctx, snapshotName

func (*Client) Ping

func (_m *Client) Ping(ctx context.Context) (*rpcpb.PingResponse, error)

Ping provides a mock function with given fields: ctx

func (*Client) RemoveNode

func (_m *Client) RemoveNode(ctx context.Context, name string) (*rpcpb.RemoveNodeResponse, error)

RemoveNode provides a mock function with given fields: ctx, name

func (*Client) RemoveSnapshot

func (_m *Client) RemoveSnapshot(ctx context.Context, snapshotName string) (*rpcpb.RemoveSnapshotResponse, error)

RemoveSnapshot provides a mock function with given fields: ctx, snapshotName

func (*Client) RestartNode

func (_m *Client) RestartNode(ctx context.Context, name string, opts ...client.OpOption) (*rpcpb.RestartNodeResponse, error)

RestartNode provides a mock function with given fields: ctx, name, opts

func (*Client) SaveSnapshot

func (_m *Client) SaveSnapshot(ctx context.Context, snapshotName string) (*rpcpb.SaveSnapshotResponse, error)

SaveSnapshot provides a mock function with given fields: ctx, snapshotName

func (*Client) SendOutboundMessage

func (_m *Client) SendOutboundMessage(ctx context.Context, nodeName string, peerID string, op uint32, msgBody []byte) (*rpcpb.SendOutboundMessageResponse, error)

SendOutboundMessage provides a mock function with given fields: ctx, nodeName, peerID, op, msgBody

func (*Client) Start

func (_m *Client) Start(ctx context.Context, execPath string, opts ...client.OpOption) (*rpcpb.StartResponse, error)

Start provides a mock function with given fields: ctx, execPath, opts

func (*Client) Status

func (_m *Client) Status(ctx context.Context) (*rpcpb.StatusResponse, error)

Status provides a mock function with given fields: ctx

func (*Client) Stop

func (_m *Client) Stop(ctx context.Context) (*rpcpb.StopResponse, error)

Stop provides a mock function with given fields: ctx

func (*Client) StreamStatus

func (_m *Client) StreamStatus(ctx context.Context, pushInterval time.Duration) (<-chan *rpcpb.ClusterInfo, error)

StreamStatus provides a mock function with given fields: ctx, pushInterval

func (*Client) URIs

func (_m *Client) URIs(ctx context.Context) ([]string, error)

URIs provides a mock function with given fields: ctx

type PluginBinaryDownloader

type PluginBinaryDownloader struct {
	mock.Mock
}

PluginBinaryDownloader is an autogenerated mock type for the PluginBinaryDownloader type

func (*PluginBinaryDownloader) Download

func (_m *PluginBinaryDownloader) Download(vmID ids.ID, pluginDir string, binDir string) error

Download provides a mock function with given fields: vmID, pluginDir, binDir

type ProcessChecker

type ProcessChecker struct {
	mock.Mock
}

ProcessChecker is an autogenerated mock type for the ProcessChecker type

func (*ProcessChecker) IsServerProcessRunning

func (_m *ProcessChecker) IsServerProcessRunning() (bool, error)

IsServerProcessRunning provides a mock function with given fields: