router

Documentation

Index

• type InterchainRouter
  • func New(logger logrus.FieldLogger, repo *repo.Repo, ledger ledger.Ledger, ...) (*InterchainRouter, error)
  • func (router *InterchainRouter) AddPier(key string) (chan *pb.MerkleWrapper, error)
  • func (router *InterchainRouter) GetMerkleWrapper(pid string, begin, end uint64, ch chan<- *pb.MerkleWrapper) error
  • func (router *InterchainRouter) PutBlock(block *pb.Block)
  • func (router *InterchainRouter) RemovePier(key string)
  • func (router *InterchainRouter) Start() error
  • func (router *InterchainRouter) Stop() error
• type Router

Types

type InterchainRouter

type InterchainRouter struct {
	// contains filtered or unexported fields
}

func New

func New(logger logrus.FieldLogger, repo *repo.Repo, ledger ledger.Ledger, peerMgr peermgr.PeerManager, quorum uint64) (*InterchainRouter, error)

func (*InterchainRouter) AddPier

func (router *InterchainRouter) AddPier(key string) (chan *pb.MerkleWrapper, error)

func (*InterchainRouter) GetMerkleWrapper

func (router *InterchainRouter) GetMerkleWrapper(pid string, begin, end uint64, ch chan<- *pb.MerkleWrapper) error

func (*InterchainRouter) PutBlock

func (router *InterchainRouter) PutBlock(block *pb.Block)

func (*InterchainRouter) RemovePier

func (router *InterchainRouter) RemovePier(key string)

func (*InterchainRouter) Start

func (router *InterchainRouter) Start() error

func (*InterchainRouter) Stop

func (router *InterchainRouter) Stop() error

type Router

type Router interface {
	// Start starts the router module
	Start() error

	// Stop
	Stop() error

	// PutBlock
	PutBlock(*pb.Block)

	// AddPier
	AddPier(id string) (chan *pb.MerkleWrapper, error)

	// RemovePier
	RemovePier(id string)

	// GetMerkleWrapper
	GetMerkleWrapper(pid string, begin, end uint64, ch chan<- *pb.MerkleWrapper) error
}