transport

Documentation

Index

• type Client
  • func NewProxyClient(resource ProxyResource, name string, namespace string, port string, ...) Client
• type HttpClientTransport
  • func NewHTTPClientTransport(host string, port string, opts ...HttpClientTransportOpt) *HttpClientTransport
  • func (h HttpClientTransport) Get(path string) ([]byte, error)
• type HttpClientTransportOpt
  • func WithTimeout(duration time.Duration) HttpClientTransportOpt
  • func WithTransport(transport http.RoundTripper) HttpClientTransportOpt
• type NotFoundError
  • func NewNotFoundError(err error) NotFoundError
  • func (e NotFoundError) Error() string
  • func (e NotFoundError) Unwrap() error
• type ProxyResource
• type ServiceUnavailableError
  • func NewServiceUnavailableError(err error) ServiceUnavailableError
  • func (e ServiceUnavailableError) Error() string
  • func (e ServiceUnavailableError) Unwrap() error

Types

type Client

type Client interface {
	Get(path string) ([]byte, error)
}

func NewProxyClient

func NewProxyClient(resource ProxyResource, name string, namespace string, port string, clientSet kubernetes.Interface) Client

type HttpClientTransport

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

func NewHTTPClientTransport

func NewHTTPClientTransport(host string, port string, opts ...HttpClientTransportOpt) *HttpClientTransport

func (HttpClientTransport) Get

func (h HttpClientTransport) Get(path string) ([]byte, error)

type HttpClientTransportOpt

type HttpClientTransportOpt func(t *HttpClientTransport)

func WithTimeout

func WithTimeout(duration time.Duration) HttpClientTransportOpt

func WithTransport

func WithTransport(transport http.RoundTripper) HttpClientTransportOpt

type NotFoundError

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

NotFoundError indicates that the requested resource was not found

func NewNotFoundError

func NewNotFoundError(err error) NotFoundError

func (NotFoundError) Error

func (e NotFoundError) Error() string

func (NotFoundError) Unwrap

func (e NotFoundError) Unwrap() error

type ProxyResource

type ProxyResource string

const (
	Pod     ProxyResource = "pods"
	Service ProxyResource = "services"
)

type ServiceUnavailableError

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

ServiceUnavailableError indicates that the Spark API is unavailable

func NewServiceUnavailableError

func NewServiceUnavailableError(err error) ServiceUnavailableError

func (ServiceUnavailableError) Error

func (e ServiceUnavailableError) Error() string

func (ServiceUnavailableError) Unwrap

func (e ServiceUnavailableError) Unwrap() error