Versions in this module Expand all Collapse all v0 v0.28.0 Jan 7, 2025 Changes in this version + const Type + type Client struct + func (c *Client) Close() + func (c *Client) IsActive() bool + type Config struct + CheckInterval int + Headers map[string]string + Method string + Request string + Server string + Service string + type Endpoint = GrpcStream + type GrpcStream struct + Config Config + Router endpointApi.Router + RuleConfig types.Config + func (x *GrpcStream) AddRouter(router endpointApi.Router, params ...interface{}) (string, error) + func (x *GrpcStream) Destroy() + func (x *GrpcStream) Id() string + func (x *GrpcStream) Init(ruleConfig types.Config, configuration types.Configuration) error + func (x *GrpcStream) New() types.Node + func (x *GrpcStream) Printf(format string, v ...interface{}) + func (x *GrpcStream) RemoveRouter(routerId string, params ...interface{}) error + func (x *GrpcStream) Start() error + func (x *GrpcStream) Type() string + 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)
Go to main page