kubernetes

package

v0.5.4 Latest Latest Go to latest Published: Oct 26, 2023 License: MPL-2.0 Imports: 26 Imported by: 0

Details

View Source

const (
	FieldOwner client.FieldOwner = "fox"
)

View Source

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

This section is empty.

type Client struct {
	client.Client

	KubeConfig *clientcmdapi.Config
	RestConfig *rest.Config
	// 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) GetPlatform(ctx context.Context) (*v1alpha1.Platform, error)

func (r *Client) ListPlatforms(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

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
	BrokerPod  string
	BrokerPort int32
	LocalPort  int32
}