transport

Documentation

Index

• Constants
• func AuthMethod(organization string, key string) (config.AuthMethod, error)
• type Sink
  • func NewSink(mgr *pm.PM, c SinkConfig) (*Sink, error)
  • func (sink *Sink) DB() *ledis.DB
  • 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
  • func (c *SinkConfig) Local() string

Constants

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

const (
	ReturnExpire = 300
)

Functions

func AuthMethod

func AuthMethod(organization string, key string) (config.AuthMethod, error)

Types

type Sink

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

func NewSink

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

func (*Sink) DB

func (sink *Sink) DB() *ledis.DB

func (*Sink) Flag

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

func (*Sink) Forward

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

func (*Sink) Result

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

func (*Sink) Start

func (sink *Sink) Start()

type SinkConfig

type SinkConfig struct {
	Port int
}

func (*SinkConfig) Local

func (c *SinkConfig) Local() string