redis

Documentation

Index

• Constants
• type Config
• type Endpoint
• type Redis
  • func (x *Redis) AddRouter(router endpointApi.Router, params ...interface{}) (string, error)
  • func (x *Redis) Close() error
  • func (x *Redis) Destroy()
  • func (x *Redis) Id() string
  • func (x *Redis) Init(ruleConfig types.Config, configuration types.Configuration) error
  • func (x *Redis) New() types.Node
  • func (x *Redis) Printf(format string, v ...interface{})
  • func (x *Redis) RemoveRouter(routerId string, params ...interface{}) error
  • func (x *Redis) Start() error
  • func (x *Redis) Type() string
• 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)

Constants

const (
	// KeyResponseTopic 响应主题metadataKey
	KeyResponseTopic = "responseTopic"
	// KeyResponseChannel 响应主题metadataKey
	KeyResponseChannel = "responseChannel"
)

const Type = types.EndpointTypePrefix + "redis"

Type 组件类型

Types

type Config

type Config struct {
	// Redis服务器地址
	Server string
	// Redis密码
	Password string
	// Redis数据库index
	Db int
}

type Endpoint

type Endpoint = Redis

Endpoint 别名

type Redis

type Redis struct {
	impl.BaseEndpoint
	base.SharedNode[*redis.Client]
	RuleConfig types.Config
	//Config 配置
	Config Config
	// contains filtered or unexported fields
}

Redis Redis接收端端点

func (*Redis) AddRouter

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

func (*Redis) Close

func (x *Redis) Close() error

func (*Redis) Destroy

func (x *Redis) Destroy()

Destroy 销毁

func (*Redis) Id

func (x *Redis) Id() string

func (*Redis) Init

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

Init 初始化

func (*Redis) New

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

func (*Redis) Printf

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

func (*Redis) RemoveRouter

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

func (*Redis) Start

func (x *Redis) Start() error

func (*Redis) Type

func (x *Redis) Type() string

Type 组件类型

type RequestMessage

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

RequestMessage 请求消息

func (*RequestMessage) Body

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

func (*RequestMessage) From

func (r *RequestMessage) From() string

func (*RequestMessage) GetError

func (r *RequestMessage) GetError() error

func (*RequestMessage) GetMsg

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

func (*RequestMessage) GetParam

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

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)

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
}

ResponseMessage http响应消息

func (*ResponseMessage) Body

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

func (*ResponseMessage) From

func (r *ResponseMessage) From() string

func (*ResponseMessage) GetError

func (r *ResponseMessage) GetError() error

func (*ResponseMessage) GetMsg

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

func (*ResponseMessage) GetParam

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

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)

func (*ResponseMessage) SetMsg

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

func (*ResponseMessage) SetStatusCode

func (r *ResponseMessage) SetStatusCode(statusCode int)