transport

package

v1.1.0-alpha-2 Latest Latest Go to latest Published: May 14, 2017 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const (
	SinkRoute = core.Route("sink")
	SinkQueue = "core:default"
)

View Source

const (
	ReturnExpire = 300
)

This section is empty.

This section is empty.

type Sink struct {
	// contains filtered or unexported fields
}

func NewSink(mgr *pm.PM, config SinkConfig) (*Sink, error)

func (sink *Sink) Flag(id string) error

func (sink *Sink) Forward(result *core.JobResult) error

func (sink *Sink) Result(job string, timeout int) (*core.JobResult, error)

func (sink *Sink) Start()

type SinkConfig struct {
	URL      string `json:"url"`
	Password string `json:"password"`
}