broker

package

v0.0.0-...-23e819b Latest Latest Go to latest Published: Nov 3, 2015 License: MIT Imports: 15 Imported by: 0

Details

process

This section is empty.

This section is empty.

This section is empty.

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

func NewBroker(cfg *config.BrokerConfig) (*Broker, error)

func (b *Broker) AddRequestToRedis(tr interface{}) error

func (b *Broker) Close()

func (b *Broker) CreateRpcTaskRequest(c *echo.Context) error

func (b *Broker) CreateScriptTaskRequest(c *echo.Context) error

func (b *Broker) FailTaskCount(c *echo.Context) error

func (b *Broker) GetFailTaskCount(date string) (int64, error)

func (b *Broker) GetSuccessTaskCount(date string) (int64, error)

func (b *Broker) GetTaskResult(c *echo.Context) error

func (b *Broker) GetUndoTaskCount() (int64, error)

func (b *Broker) HandleFailTask() error

处理失败的任务

func (b *Broker) HandleRequest(request *task.TaskRequest) error

func (b *Broker) HandleTaskResult(uuid string) (*task.Reply, error)

func (b *Broker) RegisterMiddleware()

func (b *Broker) RegisterURL()

func (b *Broker) Run()

func (b *Broker) SetFailTaskCount(reqKey string) error

func (b *Broker) SuccessTaskCount(c *echo.Context) error

func (b *Broker) UndoTaskCount(c *echo.Context) error