router

Documentation

Index

• type InterchainRouter
  • func New(logger logrus.FieldLogger, repo *repo.Repo, ledger *ledger.Ledger, ...) (*InterchainRouter, error)
  • func (router *InterchainRouter) AddPier(pierID string) (chan *pb.InterchainTxWrappers, error)
  • func (router *InterchainRouter) GetBlockHeader(begin, end uint64, ch chan<- *pb.BlockHeader) error
  • func (router *InterchainRouter) GetInterchainTxWrappers(appchainID string, begin, end uint64, ch chan<- *pb.InterchainTxWrappers) error
  • func (router *InterchainRouter) PutBlockAndMeta(block *pb.Block, meta *pb.InterchainMeta)
  • func (router *InterchainRouter) RemovePier(pierID 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(pierID string) (chan *pb.InterchainTxWrappers, error)

func (*InterchainRouter) GetBlockHeader

func (router *InterchainRouter) GetBlockHeader(begin, end uint64, ch chan<- *pb.BlockHeader) error

func (*InterchainRouter) GetInterchainTxWrappers

func (router *InterchainRouter) GetInterchainTxWrappers(appchainID string, begin, end uint64, ch chan<- *pb.InterchainTxWrappers) error

func (*InterchainRouter) PutBlockAndMeta

func (router *InterchainRouter) PutBlockAndMeta(block *pb.Block, meta *pb.InterchainMeta)

func (*InterchainRouter) RemovePier

func (router *InterchainRouter) RemovePier(pierID 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
	PutBlockAndMeta(*pb.Block, *pb.InterchainMeta)

	// AddPier
	AddPier(pierID string) (chan *pb.InterchainTxWrappers, error)

	// RemovePier
	RemovePier(pierID string)

	// GetBlockHeader
	GetBlockHeader(begin, end uint64, ch chan<- *pb.BlockHeader) error

	GetInterchainTxWrappers(appchainID string, begin, end uint64, ch chan<- *pb.InterchainTxWrappers) error
}