node

Dec 26, 2023

Changes in this version

type RuntimeConfig

+ DisableRPC bool

Oct 18, 2022

Changes in this version

type RuntimeConfig

+ WSMaxSession int

Oct 11, 2022

Changes in this version

+ const ParamBK

+ const ParamKey

+ const UrlDB

type Rest

+ func (r *Rest) BucketGetValue(ctx echo.Context) error

+ func (r *Rest) BucketInjector(next echo.HandlerFunc) echo.HandlerFunc

+ func (r *Rest) RegisterDBHandlers(g *echo.Group)

type RuntimeConfig

+ RPCRosetta bool

Aug 9, 2022

Changes in this version

+ type ChainResetParam struct

+ BlockHash common.HexBytes

+ Height int64

Jan 20, 2022

Changes in this version

+ type ChainBackupParam struct

+ Manual bool

type RuntimeConfig

+ RPCBatchLimit int

Dec 14, 2021

Changes in this version

type ChainConfig

+ ValidateTxOnSend bool

Oct 1, 2021

Changes in this version

type ChainConfig

+ ChildrenLimit *int

+ NephewsLimit *int

Apr 16, 2021

Changes in this version

+ const TaskID

type Node

+ func (n *Node) RunChainTask(cid int, task string, params json.RawMessage) error

type Rest

+ func (r *Rest) RunChainTask(ctx echo.Context) error

Jan 29, 2021

Changes in this version

type ChainConfig

+ TxTimeout int64

Oct 16, 2020

Changes in this version

type ChainConfig

+ Platform string

Oct 12, 2020

Changes in this version

+ const AuthScheme

+ const BaseUnixDomainSockHttpEndpoint

+ const ChainConfigFileName

+ const ChainGenesisZipFileName

+ const DefaultEEInstances

+ const ParamCID

+ const ParamID

+ const RestoreDirectoryPrefix

+ const UrlChain

+ const UrlChainRes

+ const UrlStats

+ const UrlSystem

+ const UrlUser

+ const UrlUserRes

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrNotExists = errors.New("not exists")

+ func EqualsSyscallErrno(err error, sen syscall.Errno) bool

+ func FileDownload(resp *http.Response) (b []byte, fileName string, err error)

+ func GetFileMultipart(ctx echo.Context, fieldname string) ([]byte, error)

+ func GetJsonMultipart(ctx echo.Context, ptr interface{}) error

+ func MultipartCopy(mw *multipart.Writer, fieldName string, r io.Reader) error

+ func MultipartFile(mw *multipart.Writer, fieldName, fileName string) error

+ func MultipartJson(mw *multipart.Writer, fieldName string, v interface{}) error

+ func NewRestError(r *http.Response) error

+ func RegisterInspectFunc(name string, f InspectFunc) error

+ func RegisterRest(n *Node)

+ func ResolveAbsolute(baseFile, targetPath string) string

+ func UrlWithParams(reqUrl string, reqParams ...*url.Values) string

+ type Auth struct

+ SkipIfEmptyUsers bool

+ func NewAuth(filePath, prefix string) *Auth

+ func (a *Auth) AddUser(id string) error

+ func (a *Auth) GetUsers() []string

+ func (a *Auth) IsEmptyUsers() bool

+ func (a *Auth) MiddlewareFunc() echo.MiddlewareFunc

+ func (a *Auth) RemoveUser(id string) error

+ func (a *Auth) SetSkip(r *echo.Route, skip bool)

+ type BackupInfo struct

+ Name string

+ Size int64

+ type Chain struct

+ type ChainConfig struct

+ AutoStart bool

+ Channel string

+ ConcurrencyLevel int

+ DBType string

+ DefWaitTimeout int64

+ MaxBlockTxBytes int

+ MaxWaitTimeout int64

+ NodeCache string

+ NormalTxPoolSize int

+ PatchTxPoolSize int

+ Role uint

+ SecureAeads string

+ SecureSuites string

+ SeedAddr string

+ func NewChainConfig(cfg *chain.Config) *ChainConfig

