client

Documentation

Index

• type Client
  • func NewClient(options ...Option) *Client
  • func (c *Client) StartListen()
  • func (c *Client) Submit(submitUri string, params map[string]string, l Listener) error
• type GetClientAddress
• type GetServerAddress
• type Listener
• type ListenerAsynFunc
  • func (f ListenerAsynFunc) Listen(reqId string, submitUri string, response string, serverError error) error
• type ListenerFunc
  • func (f ListenerFunc) Listen(reqId string, submitUri string, response string, serverError error) error
• type Option
  • func WithEngine(engine *gin.Engine) Option
  • func WithGetClientAddress(getClientAddress GetClientAddress) Option
  • func WithGetServerAddress(getServerAddress GetServerAddress) Option
  • func WithListenUri(listenUri string) Option
  • func WithLogger(logger *logrus.Logger) Option
• type SubmitResult

Types

type Client

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

func NewClient

func NewClient(options ...Option) *Client

func (*Client) StartListen

func (c *Client) StartListen()

func (*Client) Submit

func (c *Client) Submit(submitUri string, params map[string]string, l Listener) error

type GetClientAddress

type GetClientAddress func() string // http://ip:port

type GetServerAddress

type GetServerAddress func() string // http://ip:port

可用于负载均衡

type Listener

type Listener interface {
	Listen(reqId string, submitUri string, response string, serverError error) error
}

type ListenerAsynFunc

type ListenerAsynFunc func(reqId string, submitUri string, response string, serverError error) error

func (ListenerAsynFunc) Listen

func (f ListenerAsynFunc) Listen(reqId string, submitUri string, response string, serverError error) error

type ListenerFunc

type ListenerFunc func(reqId string, submitUri string, response string, serverError error) error

func (ListenerFunc) Listen

func (f ListenerFunc) Listen(reqId string, submitUri string, response string, serverError error) error

type Option

type Option func(c *Client)

func WithEngine

func WithEngine(engine *gin.Engine) Option

func WithGetClientAddress

func WithGetClientAddress(getClientAddress GetClientAddress) Option

func WithGetServerAddress

func WithGetServerAddress(getServerAddress GetServerAddress) Option

func WithListenUri

func WithListenUri(listenUri string) Option

func WithLogger

func WithLogger(logger *logrus.Logger) Option

type SubmitResult

type SubmitResult struct {
	Result   string `json:"result"`
	Complete string `json:"complete"`
	Response string `json:"response"`
}