mail

package

v0.0.0-...-d0dabfa Latest Latest Go to latest Published: Dec 30, 2020 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MailService struct {
	Inbox chan *pb.Envelope
	// contains filtered or unexported fields
}

func NewMailService(
	ctx context.Context,
	account *keypair.Full,
	node func() *core.IpfsNode,
) *MailService

NewMailService returns a new mail service

func (h *MailService) Handle(env *pb.Envelope, pid peer.ID) (*pb.Envelope, error)

Handle is called by the underlying service handler method

func (h *MailService) HandleStream(_ *pb.Envelope, _ peer.ID) (chan *pb.Envelope, chan error, chan interface{})

HandleStream is called by the underlying service handler method

func (h *MailService) Ping(pid peer.ID) (service.PeerStatus, error)

Ping pings another peer

func (h *MailService) Protocol() protocol.ID

Protocol returns the handler protocol

func (h *MailService) SendMessage(ctx context.Context, peerID string, env *pb.Envelope) error

SendMessage sends a message to a peer.

func (h *MailService) Start()

Start begins online services