Documentation
¶
Index ¶
- Variables
- type 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()
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrEmptyPayload occurs when an inbound message is provided without the contents ErrEmptyPayload = errors.New("message payload is empty") )
View Source
var ErrReadTimeout = fmt.Errorf("timed out reading response")
View Source
var ErrWriteTimeout = fmt.Errorf("timed out writing message")
View Source
var ReadMessageTimeout = time.Minute * 5
Functions ¶
This section is empty.
Types ¶
type OpenBazaarService ¶
type OpenBazaarService struct {
// contains filtered or unexported fields
}
func New ¶ added in v0.2.4
func New(node *core.OpenBazaarNode, datastore repo.Datastore) *OpenBazaarService
func (*OpenBazaarService) DisconnectFromPeer ¶ added in v0.9.3
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 (*OpenBazaarService) SendProcessingError ¶ added in v0.13.5
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 (*OpenBazaarService) WaitForReady ¶ added in v0.13.1
func (service *OpenBazaarService) WaitForReady()
Source Files
Click to show internal directories.
Click to hide internal directories.