beanstalkd

Documentation

Index

• Constants
• type BeanstalkdTubeSet
  • func (x *BeanstalkdTubeSet) AddRouter(router endpointApi.Router, params ...interface{}) (string, error)
  • func (x *BeanstalkdTubeSet) Close() error
  • func (x *BeanstalkdTubeSet) Destroy()
  • func (x *BeanstalkdTubeSet) Id() string
  • func (x *BeanstalkdTubeSet) Init(ruleConfig types.Config, configuration types.Configuration) error
  • func (x *BeanstalkdTubeSet) New() types.Node
  • func (x *BeanstalkdTubeSet) Printf(format string, v ...interface{})
  • func (x *BeanstalkdTubeSet) RemoveRouter(routerId string, params ...interface{}) error
  • func (x *BeanstalkdTubeSet) Start() error
  • func (x *BeanstalkdTubeSet) Type() string
• type Endpoint
• type RequestMessage
  • func (r *RequestMessage) Body() []byte
  • func (r *RequestMessage) From() string
  • func (r *RequestMessage) GetError() error
  • func (r *RequestMessage) GetMsg() *types.RuleMsg
  • func (r *RequestMessage) GetParam(key string) string
  • func (r *RequestMessage) Headers() textproto.MIMEHeader
  • func (r *RequestMessage) SetBody(body []byte)
  • func (r *RequestMessage) SetError(err error)
  • func (r *RequestMessage) SetMsg(msg *types.RuleMsg)
  • func (r *RequestMessage) SetStatusCode(statusCode int)
• type ResponseMessage
  • func (r *ResponseMessage) Body() []byte
  • func (r *ResponseMessage) From() string
  • func (r *ResponseMessage) GetError() error
  • func (r *ResponseMessage) GetMsg() *types.RuleMsg
  • func (r *ResponseMessage) GetParam(key string) string
  • func (r *ResponseMessage) Headers() textproto.MIMEHeader
  • func (r *ResponseMessage) SetBody(body []byte)
  • func (r *ResponseMessage) SetError(err error)
  • func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)
  • func (r *ResponseMessage) SetStatusCode(statusCode int)
• type TubesetConfig

Constants

const (
	Type                     = types.EndpointTypePrefix + "beanstalkdTubeset"
	BEANSTALKD_DATA_MSG_TYPE = "BEANSTALKD_DATA"
	DefaultTube              = "default"
)

Types

type BeanstalkdTubeSet

type BeanstalkdTubeSet struct {
	impl.BaseEndpoint
	base.SharedNode[*beanstalk.Conn]
	RuleConfig types.Config
	// beanstalk Tubeset 相关配置
	Config TubesetConfig
	// 路由实例
	Router endpointApi.Router
	// contains filtered or unexported fields
}

func (*BeanstalkdTubeSet) AddRouter

func (x *BeanstalkdTubeSet) AddRouter(router endpointApi.Router, params ...interface{}) (string, error)

AddRouter 添加路由

func (*BeanstalkdTubeSet) Close

func (x *BeanstalkdTubeSet) Close() error

func (*BeanstalkdTubeSet) Destroy

func (x *BeanstalkdTubeSet) Destroy()

Destroy 销毁

func (*BeanstalkdTubeSet) Id

func (x *BeanstalkdTubeSet) Id() string

Id 获取组件id

func (*BeanstalkdTubeSet) Init

func (x *BeanstalkdTubeSet) Init(ruleConfig types.Config, configuration types.Configuration) error

Init 初始化

func (*BeanstalkdTubeSet) New

func (x *BeanstalkdTubeSet) New() types.Node

New 创建组件实例

func (*BeanstalkdTubeSet) Printf

func (x *BeanstalkdTubeSet) Printf(format string, v ...interface{})

Printf 打印日志

func (*BeanstalkdTubeSet) RemoveRouter

func (x *BeanstalkdTubeSet) RemoveRouter(routerId string, params ...interface{}) error

RemoveRouter 移除路由

func (*BeanstalkdTubeSet) Start

func (x *BeanstalkdTubeSet) Start() error

Start 启动

func (*BeanstalkdTubeSet) Type

func (x *BeanstalkdTubeSet) Type() string

Type 组件类型

type Endpoint

type Endpoint = BeanstalkdTubeSet

Endpoint 别名

type RequestMessage

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

func (*RequestMessage) Body

func (r *RequestMessage) Body() []byte

func (*RequestMessage) From

func (r *RequestMessage) From() string

func (*RequestMessage) GetError

func (r *RequestMessage) GetError() error

GetError get error

func (*RequestMessage) GetMsg

func (r *RequestMessage) GetMsg() *types.RuleMsg

func (*RequestMessage) GetParam

func (r *RequestMessage) GetParam(key string) string

GetParam 不提供获取参数

func (*RequestMessage) Headers

func (r *RequestMessage) Headers() textproto.MIMEHeader

func (*RequestMessage) SetBody

func (r *RequestMessage) SetBody(body []byte)

func (*RequestMessage) SetError

func (r *RequestMessage) SetError(err error)

SetError set error

func (*RequestMessage) SetMsg

func (r *RequestMessage) SetMsg(msg *types.RuleMsg)

func (*RequestMessage) SetStatusCode

func (r *RequestMessage) SetStatusCode(statusCode int)

type ResponseMessage

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

func (*ResponseMessage) Body

func (r *ResponseMessage) Body() []byte

func (*ResponseMessage) From

func (r *ResponseMessage) From() string

func (*ResponseMessage) GetError

func (r *ResponseMessage) GetError() error

GetError get error

func (*ResponseMessage) GetMsg

func (r *ResponseMessage) GetMsg() *types.RuleMsg

func (*ResponseMessage) GetParam

func (r *ResponseMessage) GetParam(key string) string

GetParam 不提供获取参数

func (*ResponseMessage) Headers

func (r *ResponseMessage) Headers() textproto.MIMEHeader

func (*ResponseMessage) SetBody

func (r *ResponseMessage) SetBody(body []byte)

func (*ResponseMessage) SetError

func (r *ResponseMessage) SetError(err error)

SetError set error

func (*ResponseMessage) SetMsg

func (r *ResponseMessage) SetMsg(msg *types.RuleMsg)

func (*ResponseMessage) SetStatusCode

func (r *ResponseMessage) SetStatusCode(statusCode int)

type TubesetConfig

type TubesetConfig struct {
	// 服务器地址
	Server string
	// tube 列表
	Tubesets []string
	// 超时参数
	Timeout int64
}

beanstalk Tubeset 配置