+ type ChainImportParam struct

+ DBPath string

+ Height int64

+ type ChainInspectView struct

+ Config *ChainConfig

+ GenesisTx json.RawMessage

+ Module map[string]interface{}

+ func NewChainInspectView(c *Chain) *ChainInspectView

+ type ChainPruneParam struct

+ DBType string

+ Height int64

+ type ChainView struct

+ CID common.HexInt32

+ Channel string

+ Height int64

+ LastError string

+ NID common.HexInt32

+ State string

+ func NewChainView(c *Chain) *ChainView

+ type ConfigureParam struct

+ Key string

+ Value string

+ type InspectFunc func(c module.Chain, informal bool) map[string]interface

+ type JsonTemplate struct

+ func NewJsonTemplate(name string) *JsonTemplate

+ func (t *JsonTemplate) Response(format string, v interface{}, resp *echo.Response) error

+ type Node struct

+ func NewNode(w module.Wallet, cfg *StaticConfig, l log.Logger) *Node

+ func (n *Node) BackupChain(cid int) (string, error)

+ func (n *Node) CanAdd(cid, nid int, channel string, overwrite bool) error

+ func (n *Node) Configure(key string, value string) error

+ func (n *Node) ConfigureChain(cid int, key string, value string) error

+ func (n *Node) GetBackups() ([]BackupInfo, error)

+ func (n *Node) GetChain(cid int) *Chain

+ func (n *Node) GetChainByChannel(channel string) *Chain

+ func (n *Node) GetChainBySelector(s string) *Chain

+ func (n *Node) GetChains() []*Chain

+ func (n *Node) GetRestore() *RestoreView

+ func (n *Node) ImportChain(cid int, s string, height int64) error

+ func (n *Node) JoinChain(p *ChainConfig, genesis []byte) (module.Chain, error)

+ func (n *Node) LeaveChain(cid int) error

+ func (n *Node) PruneChain(cid int, dbt string, height int64) error

+ func (n *Node) ResetChain(cid int) error

+ func (n *Node) Start()

+ func (n *Node) StartChain(cid int) error

+ func (n *Node) StartRestore(name string, overwrite bool) (ret error)

+ func (n *Node) Stop()

+ func (n *Node) StopChain(cid int) error

+ func (n *Node) StopRestore() error

+ func (n *Node) VerifyChain(cid int) error

+ type Rest struct

+ func (r *Rest) AddUser(ctx echo.Context) error

+ func (r *Rest) BackupChain(ctx echo.Context) error

+ func (r *Rest) ChainInjector(next echo.HandlerFunc) echo.HandlerFunc

+ func (r *Rest) ConfigureChain(ctx echo.Context) error

+ func (r *Rest) ConfigureSystem(ctx echo.Context) error

+ func (r *Rest) GetBackups(ctx echo.Context) error

+ func (r *Rest) GetChain(ctx echo.Context) error

+ func (r *Rest) GetChainConfig(ctx echo.Context) error

+ func (r *Rest) GetChainGenesis(ctx echo.Context) error

+ func (r *Rest) GetChains(ctx echo.Context) error

+ func (r *Rest) GetRestore(ctx echo.Context) error

+ func (r *Rest) GetSystem(ctx echo.Context) error

+ func (r *Rest) GetSystemConfig(ctx echo.Context) error

+ func (r *Rest) ImportChain(ctx echo.Context) error

+ func (r *Rest) JoinChain(ctx echo.Context) error

+ func (r *Rest) LeaveChain(ctx echo.Context) error

+ func (r *Rest) PruneChain(ctx echo.Context) error

+ func (r *Rest) RegisterChainHandlers(g *echo.Group)

+ func (r *Rest) RegisterStatsHandlers(g *echo.Group)

+ func (r *Rest) RegisterSystemHandlers(g *echo.Group)

+ func (r *Rest) RegisterUserHandlers(g *echo.Group)

+ func (r *Rest) RegistryBackupHandlers(g *echo.Group)

+ func (r *Rest) RegistryRestoreHandlers(g *echo.Group)

