qeclients

Documentation

Index

• Constants
• Variables
• type AmqpQEClientBuilderCommon
  • func (a *AmqpQEClientBuilderCommon) CustomImage(image string) *AmqpQEClientBuilderCommon
  • func (a *AmqpQEClientBuilderCommon) Messages(count int) *AmqpQEClientBuilderCommon
  • func (a *AmqpQEClientBuilderCommon) WithCustomCommand(command string) *AmqpQEClientBuilderCommon
• type AmqpQEClientCommon
  • func (a *AmqpQEClientCommon) Result() amqp.ResultData
• type AmqpQEClientImpl
• type AmqpQEClientImplInfo
• type AmqpQEReceiverBuilder
  • func NewReceiverBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQEReceiverBuilder
  • func (a *AmqpQEReceiverBuilder) Build() (*AmqpQEClientCommon, error)
  • func (a *AmqpQEReceiverBuilder) Timeout(timeout int) *AmqpQEReceiverBuilder
  • func (a *AmqpQEReceiverBuilder) WithCount(count int) *AmqpQEReceiverBuilder
• type AmqpQESenderBuilder
  • func NewSenderBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQESenderBuilder
  • func (a *AmqpQESenderBuilder) Build() (*AmqpQEClientCommon, error)
  • func (a *AmqpQESenderBuilder) Content(content string) *AmqpQESenderBuilder
  • func (a *AmqpQESenderBuilder) Count(count int) *AmqpQESenderBuilder
  • func (a *AmqpQESenderBuilder) MessageContentFromFile(configMapName string, filenameKey string) *AmqpQESenderBuilder
  • func (a *AmqpQESenderBuilder) Timeout(timeout int) *AmqpQESenderBuilder
• type MessageDict
  • func (m MessageDict) ToMessage() amqp.Message

Constants

const (
	Python AmqpQEClientImpl = iota
	Java
	NodeJS
	JavaIBMZ
	JavaPPC
	Timeout int = 60
)

const (
	MountPath = "/opt/messaging-files"
)

Variables

var (
	QEClientImageMap = map[AmqpQEClientImpl]AmqpQEClientImplInfo{
		Python: {
			Name:            "cli-proton-python",
			Image:           "docker.io/rhmessagingqe/cli-proton-python:latest",
			CommandSender:   "cli-proton-python-sender",
			CommandReceiver: "cli-proton-python-receiver",
		},
		Java: {
			Name:            "cli-qpid-java",
			Image:           "docker.io/rhmessagingqe/cli-java:latest",
			CommandSender:   "cli-qpid-sender",
			CommandReceiver: "cli-qpid-receiver",
		},
		JavaIBMZ: {
			Name:            "cli-qpid-java",
			Image:           "quay.io/lzhan/cli-java",
			CommandSender:   "cli-qpid-sender",
			CommandReceiver: "cli-qpid-receiver",
		},
		JavaPPC: {
			Name:            "cli-qpid-java",
			Image:           "quay.io/redmark/cli-java",
			CommandSender:   "cli-qpid-sender",
			CommandReceiver: "cli-qpid-receiver",
		},
		NodeJS: {
			Name:            "cli-rhea-nodejs",
			Image:           "docker.io/rhmessagingqe/cli-rhea:centos7",
			CommandSender:   "cli-rhea-sender",
			CommandReceiver: "cli-rhea-receiver",
		},
	}
)

Types

type AmqpQEClientBuilderCommon

type AmqpQEClientBuilderCommon struct {
	MessageCount int
	// contains filtered or unexported fields
}

Common builder properties and methods to be reused by sender/receiver builders

func (*AmqpQEClientBuilderCommon) CustomImage

func (a *AmqpQEClientBuilderCommon) CustomImage(image string) *AmqpQEClientBuilderCommon

func (*AmqpQEClientBuilderCommon) Messages

func (a *AmqpQEClientBuilderCommon) Messages(count int) *AmqpQEClientBuilderCommon

func (*AmqpQEClientBuilderCommon) WithCustomCommand

func (a *AmqpQEClientBuilderCommon) WithCustomCommand(command string) *AmqpQEClientBuilderCommon

