com

package

v0.0.0-...-b99a58d Latest Latest Go to latest Published: May 10, 2017 License: AGPL-3.0 Imports: 9 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/pydio/pydio-booster

Links

Open Source Insights

Documentation ¶

Overview ¶

Package com controls the communication layer of the Pydio app

Copyright 2007-2016 Abstrium <contact (at) pydio.com>
This file is part of Pydio. *
Pydio is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version. *
Pydio is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details. *
You should have received a copy of the GNU Affero General Public License
along with Pydio. If not, see <http://www.gnu.org/licenses/>. *
The latest code can be found at <https://pydio.com/>.

Package com controls the communication layer of the Pydio app

Copyright 2007-2016 Abstrium <contact (at) pydio.com>
This file is part of Pydio. *
Pydio is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version. *
Pydio is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details. *
You should have received a copy of the GNU Affero General Public License
along with Pydio. If not, see <http://www.gnu.org/licenses/>. *
The latest code can be found at <https://pydio.com/>.

Package com controls the communication layer of the Pydio app

Copyright 2007-2016 Abstrium <contact (at) pydio.com>
This file is part of Pydio. *
Pydio is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version. *
Pydio is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details. *
You should have received a copy of the GNU Affero General Public License
along with Pydio. If not, see <http://www.gnu.org/licenses/>. *
The latest code can be found at <https://pydio.com/>.

Index ¶

func Close()
func GetNextAvailablePort(port int) int
func IsRunning() bool
func NewCom(conf *pydioconf.NsqConf) error
func NewProducer() error
func Publish(m Message) error
func StopProducer() error
func WaitForConsumers()
type Consumer
- func NewConsumer(topic string, channel string) (*Consumer, error)
type Message

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Close ¶

func Close()

Close the nsq

func GetNextAvailablePort ¶

func GetNextAvailablePort(port int) int

GetNextAvailablePort for the

func IsRunning ¶

func IsRunning() bool

IsRunning nsq ?

func NewCom ¶

func NewCom(conf *pydioconf.NsqConf) error

NewCom Consumer

func NewProducer ¶

func NewProducer() error

NewProducer that writes on the standard communication channel

func Publish ¶

func Publish(m Message) error

Publish a message to the standard communication channel

func StopProducer ¶

func StopProducer() error

StopProducer writing to the standard communication channel

func WaitForConsumers ¶

func WaitForConsumers()

WaitForConsumers to be closed before continuing

Types ¶

type Consumer ¶

type Consumer struct {
	URL       string
	Topic     string
	Channel   string
	Handlers  []func(message *nsq.Message) error
	Connected bool
	// contains filtered or unexported fields
}

Consumer of messages

func NewConsumer ¶

func NewConsumer(topic string, channel string) (*Consumer, error)

NewConsumer that will register a handler for different topic and channels

func (*Consumer) AddHandler ¶

func (c *Consumer) AddHandler(handler func(*nsq.Message) error)

AddHandler to the message consumer

func (*Consumer) Start ¶

func (c *Consumer) Start() error

Start the consumer main handler

func (*Consumer) Stop ¶

func (c *Consumer) Stop()

Stop consumer listening

type Message ¶

type Message struct {
	Topic   string
	Content []byte
}

Message standard structure for communication

Source Files ¶

View all Source files

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