mangos

package
v0.0.0-...-f0caac9 Latest Latest
Warning

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

Go to latest
Published: Aug 1, 2018 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Overview

Dozer: Mangos protocol module

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DozerProtocolMangos

type DozerProtocolMangos struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Mangos protocol type.

func (*DozerProtocolMangos) Close

func (p *DozerProtocolMangos) Close() error

Close all underlying Mangos sockets.

func (*DozerProtocolMangos) Dial

func (p *DozerProtocolMangos) Dial(typ, host string, port int64) (uint64, error)

Bind/connect to a location.

func (*DozerProtocolMangos) Init

func (p *DozerProtocolMangos) Init(args ...string) error

Initialize the Mangos protocol.

func (*DozerProtocolMangos) RecvFrom

func (p *DozerProtocolMangos) RecvFrom(id uint64, dest string, messages chan []byte, quit chan bool) error

Receive messages from a Mangos socket until a quit signal fires.

func (*DozerProtocolMangos) SendTo

func (p *DozerProtocolMangos) SendTo(id uint64, dest string, messages chan []byte, quit chan bool) error

Send messages to a Mangos socket until a quit signal fires.

Jump to

Keyboard shortcuts

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