transport

package

v1.1.0-alpha-7 Latest Latest Go to latest Published: Aug 17, 2017 License: Apache-2.0 Imports: 24 Imported by: 0

Details

View Source

const (
	SinkQueue = "core:default"
	DBIndex   = 0
)

View Source

const (
	ReturnExpire = 300
)

This section is empty.

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

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

func NewSink(c SinkConfig) (*Sink, error)

func (sink *Sink) Del(keys ...[]byte) (int64, error)

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

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

func (sink *Sink) Get(key []byte) ([]byte, error)

func (sink *Sink) GetResult(job string, timeout int) (*pm.JobResult, error)

func (sink *Sink) LExpire(key []byte, duration int64) (int64, error)

func (sink *Sink) LTrim(key []byte, start, stop int64) error

func (sink *Sink) RPush(key []byte, args ...[]byte) (int64, error)

func (sink *Sink) Result(cmd *pm.Command, result *pm.JobResult)

ResultHandler implementation

func (sink *Sink) Set(key []byte, value []byte) error

func (sink *Sink) Start()

type SinkConfig struct {
	Port int
}

func (c *SinkConfig) Local() string