+ func (r *Rest) RemoveUser(ctx echo.Context) error

+ func (r *Rest) ResetChain(ctx echo.Context) error

+ func (r *Rest) ResponseStatsView(resp *echo.Response) error

+ func (r *Rest) RestoreBackup(ctx echo.Context) error

+ func (r *Rest) StartChain(ctx echo.Context) error

+ func (r *Rest) StopChain(ctx echo.Context) error

+ func (r *Rest) StopRestore(ctx echo.Context) error

+ func (r *Rest) StreamStats(ctx echo.Context) error

+ func (r *Rest) Users(ctx echo.Context) error

+ func (r *Rest) VerifyChain(ctx echo.Context) error

+ type RestError struct

+ func (e *RestError) Error() string

+ func (e *RestError) Response() string

+ func (e *RestError) StatusCode() int

+ type RestoreBackupParam struct

+ Name string

+ Overwrite bool

+ type RestoreManager struct

+ func (m *RestoreManager) GetStatus() *RestoreStatus

+ func (m *RestoreManager) Start(node *Node, file string, baseDir string, overwrite bool) (ret error)

+ func (m *RestoreManager) Stop() error

+ type RestoreState int

+ const RestoreFailed

+ const RestoreNone

+ const RestoreStarted

+ const RestoreStopping

+ const RestoreSuccess

+ func (s RestoreState) String() string

+ type RestoreStatus struct

+ Error error

+ File string

+ Overwrite bool

+ State string

+ type RestoreView struct

+ Error string

+ Name string

+ Overwrite bool

+ State string

+ type RuntimeConfig struct

+ EEInstances int

+ FilePath string

+ RPCDefaultChannel string

+ RPCIncludeDebug bool

+ type StaticConfig struct

+ AuthSkipIfEmptyUsers bool

+ BackupDir string

+ BaseDir string

+ BuildTags string

+ BuildVersion string

+ CliSocket string

+ EESocket string

+ Engines string

+ FilePath string

+ NIDForP2P bool

+ P2PAddr string

+ P2PListenAddr string

+ RPCAddr string

+ RPCDump bool

+ func (c *StaticConfig) AbsBaseDir() string

+ func (c *StaticConfig) FillEmpty(addr module.Address)

+ func (c *StaticConfig) ResolveAbsolute(targetPath string) string

+ func (c *StaticConfig) ResolveRelative(targetPath string) string

+ func (c *StaticConfig) SetFilePath(path string) string

+ type StatsView struct

+ Chains []map[string]interface{}

+ Timestamp time.Time

+ type StreamCallbackFunc func(respPtr interface{}) error

+ type SystemView struct

+ BuildTags string

+ BuildVersion string

+ Config interface{}

+ Setting struct{ ... }

+ type UnixDomainSockHttpClient struct

+ func NewUnixDomainSockHttpClient(sockPath string) *UnixDomainSockHttpClient

+ func (c *UnixDomainSockHttpClient) Delete(reqUrl string, respPtr interface{}) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) Do(method, reqUrl string, reqPtr, respPtr interface{}) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) Get(reqUrl string, respPtr interface{}, reqParams ...*url.Values) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) Post(reqUrl string, respPtr interface{}) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) PostWithFile(reqUrl string, reqPtr interface{}, fieldName, fileName string, ...) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) PostWithJson(reqUrl string, reqPtr interface{}, respPtr interface{}) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) PostWithReader(reqUrl string, reqPtr interface{}, fieldName string, r io.Reader, ...) (resp *http.Response, err error)

+ func (c *UnixDomainSockHttpClient) Stream(reqUrl string, reqPtr, respPtr interface{}, respFunc StreamCallbackFunc, ...) (resp *http.Response, err error)

+ type UnixDomainSockHttpServer struct

+ func NewUnixDomainSockHttpServer(sockPath string, e *echo.Echo) *UnixDomainSockHttpServer

+ func (s *UnixDomainSockHttpServer) Start() error

+ func (s *UnixDomainSockHttpServer) Stop() error