Versions in this module Expand all Collapse all v0 v0.0.1 Mar 27, 2024 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 GenericManifest = blockless.FunctionManifest + var GenericPeerID = peer.ID([]byte{ ... }) + var GenericPeerIDs = []peer.ID + var GenericString = "test" + var GenericUUID = uuid.UUID + var NoopLogger = zerolog.New(io.Discard) + type Executor struct + ExecFunctionFunc func(string, execute.Request) (execute.Result, error) + func BaselineExecutor(t *testing.T) *Executor + func (e *Executor) ExecuteFunction(requestID string, req execute.Request) (execute.Result, error) + type FStore struct + GetFunc func(string) (*blockless.FunctionManifest, error) + InstallFunc func(string, string) error + InstalledFunc func(string) (bool, error) + InstalledFunctionsFunc func() ([]string, error) + SyncFunc func(string) error + func BaselineFStore(t *testing.T) *FStore + func (f *FStore) Get(cid string) (*blockless.FunctionManifest, error) + func (f *FStore) Install(address string, cid string) error + func (f *FStore) Installed(cid string) (bool, error) + func (f *FStore) InstalledFunctions() ([]string, error) + func (f *FStore) Sync(cid string) error + type Node struct + ExecuteFunctionFunc func(context.Context, execute.Request, string) (codes.Code, string, execute.ResultMap, execute.Cluster, error) + ExecutionResultFunc func(id string) (execute.Result, bool) + PublishFunctionInstallFunc func(ctx context.Context, uri string, cid string, subgroup string) error + func BaselineNode(t *testing.T) *Node + func (n *Node) ExecuteFunction(ctx context.Context, req execute.Request, subgroup string) (codes.Code, string, execute.ResultMap, execute.Cluster, error) + func (n *Node) ExecutionResult(id string) (execute.Result, bool) + func (n *Node) PublishFunctionInstall(ctx context.Context, uri string, cid string, subgroup string) error + type PeerStore struct + GetFunc func(peer.ID) (blockless.Peer, error) + PeersFunc func() ([]blockless.Peer, error) + RemoveFunc func(peer.ID) error + StoreFunc func(peer.ID, multiaddr.Multiaddr, peer.AddrInfo) error + func BaselinePeerStore(t *testing.T) *PeerStore + func (p *PeerStore) Get(id peer.ID) (blockless.Peer, error) + func (p *PeerStore) Peers() ([]blockless.Peer, error) + func (p *PeerStore) Remove(id peer.ID) error + func (p *PeerStore) Store(id peer.ID, addr multiaddr.Multiaddr, info peer.AddrInfo) error + type Store struct + DeleteFunc func(key string) error + GetFunc func(key string) (string, error) + GetRecordFunc func(key string, value interface{}) error + KeysFunc func() []string + SetFunc func(key string, value string) error + SetRecordFunc func(key string, value interface{}) error + func BaselineStore(t *testing.T) *Store + func (s *Store) Delete(key string) error + func (s *Store) Get(key string) (string, error) + func (s *Store) GetRecord(key string, value interface{}) error + func (s *Store) Keys() []string + func (s *Store) Set(key string, value string) error + func (s *Store) SetRecord(key string, value interface{}) error