service

package

v0.12.0 Latest Latest Go to latest Published: May 9, 2018 License: MIT Imports: 34 Imported by: 40

Details

This section is empty.

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

This section is empty.

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

func New(node *core.OpenBazaarNode, ctx commands.Context, 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)