type AmqpQEClientCommon

type AmqpQEClientCommon struct {
	amqp.AmqpClientCommon
	Implementation AmqpQEClientImpl
}

func (*AmqpQEClientCommon) Result

func (a *AmqpQEClientCommon) Result() amqp.ResultData

Result common implementation for QE Clients

type AmqpQEClientImpl

type AmqpQEClientImpl int

AmqpQEClientImpl specifies the available Amqp QE Clients

type AmqpQEClientImplInfo

type AmqpQEClientImplInfo struct {
	Name            string
	Image           string
	CommandSender   string
	CommandReceiver string
}

type AmqpQEReceiverBuilder

type AmqpQEReceiverBuilder struct {
	*AmqpQEClientBuilderCommon
	// contains filtered or unexported fields
}

func NewReceiverBuilder

func NewReceiverBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQEReceiverBuilder

func (*AmqpQEReceiverBuilder) Build

func (a *AmqpQEReceiverBuilder) Build() (*AmqpQEClientCommon, error)

func (*AmqpQEReceiverBuilder) Timeout

func (a *AmqpQEReceiverBuilder) Timeout(timeout int) *AmqpQEReceiverBuilder

func (*AmqpQEReceiverBuilder) WithCount

func (a *AmqpQEReceiverBuilder) WithCount(count int) *AmqpQEReceiverBuilder

type AmqpQESenderBuilder

type AmqpQESenderBuilder struct {
	*AmqpQEClientBuilderCommon

	ContentConfigMap          string
	MessageContent            string
	MessageContentFromFileKey string
	// contains filtered or unexported fields
}

func NewSenderBuilder

func NewSenderBuilder(name string, impl AmqpQEClientImpl, data framework.ContextData, url string) *AmqpQESenderBuilder

func (*AmqpQESenderBuilder) Build

func (a *AmqpQESenderBuilder) Build() (*AmqpQEClientCommon, error)

func (*AmqpQESenderBuilder) Content

func (a *AmqpQESenderBuilder) Content(content string) *AmqpQESenderBuilder

func (*AmqpQESenderBuilder) Count

func (a *AmqpQESenderBuilder) Count(count int) *AmqpQESenderBuilder

func (*AmqpQESenderBuilder) MessageContentFromFile

func (a *AmqpQESenderBuilder) MessageContentFromFile(configMapName string, filenameKey string) *AmqpQESenderBuilder

MessageContentFromFile uses the given config map name and just the filename reference, inside your configmap Data (key for the file)

func (*AmqpQESenderBuilder) Timeout

func (a *AmqpQESenderBuilder) Timeout(timeout int) *AmqpQESenderBuilder

type MessageDict

type MessageDict struct {
	AbsExpTime      int                    `json:"absolute_expiry_time"`
	Address         string                 `json:"address"`
	Annotations     string                 `json:"annotations"`
	Content         string                 `json:"content"`
	ContentEncoding string                 `json:"content_encoding"`
	ContentType     string                 `json:"content_type"`
	CorrelationId   string                 `json:"correlation_id"`
	CreationTime    float32                `json:"creation_time"`
	DeliveryCount   int                    `json:"delivery_count"`
	Durable         bool                   `json:"durable"`
	Expiration      int                    `json:"expiration"`
	FirstAcquirer   bool                   `json:"first_acquirer"`
	GroupId         string                 `json:"group_id"`
	GroupSequence   int                    `json:"group_sequence"`
	RouterLink      int                    `json:"routerLink"`
	Id              string                 `json:"id"`
	Inferred        bool                   `json:"inferred"`
	Instructions    string                 `json:"instructions"`
	Priority        int                    `json:"priority"`
	Properties      map[string]interface{} `json:"properties"`
	ReplyTo         string                 `json:"reply_to"`
	ReplyToGroupId  string                 `json:"reply_to_group_id"`
	Subject         string                 `json:"subject"`
	Ttl             int                    `json:"ttl"`
	UserId          string                 `json:"user_id"`
}

MessageDict represents a message logged by cli-proton-python as a dictionary

func (MessageDict) ToMessage

func (m MessageDict) ToMessage() amqp.Message