k8sclient

package

v0.10.2 Latest Latest Go to latest Published: Jul 24, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func NewClient() (*Client, error)

func (c *Client) GetPipelineQueryConfig(
	ctx context.Context, name string, stageType operatorv1alpha1.StageType,
) (*QueryConfig, error)

func (c *Client) ListPipelines(ctx context.Context) ([]PipelineInfo, error)

type PipelineInfo struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	Database    string `json:"-"`
}

type QueryConfig struct {
	Database string
	Schema   string
	Table    string
}