channels

Documentation

Index

• Constants
• Variables
• func NewChannelPool() map[string]GenericChannel
• type BrokerPublishChannel
  • func NewBrokerPublishChannel() BrokerPublishChannel
  • func (ch BrokerPublishChannel) Stop()
• type BrokerPublishPayload
• type BrokerSubscribeChannel
  • func NewBrokerSubscribeChannel() BrokerSubscribeChannel
  • func (ch BrokerSubscribeChannel) Stop()
• type GenericChannel
• type OSChannel
  • func NewOSChannel() OSChannel
  • func (ch OSChannel) Stop()
• type ReSyncChannel
  • func NewReSyncChannel() ReSyncChannel
  • func (ch ReSyncChannel) ReSyncInformer()
  • func (ch ReSyncChannel) Stop()
• type StopChannel
  • func NewStopChannel() StopChannel
  • func (ch StopChannel) Stop()
• type StructChannel
  • func NewStructChannel() StructChannel
  • func (ch StructChannel) Stop()

Constants

const (
	Struct = "struct"
)

Variables

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

var (
	OS     = "os"
	Stop   = "stop"
	ReSync = "resync"
)

Functions

func NewChannelPool

func NewChannelPool() map[string]GenericChannel

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 OSChannel

type OSChannel chan os.Signal

func NewOSChannel

func NewOSChannel() OSChannel

func (OSChannel) Stop

func (ch OSChannel) Stop()

type ReSyncChannel

type ReSyncChannel chan struct{}

func NewReSyncChannel

func NewReSyncChannel() ReSyncChannel

func (ReSyncChannel) ReSyncInformer

func (ch ReSyncChannel) ReSyncInformer()

func (ReSyncChannel) Stop

func (ch ReSyncChannel) Stop()

type StopChannel

type StopChannel chan struct{}

func NewStopChannel

func NewStopChannel() StopChannel

func (StopChannel) Stop

func (ch StopChannel) Stop()

type StructChannel

type StructChannel chan struct{}

func NewStructChannel

func NewStructChannel() StructChannel

func (StructChannel) Stop

func (ch StructChannel) Stop()