service

Documentation

Index

• Variables
• type OpenBazaarService
  • func New(node *core.OpenBazaarNode, datastore repo.Datastore) *OpenBazaarService
  • func (service *OpenBazaarService) DisconnectFromPeer(p peer.ID) error
  • func (service *OpenBazaarService) HandleNewStream(s inet.Stream)
  • func (service *OpenBazaarService) HandlerForMsgType(t pb.Message_MessageType) func(peer.ID, *pb.Message, interface{}) (*pb.Message, error)
  • func (service *OpenBazaarService) SendMessage(ctx context.Context, p peer.ID, pmes *pb.Message) error
  • func (service *OpenBazaarService) SendRequest(ctx context.Context, p peer.ID, pmes *pb.Message) (*pb.Message, error)
  • func (service *OpenBazaarService) WaitForReady()

Variables

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

var ErrWriteTimeout = fmt.Errorf("timed out writing message")

var ProtocolOpenBazaar protocol.ID = "/openbazaar/app/1.0.0"

var ReadMessageTimeout = time.Minute * 5

Types

type OpenBazaarService

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

func New

func New(node *core.OpenBazaarNode, datastore repo.Datastore) *OpenBazaarService

func (*OpenBazaarService) DisconnectFromPeer

func (service *OpenBazaarService) DisconnectFromPeer(p peer.ID) error

func (*OpenBazaarService) HandleNewStream

func (service *OpenBazaarService) HandleNewStream(s inet.Stream)

func (*OpenBazaarService) HandlerForMsgType

func (service *OpenBazaarService) HandlerForMsgType(t pb.Message_MessageType) func(peer.ID, *pb.Message, interface{}) (*pb.Message, error)

func (*OpenBazaarService) SendMessage

func (service *OpenBazaarService) SendMessage(ctx context.Context, p peer.ID, pmes *pb.Message) error

func (*OpenBazaarService) SendRequest

func (service *OpenBazaarService) SendRequest(ctx context.Context, p peer.ID, pmes *pb.Message) (*pb.Message, error)

func (*OpenBazaarService) WaitForReady

func (service *OpenBazaarService) WaitForReady()