kubernetes

Feb 3, 2024

Changes in this version

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

type Client

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

+ func (c *Client) CreatePlatform(namespace, name string) *v1alpha1.Platform

type PortForwardRequest

+ HTTPSrvPod string

+ HTTPSrvPort int32

Oct 26, 2023

Changes in this version

+ const FieldOwner

+ var ErrComponentNotRead = fmt.Errorf("component not ready")

+ type Client struct

+ KubeConfig *clientcmdapi.Config

+ RestConfig *rest.Config

+ func NewClient(cfg *config.Config) *Client

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

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

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

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

+ func (c *Client) WaitPlatformReady(ctx context.Context, p *v1alpha1.Platform, spec *v1alpha1.DeploymentSpec)

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

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

+ type PortForward struct

+ LocalPort int32

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

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

+ func (pf *PortForward) Stop()

+ type PortForwardRequest struct

+ BrokerPod string

+ BrokerPort int32

+ LocalPort int32

+ Namespace string

+ Platform string