channel

Documentation

Index

• Constants
• type BindMap
• type ChannelType
  • func (ct ChannelType) String() string
  • func (ct *ChannelType) UnmarshalText(b []byte) error
• type Endpoint
• type Inbound
  • func (inbound *Inbound) ToFMQMap(port uint64) (pm controlcommands.PropertyMap)
  • func (c *Inbound) UnmarshalYAML(unmarshal func(interface{}) error) (err error)
• type Outbound
  • func (outbound *Outbound) ToFMQMap(bindMap BindMap) (pm controlcommands.PropertyMap)
  • func (outbound *Outbound) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

Constants

const (
	PUSH = ChannelType("push")
	PULL = ChannelType("pull")
	PUB  = ChannelType("pub")
	SUB  = ChannelType("sub")
)

Types

type BindMap

type BindMap map[string]Endpoint

type ChannelType

type ChannelType string

TODO: FairMQ has the following channel types: push/pull/pub/sub/spub/xsub/pair/req/rep/dealer/router Do we need to support them all?

func (ChannelType) String

func (ct ChannelType) String() string

func (*ChannelType) UnmarshalText

func (ct *ChannelType) UnmarshalText(b []byte) error

type Endpoint

type Endpoint struct {
	Host string
	Port uint64
}

type Inbound

type Inbound struct {
	// contains filtered or unexported fields
}

func (*Inbound) ToFMQMap

func (inbound *Inbound) ToFMQMap(port uint64) (pm controlcommands.PropertyMap)

func (*Inbound) UnmarshalYAML

func (c *Inbound) UnmarshalYAML(unmarshal func(interface{}) error) (err error)

type Outbound

type Outbound struct {
	Target string `json:"target" yaml:"target"`
	// contains filtered or unexported fields
}

func (*Outbound) ToFMQMap

func (outbound *Outbound) ToFMQMap(bindMap BindMap) (pm controlcommands.PropertyMap)

func (*Outbound) UnmarshalYAML

func (outbound *Outbound) UnmarshalYAML(unmarshal func(interface{}) error) (err error)