Documentation
¶
Index ¶
- type Client
- func (c *Client) StreamAnalysisRunLogs(ctx context.Context, project string, analysisRun string, metricName string, ...) (<-chan string, <-chan error)
- func (c *Client) WatchClusterConfig(ctx context.Context) (<-chan Event[*kargoapi.ClusterConfig], <-chan error)
- func (c *Client) WatchProjectConfig(ctx context.Context, project string) (<-chan Event[*kargoapi.ProjectConfig], <-chan error)
- func (c *Client) WatchPromotion(ctx context.Context, project string, promotion string) (<-chan Event[*kargoapi.Promotion], <-chan error)
- func (c *Client) WatchPromotions(ctx context.Context, project string) (<-chan Event[*kargoapi.Promotion], <-chan error)
- func (c *Client) WatchStage(ctx context.Context, project string, stage string) (<-chan Event[*kargoapi.Stage], <-chan error)
- func (c *Client) WatchStages(ctx context.Context, project string) (<-chan Event[*kargoapi.Stage], <-chan error)
- func (c *Client) WatchWarehouse(ctx context.Context, project string, warehouse string) (<-chan Event[*kargoapi.Warehouse], <-chan error)
- func (c *Client) WatchWarehouses(ctx context.Context, project string) (<-chan Event[*kargoapi.Warehouse], <-chan error)
- type Event
- type EventType
- type LogEntry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is an SSE watch client for Kargo resources.
func (*Client) StreamAnalysisRunLogs ¶
func (c *Client) StreamAnalysisRunLogs( ctx context.Context, project string, analysisRun string, metricName string, containerName string, ) (<-chan string, <-chan error)
StreamAnalysisRunLogs streams logs from an analysis run.
func (*Client) WatchClusterConfig ¶
func (c *Client) WatchClusterConfig( ctx context.Context, ) (<-chan Event[*kargoapi.ClusterConfig], <-chan error)
WatchClusterConfig watches the ClusterConfig. Cancel the provided context to stop watching.
func (*Client) WatchProjectConfig ¶
func (c *Client) WatchProjectConfig( ctx context.Context, project string, ) (<-chan Event[*kargoapi.ProjectConfig], <-chan error)
WatchProjectConfig watches the ProjectConfig for a specific project. Cancel the provided context to stop watching.
func (*Client) WatchPromotion ¶
func (c *Client) WatchPromotion( ctx context.Context, project string, promotion string, ) (<-chan Event[*kargoapi.Promotion], <-chan error)
WatchPromotion watches a specific Promotion for changes. Cancel the provided context to stop watching.
func (*Client) WatchPromotions ¶
func (c *Client) WatchPromotions( ctx context.Context, project string, ) (<-chan Event[*kargoapi.Promotion], <-chan error)
WatchPromotions watches all Promotions in a project for changes. Cancel the provided context to stop watching.
func (*Client) WatchStage ¶
func (c *Client) WatchStage( ctx context.Context, project string, stage string, ) (<-chan Event[*kargoapi.Stage], <-chan error)
WatchStage watches a specific Stage for changes. Cancel the provided context to stop watching.
func (*Client) WatchStages ¶
func (c *Client) WatchStages( ctx context.Context, project string, ) (<-chan Event[*kargoapi.Stage], <-chan error)
WatchStages watches all Stages in a project for changes. Cancel the provided context to stop watching.
Source Files