kubernetes

package

v0.8.3 Latest Latest Go to latest Published: Feb 16, 2024 License: MPL-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

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, commit string) error

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

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

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

func (pf *PortForward) Stop()

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