kubernetes

Documentation

Index

• Variables
• type Client
  • func NewClient(cfg *config.Config) *Client
  • func (c *Client) Apply(ctx context.Context, obj client.Object) error
  • func (c *Client) Create(ctx context.Context, obj client.Object) error
  • func (c *Client) CreatePlatform(ctx context.Context, namespace, name string) *v1alpha1.Platform
  • func (c *Client) GetPlatform(ctx context.Context) *v1alpha1.Platform
  • func (c *Client) ListPlatforms(ctx context.Context) ([]v1alpha1.Platform, error)
  • func (c *Client) Merge(ctx context.Context, modified, original client.Object) error
  • func (c *Client) PortForward(ctx context.Context, req *PortForwardRequest) (*PortForward, error)
  • func (c *Client) WaitPlatformReady(waitTime time.Duration, p *v1alpha1.Platform, spec *v1alpha1.AppDeploymentSpec)
  • func (c *Client) WaitPodReady(ctx context.Context, p *v1alpha1.Platform, comp, hash string) error
• type PortForward
  • func (pf *PortForward) Done() <-chan struct{}
  • func (pf *PortForward) Ready() <-chan struct{}
  • func (pf *PortForward) Stop()
• type PortForwardRequest

Variables

var (
	ErrComponentNotReady = fmt.Errorf("component not ready")
)

Types

type Client

type Client struct {
	*k8s.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cfg *config.Config) *Client

func (*Client) Apply

func (c *Client) Apply(ctx context.Context, obj client.Object) error

func (*Client) Create

func (c *Client) Create(ctx context.Context, obj client.Object) error

func (*Client) CreatePlatform

func (c *Client) CreatePlatform(ctx context.Context, namespace, name string) *v1alpha1.Platform

func (*Client) GetPlatform

func (c *Client) GetPlatform(ctx context.Context) *v1alpha1.Platform

func (*Client) ListPlatforms

func (c *Client) ListPlatforms(ctx context.Context) ([]v1alpha1.Platform, error)

func (*Client) Merge

func (c *Client) Merge(ctx context.Context, modified, original client.Object) error

func (*Client) PortForward

func (c *Client) PortForward(ctx context.Context, req *PortForwardRequest) (*PortForward, error)

func (*Client) WaitPlatformReady

func (c *Client) WaitPlatformReady(waitTime time.Duration, p *v1alpha1.Platform, spec *v1alpha1.AppDeploymentSpec)

func (*Client) WaitPodReady

func (c *Client) WaitPodReady(ctx context.Context, p *v1alpha1.Platform, comp, hash string) error

type PortForward

type PortForward struct {
	LocalPort int32
	// contains filtered or unexported fields
}

func (*PortForward) Done

func (pf *PortForward) Done() <-chan struct{}

func (*PortForward) Ready

func (pf *PortForward) Ready() <-chan struct{}

func (*PortForward) Stop

func (pf *PortForward) Stop()

type PortForwardRequest

type PortForwardRequest struct {
	Namespace   string
	Platform    string
	HTTPSrvPod  string
	HTTPSrvPort int32
	LocalPort   int32
}