accumulated

Documentation

Index

• func BuildGenesisDocs(network *NetworkInit, globals *core.GlobalValues, time time.Time, ...) (map[string]*tmtypes.GenesisDoc, error)
• func BuildNodesConfig(network *NetworkInit, mkcfg MakeConfigFunc) [][][2]*config.Config
• func ConfigureNodePorts(node *NodeInit, cfg *config.Config, offset config.PortOffset)
• func LoadOrGenerateTmPrivKey(privFileName string) (ed25519.PrivKey, error)
• func WriteNodeFiles(cfg *config.Config, privValKey, nodeKey []byte, genDoc *tmtypes.GenesisDoc) (err error)
• type BvnInit
  • func (v *BvnInit) MarshalJSON() ([]byte, error)
  • func (b *BvnInit) Peers(node *NodeInit, offset ...config.PortOffset) []string
  • func (v *BvnInit) UnmarshalJSON(data []byte) error
• type Daemon
  • func Load(dir string, newWriter func(*config.Config) (io.Writer, error)) (*Daemon, error)
  • func (d *Daemon) ConnectDirectly(e *Daemon) error
  • func (d *Daemon) DB_TESTONLY() *database.Database
  • func (d *Daemon) Jrpc_TESTONLY() *api.JrpcMethods
  • func (d *Daemon) Key() crypto.PrivKey
  • func (d *Daemon) LocalClient() (connections.ABCIClient, error)
  • func (d *Daemon) Node_TESTONLY() *node.Node
  • func (d *Daemon) Start() (err error)
  • func (d *Daemon) Stop() error
• type DevnetOptions
• type MakeConfigFunc
• type NetworkInit
  • func NewDevnet(opts DevnetOptions) *NetworkInit
  • func (v *NetworkInit) MarshalJSON() ([]byte, error)
  • func (n *NetworkInit) Peers(node *NodeInit, offset ...config.PortOffset) []string
  • func (v *NetworkInit) UnmarshalJSON(data []byte) error
• type NodeInit
  • func (n *NodeInit) Address(listen bool, scheme string, offset ...config.PortOffset) string
  • func (v *NodeInit) MarshalJSON() ([]byte, error)
  • func (n *NodeInit) Port(offset ...config.PortOffset) int
  • func (n *NodeInit) TmNodeAddress(offset ...config.PortOffset) string
  • func (v *NodeInit) UnmarshalJSON(data []byte) error

Functions

func BuildGenesisDocs

func BuildGenesisDocs(network *NetworkInit, globals *core.GlobalValues, time time.Time, logger log.Logger, factomAddresses func() (io.Reader, error)) (map[string]*tmtypes.GenesisDoc, error)

func BuildNodesConfig

func BuildNodesConfig(network *NetworkInit, mkcfg MakeConfigFunc) [][][2]*config.Config

func ConfigureNodePorts

func ConfigureNodePorts(node *NodeInit, cfg *config.Config, offset config.PortOffset)

func LoadOrGenerateTmPrivKey

func LoadOrGenerateTmPrivKey(privFileName string) (ed25519.PrivKey, error)

func WriteNodeFiles

func WriteNodeFiles(cfg *config.Config, privValKey, nodeKey []byte, genDoc *tmtypes.GenesisDoc) (err error)

Types

type BvnInit

type BvnInit struct {
	Id    string      `json:"id,omitempty" form:"id" query:"id" validate:"required"`
	Nodes []*NodeInit `json:"nodes,omitempty" form:"nodes" query:"nodes" validate:"required"`
}

func (*BvnInit) MarshalJSON

func (v *BvnInit) MarshalJSON() ([]byte, error)

func (*BvnInit) Peers

func (b *BvnInit) Peers(node *NodeInit, offset ...config.PortOffset) []string

func (*BvnInit) UnmarshalJSON

func (v *BvnInit) UnmarshalJSON(data []byte) error

type Daemon

type Daemon struct {
	Config *config.Config
	Logger tmlog.Logger

	// knobs for tests
	// IsTest   bool
	UseMemDB bool
	// contains filtered or unexported fields
}

func Load

func Load(dir string, newWriter func(*config.Config) (io.Writer, error)) (*Daemon, error)

func (*Daemon) ConnectDirectly

func (d *Daemon) ConnectDirectly(e *Daemon) error

func (*Daemon) DB_TESTONLY

func (d *Daemon) DB_TESTONLY() *database.Database

func (*Daemon) Jrpc_TESTONLY

func (d *Daemon) Jrpc_TESTONLY() *api.JrpcMethods

func (*Daemon) Key

func (d *Daemon) Key() crypto.PrivKey

func (*Daemon) LocalClient

func (d *Daemon) LocalClient() (connections.ABCIClient, error)

func (*Daemon) Node_TESTONLY

func (d *Daemon) Node_TESTONLY() *node.Node

func (*Daemon) Start

func (d *Daemon) Start() (err error)

func (*Daemon) Stop

func (d *Daemon) Stop() error

type DevnetOptions

type DevnetOptions struct {
	BvnCount       int
	ValidatorCount int
	FollowerCount  int
	BasePort       int
	GenerateKeys   func() (privVal, node []byte)
	HostName       func(bvnNum, nodeNum int) (host, listen string)
}

type MakeConfigFunc

type MakeConfigFunc func(networkName string, net config.NetworkType, node config.NodeType, netId string) *config.Config

type NetworkInit

type NetworkInit struct {
	Id   string     `json:"id,omitempty" form:"id" query:"id" validate:"required"`
	Bvns []*BvnInit `json:"bvns,omitempty" form:"bvns" query:"bvns" validate:"required"`
}

func NewDevnet

func NewDevnet(opts DevnetOptions) *NetworkInit

func (*NetworkInit) MarshalJSON

func (v *NetworkInit) MarshalJSON() ([]byte, error)

func (*NetworkInit) Peers

func (n *NetworkInit) Peers(node *NodeInit, offset ...config.PortOffset) []string

func (*NetworkInit) UnmarshalJSON

func (v *NetworkInit) UnmarshalJSON(data []byte) error

type NodeInit

type NodeInit struct {
	DnnType    config.NodeType `json:"dnnType,omitempty" form:"dnnType" query:"dnnType" validate:"required"`
	BvnnType   config.NodeType `json:"bvnnType,omitempty" form:"bvnnType" query:"bvnnType" validate:"required"`
	BasePort   uint64          `json:"basePort,omitempty" form:"basePort" query:"basePort" validate:"required"`
	HostName   string          `json:"hostName,omitempty" form:"hostName" query:"hostName" validate:"required"`
	ListenIP   string          `json:"listenIP,omitempty" form:"listenIP" query:"listenIP" validate:"required"`
	PrivValKey []byte          `json:"privValKey,omitempty" form:"privValKey" query:"privValKey" validate:"required"`
	NodeKey    []byte          `json:"nodeKey,omitempty" form:"nodeKey" query:"nodeKey" validate:"required"`
}

func (*NodeInit) Address

func (n *NodeInit) Address(listen bool, scheme string, offset ...config.PortOffset) string

func (*NodeInit) MarshalJSON

func (v *NodeInit) MarshalJSON() ([]byte, error)

func (*NodeInit) Port

func (n *NodeInit) Port(offset ...config.PortOffset) int

func (*NodeInit) TmNodeAddress

func (n *NodeInit) TmNodeAddress(offset ...config.PortOffset) string

func (*NodeInit) UnmarshalJSON

func (v *NodeInit) UnmarshalJSON(data []byte) error