util

Documentation

Index

• Variables
• func HttpGet(ctx context.Context, url string, header map[string]string, data g.Map, ...) error
• func HttpPost(ctx context.Context, url string, header map[string]string, ...) error
• type RequestErrorHandler
• type StreamReader
  • func SSEClient(ctx context.Context, url string, header map[string]string, data interface{}, ...) (stream *StreamReader, err error)
  • func (stream *StreamReader) Close() error
  • func (stream *StreamReader) Recv() (response []byte, err error)
• type WebSocketConn
  • func WebSocketClient(ctx context.Context, wsURL string, messageType int, message []byte, ...) (*WebSocketConn, error)
  • func (c *WebSocketConn) Close() (err error)
  • func (c *WebSocketConn) ReadMessage(ctx context.Context) ([]byte, error)

Variables

var (
	ErrTooManyEmptyStreamMessages = errors.New("stream has sent too many empty messages")
)

Functions

func HttpGet

func HttpGet(ctx context.Context, url string, header map[string]string, data g.Map, result interface{}, proxyURL string) error

func HttpPost

func HttpPost(ctx context.Context, url string, header map[string]string, data, result interface{}, proxyURL string) error

Types

type RequestErrorHandler

type RequestErrorHandler func(ctx context.Context, response *gclient.Response) (err error)

type StreamReader

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

func SSEClient

func SSEClient(ctx context.Context, url string, header map[string]string, data interface{}, proxyURL string, requestErrorHandler RequestErrorHandler) (stream *StreamReader, err error)

func (*StreamReader) Close

func (stream *StreamReader) Close() error

func (*StreamReader) Recv

func (stream *StreamReader) Recv() (response []byte, err error)

type WebSocketConn

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

func WebSocketClient

func WebSocketClient(ctx context.Context, wsURL string, messageType int, message []byte, proxyURL string) (*WebSocketConn, error)

func (*WebSocketConn) Close

func (c *WebSocketConn) Close() (err error)

func (*WebSocketConn) ReadMessage

func (c *WebSocketConn) ReadMessage(ctx context.Context) ([]byte, error)