mq

Documentation

Index

• Constants
• type MqConfiguration
• type MqConnection
  • func NewMqConnection(logger *slog.Logger, cfgFilename string) (*MqConnection, error)
  • func (c *MqConnection) Close()
  • func (c *MqConnection) Queues() []collector.Queue
  • func (c *MqConnection) Timeout() time.Duration
• type MqQueue
  • func (q *MqQueue) Read() (collector.QueueMetrics, error)

Constants

const (
	YES = 1
	NO  = 0
)

Types

type MqConfiguration

type MqConfiguration struct {
	QueueManager  string `yaml:"queueManager"`
	User          string
	Password      string
	ConnName      string `yaml:"connName"`
	Channel       string
	SSLCipherSpec string `yaml:"sslCipherSpec"`
	KeyRepository string `yaml:"keyRepository"`
	Timeout       *time.Duration
	Queues        []string
}

type MqConnection

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

func NewMqConnection

func NewMqConnection(logger *slog.Logger, cfgFilename string) (*MqConnection, error)

func (*MqConnection) Close

func (c *MqConnection) Close()

func (*MqConnection) Queues

func (c *MqConnection) Queues() []collector.Queue

func (*MqConnection) Timeout

func (c *MqConnection) Timeout() time.Duration

type MqQueue

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

func (*MqQueue) Read

func (q *MqQueue) Read() (collector.QueueMetrics, error)