entities

package
v0.0.0-...-d0ca599 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 20, 2019 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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 FromJson

func FromJson(json string, value interface{}) error

func FromXml

func FromXml(xml string, value interface{}) error

func Initialize

func Initialize()

func LoadChannelFromConfigOrFail

func LoadChannelFromConfigOrFail(value *messaging.ChannelConfig, path ...string)

func LoadOptionsFromConfigOrFail

func LoadOptionsFromConfigOrFail(value interface{}, path ...string)

func ToJson

func ToJson(value interface{}) (string, error)

func ToXml

func ToXml(value interface{}) (string, error)

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 SliceCompletedEvent struct {
	JobID      string `xml:"JobId"`
	FileHash   string `xml:",omitempty"`
	SliceNr    int
	StdStreams []StdStream `xml:"StdStreams>L,omitempty"`
}

type StdStream

type StdStream struct {
	FD   int    `xml:"fd,attr"`
	Line string `xml:",innerxml"`
}

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL