chain

Documentation

Index

• Constants
• func GetChannel(channel string, nid int) string
• func IsNodeCacheOption(s string) bool
• func NewChain(wallet module.Wallet, transport module.NetworkTransport, srv *server.Manager, ...) *singleChain
• func NewPlatform(name string, base string, cid int) (base.Platform, error)
• func NewRegulator(logger log.Logger) *regulator
• func ParseNodeCacheOption(s string) (int, int, int, error)
• func RegisterPlatform(name string, factory PlatformFactory)
• type BackupInfo
  • func GetBackupInfoOf(f string) (*BackupInfo, error)
  • func ReadBackupInfo(zr *zip.Reader) (*BackupInfo, error)
• type Config
  • func (c *Config) AbsBaseDir() string
  • func (c *Config) CID() int
  • func (c *Config) GetChannel() string
  • func (c *Config) NetID() int
  • func (c *Config) ResolveAbsolute(targetPath string) string
  • func (c *Config) ResolveRelative(targetPath string) string
  • func (c *Config) Save() error
• type PlatformFactory
• type RevertHandler
• type Revertible
  • func (h *Revertible) Append(handler RevertHandler) int
  • func (h *Revertible) Delete(p string) error
  • func (h *Revertible) Rename(p1, p2 string) error
  • func (h *Revertible) RevertOrCommit(revert bool)
  • func (h *Revertible) RevertOrCommitOne(index int, revert bool) bool
• type State
  • func (s State) String() string
• type TaskFactory

Constants

const (
	DefaultDBDir       = "db"
	DefaultWALDir      = "wal"
	DefaultContractDir = "contract"
	DefaultCacheDir    = "cache"
	DefaultTmpDBDir    = "tmp"
)

const (
	ConfigDefaultNormalTxPoolSize = 5000
	ConfigDefaultPatchTxPoolSize  = 1000
	ConfigDefaultMaxBlockTxBytes  = 1024 * 1024
	ConfigDefaultTxTimeout        = 5000 * time.Millisecond
	ConfigDefaultChildrenLimit    = 10
	ConfigDefaultNephewLimit      = 10
)

const (
	NodeCacheNone    = "none"
	NodeCacheSmall   = "small"
	NodeCacheLarge   = "large"
	NodeCacheDefault = NodeCacheNone
)

const (
	ConfigDefaultTransactions     = 1000
	ConfigDefaultCommitTimeout    = time.Second
	ConfigDefaultBlockInterval    = time.Second
	ConfigDefaultMinCommitTimeout = 200 * time.Millisecond
)

const (
	ImportICONTask = "import_icon"
	ImportICONName = "ImportICON"
)

const BackupSuffix = ".bk"

const (
	TempSuffix = ".tmp"
)

const TemporalBackupFile = ".backup"

Functions

func GetChannel

func GetChannel(channel string, nid int) string

func IsNodeCacheOption

func IsNodeCacheOption(s string) bool

func NewChain

func NewChain(
	wallet module.Wallet,
	transport module.NetworkTransport,
	srv *server.Manager,
	pm eeproxy.Manager,
	logger log.Logger,
	cfg *Config,
) *singleChain

func NewPlatform

func NewPlatform(name string, base string, cid int) (base.Platform, error)

func NewRegulator

func NewRegulator(logger log.Logger) *regulator

func ParseNodeCacheOption

func ParseNodeCacheOption(s string) (int, int, int, error)

func RegisterPlatform

func RegisterPlatform(name string, factory PlatformFactory)

Types

type BackupInfo

type BackupInfo struct {
	NID     common.HexInt32 `json:"nid"`
	CID     common.HexInt32 `json:"cid"`
	Channel string          `json:"channel"`
	Height  int64           `json:"height"`
	Codec   string          `json:"codec"`
}

func GetBackupInfoOf

func GetBackupInfoOf(f string) (*BackupInfo, error)

func ReadBackupInfo

func ReadBackupInfo(zr *zip.Reader) (*BackupInfo, error)

type Config

type Config struct {
	// fixed
	NID    int    `json:"nid"`
	DBType string `json:"db_type"`

	Platform string `json:"platform,omitempty"`

	// static
	SeedAddr         string `json:"seed_addr"`
	Role             uint   `json:"role"`
	ConcurrencyLevel int    `json:"concurrency_level,omitempty"`
	NormalTxPoolSize int    `json:"normal_tx_pool,omitempty"`
	PatchTxPoolSize  int    `json:"patch_tx_pool,omitempty"`
	MaxBlockTxBytes  int    `json:"max_block_tx_bytes,omitempty"`
	NodeCache        string `json:"node_cache,omitempty"`
	AutoStart        bool   `json:"auto_start,omitempty"`
	ChildrenLimit    *int   `json:"children_limit,omitempty"`
	NephewsLimit     *int   `json:"nephews_limit,omitempty"`
	ValidateTxOnSend bool   `json:"validate_tx_on_send,omitempty"`

	// runtime
	Channel        string `json:"channel"`
	SecureSuites   string `json:"secureSuites"`
	SecureAeads    string `json:"secureAeads"`
	DefWaitTimeout int64  `json:"waitTimeout"`
	MaxWaitTimeout int64  `json:"maxTimeout"`
	TxTimeout      int64  `json:"txTimeout"`

	GenesisStorage module.GenesisStorage `json:"-"`
	Genesis        json.RawMessage       `json:"genesis"`

	BaseDir  string `json:"chain_dir"`
	FilePath string `json:"-"` // absolute path

	NIDForP2P bool `json:"-"`
}

func (*Config) AbsBaseDir

func (c *Config) AbsBaseDir() string

func (*Config) CID

func (c *Config) CID() int

func (*Config) GetChannel

func (c *Config) GetChannel() string

func (*Config) NetID

func (c *Config) NetID() int

func (*Config) ResolveAbsolute

func (c *Config) ResolveAbsolute(targetPath string) string

func (*Config) ResolveRelative

func (c *Config) ResolveRelative(targetPath string) string

func (*Config) Save

func (c *Config) Save() error

Save store configuration to c.FilePath

type PlatformFactory

type PlatformFactory func(base string, cid int) (base.Platform, error)

type RevertHandler

type RevertHandler func(revert bool)

type Revertible

type Revertible []RevertHandler

func (*Revertible) Append

func (h *Revertible) Append(handler RevertHandler) int

func (*Revertible) Delete

func (h *Revertible) Delete(p string) error

func (*Revertible) Rename

func (h *Revertible) Rename(p1, p2 string) error

func (*Revertible) RevertOrCommit

func (h *Revertible) RevertOrCommit(revert bool)

func (*Revertible) RevertOrCommitOne

func (h *Revertible) RevertOrCommitOne(index int, revert bool) bool

type State

type State int

const (
	Created State = iota
	Initializing
	InitializeFailed
	Starting
	Started
	Stopping
	Failed
	Finished
	Stopped
	Terminating
	Terminated
)

func (State) String

func (s State) String() string

type TaskFactory

type TaskFactory func(c *singleChain, params json.RawMessage) (chainTask, error)