ticdc

Documentation

Index

• Variables
• type Client
  • func NewTiCDCClient(lc fx.Lifecycle, httpClient *httpc.Client, config *config.Config) *Client
  • func (c Client) AddRequestHeader(key, value string) *Client
  • func (c *Client) Get(host string, statusPort int, relativeURI string) (*httpc.Response, error)
  • func (c *Client) SendGetRequest(host string, statusPort int, relativeURI string) ([]byte, error)
  • func (c *Client) SendPostRequest(host string, statusPort int, relativeURI string, body io.Reader) ([]byte, error)
  • func (c Client) WithTimeout(timeout time.Duration) *Client

Variables

var ErrNS = errorx.NewNamespace("error.ticdc")

var ErrTiCDCClientRequestFailed = ErrNS.NewType("client_request_failed")

Types

type Client

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

func NewTiCDCClient

func NewTiCDCClient(lc fx.Lifecycle, httpClient *httpc.Client, config *config.Config) *Client

func (Client) AddRequestHeader

func (c Client) AddRequestHeader(key, value string) *Client

func (*Client) Get

func (c *Client) Get(host string, statusPort int, relativeURI string) (*httpc.Response, error)

func (*Client) SendGetRequest

func (c *Client) SendGetRequest(host string, statusPort int, relativeURI string) ([]byte, error)

func (*Client) SendPostRequest

func (c *Client) SendPostRequest(host string, statusPort int, relativeURI string, body io.Reader) ([]byte, error)

func (Client) WithTimeout

func (c Client) WithTimeout(timeout time.Duration) *Client