Documentation ¶
Index ¶
Constants ¶
View Source
const SCRIPT_STRING = `` /* 2085-byte string literal not displayed */
Variables ¶
View Source
var ( Version string Rev string )
View Source
var ApplicationJsonRegex = regexp.MustCompile(`^application/json`)
Functions ¶
func ProgVersion ¶
func ProgVersion() string
Types ¶
type BundleExecer ¶
type BundleExecer struct { Configuration sync.Mutex }
func NewBundleExecer ¶
func NewBundleExecer(config Configuration) *BundleExecer
func (*BundleExecer) ProcessInstructions ¶
func (me *BundleExecer) ProcessInstructions(instructions *Instructions) error
type Configuration ¶
type Configuration struct { AmqpQos int AuthToken string Binding string ConnectionString string DisplayRev bool DisplayVersion bool Exchange string ExitImmediately bool GemDir string GibHost string Logger gsmlog.GsmLogger Queue string ScriptLoc string }
func NewConfigurationFromFlags ¶
func NewConfigurationFromFlags() *Configuration
type Consumer ¶
type Consumer struct { Configuration sync.Mutex // contains filtered or unexported fields }
func NewConsumer ¶
func NewConsumer(config Configuration) *Consumer
type Instructions ¶
type Orchestrator ¶
type Orchestrator struct {
Configuration
}
func NewOrchestrator ¶
func NewOrchestrator(config Configuration) *Orchestrator
func (*Orchestrator) Orchestrate ¶
func (me *Orchestrator) Orchestrate(delivery amqp.Delivery) (*Instructions, error)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.