service

Documentation

Index

• Variables
• type OpenBazaarService
  • func New(node *core.OpenBazaarNode, datastore repo.Datastore) *OpenBazaarService
  • func (service *OpenBazaarService) DisconnectFromPeer(p peer.ID)
  • 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) SendProcessingError(peerID, orderID string, attemptedMessage pb.Message_MessageType, ...) error
  • func (service *OpenBazaarService) SendRequest(ctx context.Context, p peer.ID, pmes *pb.Message) (*pb.Message, error)
  • func (service *OpenBazaarService) WaitForReady()

Variables

var (
	// ErrEmptyPayload occurs when an inbound message is provided without the contents
	ErrEmptyPayload = errors.New("message payload is empty")
)

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

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

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)

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) SendProcessingError

func (service *OpenBazaarService) SendProcessingError(peerID, orderID string, attemptedMessage pb.Message_MessageType, latestContract *pb.RicardianContract) error

SendProcessingError produces a ORDER_PROCESSING_FAILURE error message to be sent to peerID regarding orderID. This message should cause the peerID to reproduce the missing messages omitted in latestContract up-to-and-including the last attemptedMessage

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()