service

Documentation

Index

• Variables
• type TextileService
  • func NewService(node *core.IpfsNode, datastore repo.Datastore, ...) *TextileService
  • func (s *TextileService) DisconnectFromPeer(p peer.ID) error
  • func (s *TextileService) HandleNewStream(stream inet.Stream)
  • func (s *TextileService) HandlerForMsgType(t pb.Message_Type) func(peer.ID, *pb.Envelope, interface{}) (*pb.Envelope, error)
  • func (s *TextileService) SendMessage(ctx context.Context, p peer.ID, pmes *pb.Envelope) error
  • func (s *TextileService) SendRequest(ctx context.Context, p peer.ID, pmes *pb.Envelope) (*pb.Envelope, error)

Variables

var ErrReadTimeout = fmt.Errorf("timed out reading response")

var ReadMessageTimeout = time.Minute * 5

var TextileProtocol protocol.ID = "/textile/app/1.0.0"

Types

type TextileService

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

func NewService

func NewService(
	node *core.IpfsNode,
	datastore repo.Datastore,
	getThread func(string) (*int, *thread.Thread),
	notify func(notificaiton *repo.Notification) error,
) *TextileService

func (*TextileService) DisconnectFromPeer

func (s *TextileService) DisconnectFromPeer(p peer.ID) error

func (*TextileService) HandleNewStream

func (s *TextileService) HandleNewStream(stream inet.Stream)

func (*TextileService) HandlerForMsgType

func (s *TextileService) HandlerForMsgType(t pb.Message_Type) func(peer.ID, *pb.Envelope, interface{}) (*pb.Envelope, error)

func (*TextileService) SendMessage

func (s *TextileService) SendMessage(ctx context.Context, p peer.ID, pmes *pb.Envelope) error

func (*TextileService) SendRequest

func (s *TextileService) SendRequest(ctx context.Context, p peer.ID, pmes *pb.Envelope) (*pb.Envelope, error)