hello

Documentation

Index

• Constants
• type HelloMessage
  • func (t *HelloMessage) MarshalCBOR(w io.Writer) error
  • func (t *HelloMessage) UnmarshalCBOR(r io.Reader) error
• type LatencyMessage
  • func (t *LatencyMessage) MarshalCBOR(w io.Writer) error
  • func (t *LatencyMessage) UnmarshalCBOR(r io.Reader) error
• type NewStreamFunc
• type Service
  • func NewHelloService(h host.Host, cs *store.ChainStore, syncer *chain.Syncer, ...) *Service
  • func (hs *Service) HandleStream(s inet.Stream)
  • func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error

Constants

const ProtocolID = "/epk/hello/1.0.0"

Types

type HelloMessage

type HelloMessage struct {
	HeaviestTipSet       []cid.Cid
	HeaviestTipSetHeight abi.ChainEpoch
	HeaviestTipSetWeight big.Int
	GenesisHash          cid.Cid
}

func (*HelloMessage) MarshalCBOR

func (t *HelloMessage) MarshalCBOR(w io.Writer) error

func (*HelloMessage) UnmarshalCBOR

func (t *HelloMessage) UnmarshalCBOR(r io.Reader) error

type LatencyMessage

type LatencyMessage struct {
	TArrival int64
	TSent    int64
}

func (*LatencyMessage) MarshalCBOR

func (t *LatencyMessage) MarshalCBOR(w io.Writer) error

func (*LatencyMessage) UnmarshalCBOR

func (t *LatencyMessage) UnmarshalCBOR(r io.Reader) error

type NewStreamFunc

type NewStreamFunc func(context.Context, peer.ID, ...protocol.ID) (inet.Stream, error)

type Service

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

func NewHelloService

func NewHelloService(h host.Host, cs *store.ChainStore, syncer *chain.Syncer, pmgr peermgr.MaybePeerMgr) *Service

func (*Service) HandleStream

func (hs *Service) HandleStream(s inet.Stream)

func (*Service) SayHello

func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error