service

package
v0.13.0-beta Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 18, 2018 License: MIT Imports: 30 Imported by: 0

Documentation

Index

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, 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

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL