Versions in this module Expand all Collapse all v0 v0.29.1 Mar 5, 2025 v0.29.0 Mar 3, 2025 Changes in this version + const BEANSTALKD_DATA_MSG_TYPE + const DefaultTube + const Type + type BeanstalkdTubeSet struct + Config TubesetConfig + Router endpointApi.Router + RuleConfig types.Config + 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 = BeanstalkdTubeSet + type RequestMessage struct + 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 struct + 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 struct + Server string + Timeout int64 + Tubesets []string
Go to main page