channels

package
v0.6.59 Latest Latest
Warning

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

Go to latest
Published: Mar 2, 2023 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BrokerPublish   = "broker-publish"
	BrokerSubscribe = "broker-subscribe"
)
View Source
var (
	MeshSync = "meshsync"
)

Functions

This section is empty.

Types

type BrokerPublishChannel

type BrokerPublishChannel chan *BrokerPublishPayload

func NewBrokerPublishChannel

func NewBrokerPublishChannel() BrokerPublishChannel

func (BrokerPublishChannel) Stop

func (ch BrokerPublishChannel) Stop()

type BrokerPublishPayload

type BrokerPublishPayload struct {
	Subject string
	Data    *broker.Message
}

type BrokerSubscribeChannel

type BrokerSubscribeChannel chan *broker.Message

func NewBrokerSubscribeChannel

func NewBrokerSubscribeChannel() BrokerSubscribeChannel

func (BrokerSubscribeChannel) Stop

func (ch BrokerSubscribeChannel) Stop()

type GenericChannel

type GenericChannel interface {
	Stop()
}

type MeshSyncChannel

type MeshSyncChannel chan struct{}

func NewMeshSyncChannel

func NewMeshSyncChannel() MeshSyncChannel

func (MeshSyncChannel) Stop

func (ch MeshSyncChannel) Stop()

Jump to

Keyboard shortcuts

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