Documentation ¶
Index ¶
- Variables
- type 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrReadTimeout = fmt.Errorf("timed out reading response")
View Source
var ProtocolOpenBazaar protocol.ID = "/openbazaar/app/1.0.0"
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, ctx commands.Context, datastore repo.Datastore) *OpenBazaarService
func (*OpenBazaarService) DisconnectFromPeer ¶ added in v0.9.3
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 ¶
Click to show internal directories.
Click to hide internal directories.