Documentation
¶
Index ¶
- Constants
- Variables
- func FromJson(json string, value interface{}) error
- func FromXml(xml string, value interface{}) error
- func Initialize()
- func LoadChannelFromConfigOrFail(value *messaging.ChannelConfig, path ...string)
- func LoadOptionsFromConfigOrFail(value interface{}, path ...string)
- func ToJson(value interface{}) (string, error)
- func ToXml(value interface{}) (string, error)
- type CompletionType
- type Message
- type SliceAddedEvent
- type SliceCompletedEvent
- type StdStream
- type TaskAddedEvent
- type TaskCancelledEvent
- type TaskCompletedEvent
Constants ¶
View Source
const ( Complete CompletionType = 0 Incomplete CompletionType = 1 IncompleteAndRequeue CompletionType = 2 StdInFileDescriptor = 0 StdOutFileDescriptor = 1 StdErrFileDescriptor = 2 )
Variables ¶
View Source
var Validator *schema.Validator
Functions ¶
func Initialize ¶
func Initialize()
func LoadChannelFromConfigOrFail ¶
func LoadChannelFromConfigOrFail(value *messaging.ChannelConfig, path ...string)
func LoadOptionsFromConfigOrFail ¶
func LoadOptionsFromConfigOrFail(value interface{}, path ...string)
Types ¶
type CompletionType ¶
type CompletionType int
type Message ¶
type Message interface {
SetComplete(completionType CompletionType)
}
type SliceAddedEvent ¶
type SliceAddedEvent struct { JobID string `xml:"JobId"` SliceNr int Args []string `xml:"Args>Arg,omitempty"` // contains filtered or unexported fields }
func DeserializeSliceAddedEvent ¶
func DeserializeSliceAddedEvent(d *amqp.Delivery) (*SliceAddedEvent, error)
func (SliceAddedEvent) SetComplete ¶
func (e SliceAddedEvent) SetComplete(completionType CompletionType)
type SliceCompletedEvent ¶
type TaskAddedEvent ¶
type TaskAddedEvent struct { JobID string `xml:"JobId"` File *url.URL SliceSize int FileHash string Args []string `xml:"Args>Arg,omitempty"` // contains filtered or unexported fields }
func DeserializeTaskAddedEvent ¶
func DeserializeTaskAddedEvent(d *amqp.Delivery) (*TaskAddedEvent, error)
func (TaskAddedEvent) Priority ¶
func (e TaskAddedEvent) Priority() int
func (TaskAddedEvent) SetComplete ¶
func (e TaskAddedEvent) SetComplete(completionType CompletionType)
type TaskCancelledEvent ¶
type TaskCancelledEvent struct { JobID string `xml:"JobId"` // contains filtered or unexported fields }
func DeserializeTaskCancelledEvent ¶
func DeserializeTaskCancelledEvent(d *amqp.Delivery) (*TaskCancelledEvent, error)
func (TaskCancelledEvent) SetComplete ¶
func (e TaskCancelledEvent) SetComplete(completionType CompletionType)
type TaskCompletedEvent ¶
type TaskCompletedEvent struct {
JobID string `xml:"JobId"`
}
Click to show internal directories.
Click to hide internal directories.