Versions in this module Expand all Collapse all v0 v0.7.6 Oct 23, 2025 v0.7.5 Jun 30, 2025 Changes in this version + var GenericAddress = "/ip4/127.0.0.1/tcp/9000/p2p/12D3KooWRp3AVk7qtc2Av6xiqgAza1ZouksQaYcS2cvN94kHSCoa" + var GenericError = errors.New("dummy error") + var GenericExecutionRequest = execute.Request + var GenericExecutionResult = execute.Result + var GenericExecutionResultMap = execute.ResultMap + var GenericFunctionRecord = bls.FunctionRecord + var GenericManifest = bls.FunctionManifest + var GenericMultiaddress = multiaddr.StringCast(GenericAddress) + var GenericPeer = bls.Peer + var GenericPeerID = peer.ID([]byte{ ... }) + var GenericPeerIDs = []peer.ID + var GenericString = "test" + var GenericUUID = uuid.UUID + var NoopLogger = zerolog.New(io.Discard) + type APINode struct + ExecuteFunctionFunc func(context.Context, execute.Request, string) (codes.Code, string, execute.ResultMap, execute.Cluster, error) + ExecutionResultFunc func(id string) (execute.ResultMap, bool) + PublishFunctionInstallFunc func(ctx context.Context, uri string, cid string, subgroup string) error + func BaselineNode(t *testing.T) *APINode + func (n *APINode) ExecuteFunction(ctx context.Context, req execute.Request, subgroup string) (codes.Code, string, execute.ResultMap, execute.Cluster, error) + func (n *APINode) ExecutionResult(id string) (execute.ResultMap, bool) + func (n *APINode) PublishFunctionInstall(ctx context.Context, uri string, cid string, subgroup string) error + type Codec struct + MarshalFunc func(any) ([]byte, error) + UnmarshalFunc func([]byte, any) error + func BaselineCodec(t *testing.T) *Codec + func (c *Codec) Marshal(obj any) ([]byte, error) + func (c *Codec) Unmarshal(data []byte, obj any) error + type Executor struct + ExecFunctionFunc func(context.Context, string, execute.Request) (execute.Result, error) + func BaselineExecutor(t *testing.T) *Executor + func (e *Executor) ExecuteFunction(ctx context.Context, requestID string, req execute.Request) (execute.Result, error) + type FStore struct + InstallFunc func(context.Context, string, string) error + IsInstalledFunc func(string) (bool, error) + SyncFunc func(context.Context, bool) error + func BaselineFStore(t *testing.T) *FStore + func (f *FStore) Install(ctx context.Context, address string, cid string) error + func (f *FStore) IsInstalled(cid string) (bool, error) + func (f *FStore) Sync(ctx context.Context, haltOnError bool) error + type NodeCore struct + ConnectedFunc func(peer.ID) bool + HostFunc func() *host.Host + IDFunc func() string + JoinTopicFunc func(string) error + LogFunc func() *zerolog.Logger + MetricsFunc func() *metrics.Metrics + PublishFunc func(context.Context, bls.Message) error + PublishToTopicFunc func(context.Context, string, bls.Message) error + RunFunc func(context.Context, func(context.Context, peer.ID, string, []byte) error) error + SendFunc func(context.Context, peer.ID, bls.Message) error + SendToManyFunc func(context.Context, []peer.ID, bls.Message, bool) error + SubscribeFunc func(context.Context, string) error + TracerFunc func() *tracing.Tracer + func BaselineNodeCore(t *testing.T) *NodeCore + func (c NodeCore) Connected(peerID peer.ID) bool + func (c NodeCore) Host() *host.Host + func (c NodeCore) ID() string + func (c NodeCore) JoinTopic(topic string) error + func (c NodeCore) Log() *zerolog.Logger + func (c NodeCore) Metrics() *metrics.Metrics + func (c NodeCore) Publish(ctx context.Context, msg bls.Message) error + func (c NodeCore) PublishToTopic(ctx context.Context, topic string, msg bls.Message) error + func (c NodeCore) Run(context.Context, func(context.Context, peer.ID, string, []byte) error) error + func (c NodeCore) Send(ctx context.Context, peerID peer.ID, msg bls.Message) error + func (c NodeCore) SendToMany(ctx context.Context, peerIDs []peer.ID, msg bls.Message, flag bool) error + func (c NodeCore) Subscribe(ctx context.Context, topic string) error + func (c NodeCore) Tracer() *tracing.Tracer + type Store struct + RemoveFunctionFunc func(context.Context, string) error + RemovePeerFunc func(context.Context, peer.ID) error + RetrieveFunctionFunc func(context.Context, string) (bls.FunctionRecord, error) + RetrieveFunctionsFunc func(context.Context) ([]bls.FunctionRecord, error) + RetrievePeerFunc func(context.Context, peer.ID) (bls.Peer, error) + RetrievePeersFunc func(context.Context) ([]bls.Peer, error) + SaveFunctionFunc func(context.Context, bls.FunctionRecord) error + SavePeerFunc func(context.Context, bls.Peer) error + func BaselineStore(t *testing.T) *Store + func (s *Store) RemoveFunction(ctx context.Context, id string) error + func (s *Store) RemovePeer(ctx context.Context, id peer.ID) error + func (s *Store) RetrieveFunction(ctx context.Context, cid string) (bls.FunctionRecord, error) + func (s *Store) RetrieveFunctions(ctx context.Context) ([]bls.FunctionRecord, error) + func (s *Store) RetrievePeer(ctx context.Context, id peer.ID) (bls.Peer, error) + func (s *Store) RetrievePeers(ctx context.Context) ([]bls.Peer, error) + func (s *Store) SaveFunction(ctx context.Context, function bls.FunctionRecord) error + func (s *Store) SavePeer(ctx context.Context, peer bls.Peer) error
Go to main page