client

Documentation

Index

• Constants
• Variables
• func RetryWithBackoff(ctx context.Context, timeout time.Duration, fn func() error) error
• type CheckStatusResponse
• type Client
  • 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
• type Option
  • func WithDialer(dialer Dialer) Option
  • func WithLogger(logger *slog.Logger) Option

Constants

const (
	DefaultConnectTimeout = 5 * time.Second
)

Variables

var (
	ErrRetryTimeoutExceeded = errors.New("retry timeout exceeded")
)

Functions

func RetryWithBackoff

func RetryWithBackoff(ctx context.Context, timeout time.Duration, fn func() error) error

Types

type CheckStatusResponse

type CheckStatusResponse struct {
	Status        api.Status
	FailureReason string
}

type Client

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

func New

func New(target string, opts ...Option) (*Client, error)

func (*Client) CheckStatus

func (c *Client) CheckStatus(ctx context.Context) (CheckStatusResponse, error)

func (*Client) Connect

func (c *Client) Connect(ctx context.Context) error

func (*Client) ConnectWithTimeout

func (c *Client) ConnectWithTimeout(ctx context.Context, timeout time.Duration) error

func (*Client) InitForcefulShutdown

func (c *Client) InitForcefulShutdown(ctx context.Context) (CheckStatusResponse, error)

func (*Client) InitGracefulShutdown

func (c *Client) InitGracefulShutdown(ctx context.Context, req api.InitGracefulShutdownRequest) (CheckStatusResponse, error)

type Dialer

type Dialer func(network string, address string) (net.Conn, error)

type Option

type Option func(o *options)

func WithDialer

func WithDialer(dialer Dialer) Option

func WithLogger

func WithLogger(logger *slog.Logger) Option