service

Documentation

Index

• Variables
• type OpenBazaarService
  • func SetupOpenBazaarService(node *core.IpfsNode, broadcast chan []byte, ctx commands.Context, ...) *OpenBazaarService
  • func (service *OpenBazaarService) HandleNewStream(s inet.Stream)
  • func (service *OpenBazaarService) HandlerForMsgType(t pb.Message_MessageType) serviceHandler
  • 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)

Variables

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

Types

type OpenBazaarService

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

var OBService *OpenBazaarService

func SetupOpenBazaarService

func SetupOpenBazaarService(node *core.IpfsNode, broadcast chan []byte, ctx commands.Context, datastore repo.Datastore) *OpenBazaarService

func (*OpenBazaarService) HandleNewStream

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

func (*OpenBazaarService) HandlerForMsgType

func (service *OpenBazaarService) HandlerForMsgType(t pb.Message_MessageType) serviceHandler

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)