Versions in this module Expand all Collapse all v0 v0.1.1 Mar 7, 2025 v0.1.0 Feb 28, 2025 Changes in this version + const DefaultConnectTimeout + var ErrRetryTimeoutExceeded = errors.New("retry timeout exceeded") + func RetryWithBackoff(ctx context.Context, timeout time.Duration, fn func() error) error + type CheckStatusResponse struct + FailureReason string + Status api.Status + type Client struct + func New(target string, opts ...Option) (*Client, error) + func (c *Client) CheckStatus(ctx context.Context) (CheckStatusResponse, error) + func (c *Client) Connect(ctx context.Context) error + func (c *Client) ConnectWithTimeout(ctx context.Context, timeout time.Duration) error + func (c *Client) InitForcefulShutdown(ctx context.Context) (CheckStatusResponse, error) + func (c *Client) InitGracefulShutdown(ctx context.Context, req api.InitGracefulShutdownRequest) (CheckStatusResponse, error) + type Dialer func(network string, address string) (net.Conn, error) + type InitGracefulShutdownResponse struct + FailureReason string + Status api.Status + type Option func(o *options) + func WithDialer(dialer Dialer) Option + func WithLogger(logger *slog.Logger) Option
Go to main page