direct_adapter

Documentation

Index

• func NewGoPool(size int) *pool
• type DirectAdapter
  • func New(peerMgr peermgr.PeerManager, appchainAdapt adapt.Adapt, ...) (*DirectAdapter, error)
  • func (d *DirectAdapter) GetServiceIDList() ([]string, error)
  • func (d *DirectAdapter) ID() string
  • func (d *DirectAdapter) MonitorIBTP() chan *pb.IBTP
  • func (d *DirectAdapter) MonitorUpdatedMeta() chan *[]byte
  • func (d *DirectAdapter) Name() string
  • func (d *DirectAdapter) QueryIBTP(id string, isReq bool) (*pb.IBTP, error)
  • func (d *DirectAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)
  • func (d *DirectAdapter) SendIBTP(ibtp *pb.IBTP) error
  • func (d *DirectAdapter) SendUpdatedMeta(byte []byte) error
  • func (d *DirectAdapter) Start() error
  • func (d *DirectAdapter) Stop() error
• type MyTree
  • func (m *MyTree) Less(item btree.Item) bool
• type Pool
  • func NewPool() *Pool

Functions

func NewGoPool

func NewGoPool(size int) *pool

Types

type DirectAdapter

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

func New

func New(peerMgr peermgr.PeerManager, appchainAdapt adapt.Adapt, logger logrus.FieldLogger) (*DirectAdapter, error)

func (*DirectAdapter) GetServiceIDList

func (d *DirectAdapter) GetServiceIDList() ([]string, error)

func (*DirectAdapter) ID

func (d *DirectAdapter) ID() string

func (*DirectAdapter) MonitorIBTP

func (d *DirectAdapter) MonitorIBTP() chan *pb.IBTP

func (*DirectAdapter) MonitorUpdatedMeta

func (d *DirectAdapter) MonitorUpdatedMeta() chan *[]byte

func (*DirectAdapter) Name

func (d *DirectAdapter) Name() string

func (*DirectAdapter) QueryIBTP

func (d *DirectAdapter) QueryIBTP(id string, isReq bool) (*pb.IBTP, error)

QueryIBTP query ibtp from another pier

func (*DirectAdapter) QueryInterchain

func (d *DirectAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)

func (*DirectAdapter) SendIBTP

func (d *DirectAdapter) SendIBTP(ibtp *pb.IBTP) error

SendIBTP send ibtp to another pier

func (*DirectAdapter) SendUpdatedMeta

func (d *DirectAdapter) SendUpdatedMeta(byte []byte) error

func (*DirectAdapter) Start

func (d *DirectAdapter) Start() error

func (*DirectAdapter) Stop

func (d *DirectAdapter) Stop() error

type MyTree

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

func (*MyTree) Less

func (m *MyTree) Less(item btree.Item) bool

type Pool

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

func NewPool

func NewPool() *Pool