Versions in this module Expand all Collapse all v0 v0.2.7 Jul 17, 2021 v0.2.6 Jul 17, 2021 v0.2.5 Apr 9, 2021 Changes in this version + const Poll + const TimeoutDefaultSecs + const TimeoutInterruptSecs + func ClientStatusIn(status ClientStatus, statuses ...ClientStatus) bool + type AmqpClientCommon struct + Context framework.ContextData + FinalResult *ResultData + Interrupted bool + Mutex sync.Mutex + Name string + Params []Param + Pod *v1.Pod + TimedOut bool + Timeout int + Url string + func (a *AmqpClientCommon) Deploy() error + func (a *AmqpClientCommon) Interrupt() + func (a *AmqpClientCommon) Running() bool + func (a *AmqpClientCommon) Status() ClientStatus + func (a *AmqpClientCommon) Wait() ClientStatus + func (a *AmqpClientCommon) WaitFor(secs int) ClientStatus + func (a *AmqpClientCommon) WaitForStatus(secs int, statuses ...ClientStatus) ClientStatus + type Client interface + Deploy func() error + Interrupt func() + Result func() ResultData + Running func() bool + Status func() ClientStatus + Wait func() ClientStatus + type ClientStatus int + const Error + const Interrupted + const Running + const Starting + const Success + const Timeout + const Unknown + type Message struct + Address string + Content string + ContentSHA1 string + CorrelationId string + Expiration int + Id string + Priority int + ReplyTo string + Ttl int + UserId string + type Param struct + Name string + Value string + type ResultData struct + Accepted int + Delivered int + Messages []Message + Modified int + Rejected int + Released int