network

package

v0.2.1 Latest Latest Go to latest Published: Dec 10, 2019 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jcmurray/monitor

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Networker
- func NewNetworker(workers *worker.Workers, id int, label string) *Networker

Constants ¶

View Source

const (
	SubscriptionTypeConection = "connection"
	Connected                 = "connected"
	Disconnected              = "disconnected"
)

SubscriptionTypeConection for use by other go routines

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Networker ¶

type Networker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Networker network worker

func NewNetworker ¶

func NewNetworker(workers *worker.Workers, id int, label string) *Networker

NewNetworker create a new Networker

func (*Networker) Command ¶

func (w *Networker) Command(c int)

Command sent to this worker

func (*Networker) Data ¶

func (w *Networker) Data(d []byte)

Data sent to this worker

func (*Networker) Disconnect ¶

func (w *Networker) Disconnect()

Disconnect the websocket

func (*Networker) ID ¶ added in v0.2.0

func (w *Networker) ID() int

ID return label of worker

func (*Networker) Label ¶ added in v0.2.0

func (w *Networker) Label() string

Label return label of worker

func (*Networker) Run ¶

func (w *Networker) Run(wg *sync.WaitGroup, term *chan int)

Run is main finction of this worker

func (w *Networker) Subscribe(id int, sType string, label string) *worker.Subscription

Subscribe to this worker

func (*Networker) Subscriptions ¶ added in v0.2.0

func (w *Networker) Subscriptions() []*worker.Subscription

Subscriptions return a copy of current scubscriptions

func (*Networker) Terminate ¶

func (w *Networker) Terminate()

Terminate the worker

func (*Networker) UnSubscribe ¶

func (w *Networker) UnSubscribe(id int, sType string)

UnSubscribe from this worker

Source Files ¶

View all Source files

networker.go

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