transport

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

type ExponentialBackoffOptions struct {
	// BaseDelay is the base delay before the first retry.
	BaseDelay time.Duration

	// MaxDelay is the maximum delay between retries.
	MaxDelay time.Duration

	// ExponentialFactor is the exponential factor to use for calculating the delay.
	// The delay is calculated as BaseDelay * ExponentialFactor ^ retryCount.
	ExponentialFactor float64
}

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

type HTTPError struct {
	Code int   // Code is the HTTP status code.
	Err  error // Err is an optional underlying error.
}

type HTTPErrorCode interface {
	// HTTPErrorCode returns the HTTP status code.
	HTTPErrorCode() int
}

type HTTPOptions struct {
	// URL of the HTTP endpoint.
	URL string

	// HTTPClient is the HTTP client to use. If nil, http.DefaultClient is
	// used.
	HTTPClient *http.Client

	// HTTPHeader specifies the HTTP headers to send with each request.
	HTTPHeader http.Header
}

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

type IPCOptions struct {
	// Context used to close the connection.
	Context context.Context

	// Path is the path to the IPC socket.
	Path string

	// Timeout is the timeout for the IPC requests. Default is 60s.
	Timout time.Duration

	// ErrorCh is an optional channel used to report errors.
	ErrorCh chan error
}

type RPCError struct {
	Code    int    // Code is the JSON-RPC error code.
	Message string // Message is the error message.
	Data    any    // Data associated with the error.
}

type RPCErrorCode interface {
	// RPCErrorCode returns the JSON-RPC error code.
	RPCErrorCode() int
}

type RPCErrorData interface {
	// RPCErrorData returns the JSON-RPC error data.
	RPCErrorData() any
}

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

type RetryOptions struct {
	// Transport is the underlying transport to use.
	Transport Transport

	// RetryFunc is a function that returns true if the request should be
	// retried. The RetryOnAnyError and RetryOnLimitExceeded functions can be
	// used or a custom function can be provided.
	RetryFunc func(error) bool

	// BackoffFunc is a function that returns the delay before the next retry.
	// It takes the current retry count as an argument.
	BackoffFunc func(int) time.Duration

	// MaxRetries is the maximum number of retries. If negative, there is no limit.
	MaxRetries int
}

type SubscriptionTransport interface {
	Transport

	// Subscribe starts a new subscription. It returns a channel that receives
	// subscription messages and a subscription ID.
	Subscribe(ctx context.Context, method string, args ...any) (ch chan json.RawMessage, id string, err error)

	// Unsubscribe cancels a subscription. The channel returned by Subscribe
	// will be closed.
	Unsubscribe(ctx context.Context, id string) error
}

type Transport interface {
	// Call performs a JSON-RPC call.
	Call(ctx context.Context, result any, method string, args ...any) error
}

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

type WebsocketOptions struct {
	// Context used to close the connection.
	Context context.Context

	// URL of the websocket endpoint.
	URL string

	// HTTPClient is the HTTP client to use. If nil, http.DefaultClient is
	// used.
	HTTPClient *http.Client

	// HTTPHeader specifies the HTTP headers to be included in the
	// websocket handshake request.
	HTTPHeader http.Header

	// Timeout is the timeout for the websocket requests. Default is 60s.
	Timout time.Duration

	// ErrorCh is an optional channel used to report errors.
	ErrorCh chan error
}