pkg

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(socketAddr string) *Client
  • func (c *Client) Get(path string) (string, error)
  • func (c *Client) GetJson(path string, data any) error
  • func (c *Client) Ready() error
  • func (c *Client) Stop() error
• type Forwarder
  • func NewForwarder(kubeconfig string, target Target) (*Forwarder, error)
  • func (f *Forwarder) Run(ctx context.Context)
  • func (f *Forwarder) Stop()
• type ForwarderStatus
• type Manifest
  • func LoadManifest(filepath string) (*Manifest, error)
• type Server
  • func NewServer(socketAddr string, kubeconfig string, manifest string, logFilePath string) *Server
  • func (s Server) Run() error
• type Target
  • func (t Target) String() string

Constants

const (
	Version = "unset"
)

Variables

var ErrNotReady = errors.New("not ready")

Types

type Client

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

func NewClient

func NewClient(socketAddr string) *Client

func (*Client) Get

func (c *Client) Get(path string) (string, error)

func (*Client) GetJson

func (c *Client) GetJson(path string, data any) error

func (*Client) Ready

func (c *Client) Ready() error

func (*Client) Stop

func (c *Client) Stop() error

type Forwarder

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

func NewForwarder

func NewForwarder(kubeconfig string, target Target) (*Forwarder, error)

func (*Forwarder) Run

func (f *Forwarder) Run(ctx context.Context)

func (*Forwarder) Stop

func (f *Forwarder) Stop()

type ForwarderStatus

type ForwarderStatus struct {
	Target     `json:,inline`
	Forwarding bool `json:"forwarding"`
}

type Manifest

type Manifest struct {
	Targets []Target `json:"targets"`
}

func LoadManifest

func LoadManifest(filepath string) (*Manifest, error)

type Server

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

func NewServer

func NewServer(socketAddr string, kubeconfig string, manifest string, logFilePath string) *Server

func (Server) Run

func (s Server) Run() error

type Target

type Target struct {
	ObjectType string   `json:"type"`
	Namespace  string   `json:"namespace"`
	Name       string   `json:"name"`
	Ports      []string `json:"ports"`
}

func (Target) String

func (t Target) String() string