channels

Documentation

Index

• Variables
• type BrokerPublishChannel
  • func NewBrokerPublishChannel() BrokerPublishChannel
  • func (ch BrokerPublishChannel) Stop()
• type BrokerPublishPayload
• type BrokerSubscribeChannel
  • func NewBrokerSubscribeChannel() BrokerSubscribeChannel
  • func (ch BrokerSubscribeChannel) Stop()
• type GenericChannel
• type MeshSyncChannel
  • func NewMeshSyncChannel() MeshSyncChannel
  • func (ch MeshSyncChannel) Stop()

Variables

var (
	BrokerPublish   = "broker-publish"
	BrokerSubscribe = "broker-subscribe"
)

var (
	MeshSync = "meshsync"
)

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()