rabbitmq

Documentation

Index

• type CfgOptFunc
  • func ClusteringModeSetter(v string) CfgOptFunc
  • func DomainNameSetter(v string) CfgOptFunc
  • func EnabledPluginsSetter(v ...string) CfgOptFunc
  • func K8sPortSetter(v int) CfgOptFunc
  • func NamespaceSetter(v string) CfgOptFunc
  • func TargetServiceSetter(v string) CfgOptFunc
• type RabbitmqRecipient
  • func NewRabbitmqRecipient(options ...CfgOptFunc) (*RabbitmqRecipient, error)
  • func (recipe *RabbitmqRecipient) Generate(dir string) error
  • func (recipe *RabbitmqRecipient) Parse(assetName string) (*bytes.Buffer, error)

Types

type CfgOptFunc

type CfgOptFunc func(*RabbitmqRecipient) error

func ClusteringModeSetter

func ClusteringModeSetter(v string) CfgOptFunc

func DomainNameSetter

func DomainNameSetter(v string) CfgOptFunc

func EnabledPluginsSetter

func EnabledPluginsSetter(v ...string) CfgOptFunc

func K8sPortSetter

func K8sPortSetter(v int) CfgOptFunc

func NamespaceSetter

func NamespaceSetter(v string) CfgOptFunc

func TargetServiceSetter

func TargetServiceSetter(v string) CfgOptFunc

type RabbitmqRecipient

type RabbitmqRecipient struct {
	Namespace, TargetService                     string
	Plugins, Domain                              string
	K8sPort                                      int
	FirstNodeHost, SecondNodeHost, ThirdNodeHost string
	ThisNodeHost, ThisNodeName                   string
	// contains filtered or unexported fields
}

func NewRabbitmqRecipient

func NewRabbitmqRecipient(options ...CfgOptFunc) (*RabbitmqRecipient, error)

func (*RabbitmqRecipient) Generate

func (recipe *RabbitmqRecipient) Generate(dir string) error

func (*RabbitmqRecipient) Parse

func (recipe *RabbitmqRecipient) Parse(assetName string) (*bytes.Buffer, error)