Versions in this module Expand all Collapse all v0 v0.0.1 Jun 27, 2024 Changes in this version + type Client interface + AddNode func(ctx context.Context, name string, execPath string, opts ...OpOption) (*rpcpb.AddNodeResponse, error) + AddPermissionlessValidator func(ctx context.Context, validatorSpec []*rpcpb.PermissionlessValidatorSpec) (*rpcpb.AddPermissionlessValidatorResponse, error) + AttachPeer func(ctx context.Context, nodeName string) (*rpcpb.AttachPeerResponse, error) + Close func() error + CreateBlockchains func(ctx context.Context, blockchainSpecs []*rpcpb.BlockchainSpec) (*rpcpb.CreateBlockchainsResponse, error) + CreateSubnets func(ctx context.Context, subnetSpecs []*rpcpb.SubnetSpec) (*rpcpb.CreateSubnetsResponse, error) + GetSnapshotNames func(ctx context.Context) ([]string, error) + Health func(ctx context.Context) (*rpcpb.HealthResponse, error) + LoadSnapshot func(ctx context.Context, snapshotName string, opts ...OpOption) (*rpcpb.LoadSnapshotResponse, error) + PauseNode func(ctx context.Context, name string) (*rpcpb.PauseNodeResponse, error) + Ping func(ctx context.Context) (*rpcpb.PingResponse, error) + RPCVersion func(ctx context.Context) (*rpcpb.RPCVersionResponse, error) + RemoveNode func(ctx context.Context, name string) (*rpcpb.RemoveNodeResponse, error) + RemoveSnapshot func(ctx context.Context, snapshotName string) (*rpcpb.RemoveSnapshotResponse, error) + RemoveSubnetValidator func(ctx context.Context, validatorSpec []*rpcpb.RemoveSubnetValidatorSpec) (*rpcpb.RemoveSubnetValidatorResponse, error) + RestartNode func(ctx context.Context, name string, opts ...OpOption) (*rpcpb.RestartNodeResponse, error) + ResumeNode func(ctx context.Context, name string) (*rpcpb.ResumeNodeResponse, error) + SaveSnapshot func(ctx context.Context, snapshotName string) (*rpcpb.SaveSnapshotResponse, error) + SendOutboundMessage func(ctx context.Context, nodeName string, peerID string, op uint32, msgBody []byte) (*rpcpb.SendOutboundMessageResponse, error) + Start func(ctx context.Context, execPath string, opts ...OpOption) (*rpcpb.StartResponse, error) + Status func(ctx context.Context) (*rpcpb.StatusResponse, error) + Stop func(ctx context.Context) (*rpcpb.StopResponse, error) + StreamStatus func(ctx context.Context, pushInterval time.Duration) (<-chan *rpcpb.ClusterInfo, error) + TransformElasticSubnets func(ctx context.Context, elasticSubnetSpecs []*rpcpb.ElasticSubnetSpec) (*rpcpb.TransformElasticSubnetsResponse, error) + URIs func(ctx context.Context) ([]string, error) + WaitForHealthy func(ctx context.Context) (*rpcpb.WaitForHealthyResponse, error) + func New(cfg Config, log logging.Logger) (Client, error) + type Config struct + DialTimeout time.Duration + Endpoint string + type Op struct + type OpOption func(*Op) + func WithBlockchainSpecs(blockchainSpecs []*rpcpb.BlockchainSpec) OpOption + func WithChainConfigs(chainConfigs map[string]string) OpOption + func WithCustomNodeConfigs(customNodeConfigs map[string]string) OpOption + func WithDynamicPorts(dynamicPorts bool) OpOption + func WithExecPath(execPath string) OpOption + func WithGlobalNodeConfig(nodeConfig string) OpOption + func WithNumNodes(numNodes uint32) OpOption + func WithNumSubnets(numSubnets uint32) OpOption + func WithPluginDir(pluginDir string) OpOption + func WithReassignPortsIfUsed(reassignPortsIfUsed bool) OpOption + func WithRootDataDir(rootDataDir string) OpOption + func WithSubnetConfigs(subnetConfigs map[string]string) OpOption + func WithTrackSubnets(trackSubnets string) OpOption + func WithUpgradeConfigs(upgradeConfigs map[string]string) OpOption + func WithWhitelistedSubnets(trackSubnets string) OpOption
Go to main page