sources

Documentation

Index

• Constants
• type LogEntry
• type PubSubSource
  • func NewPubSubSource(ctx context.Context, project string, subscription string) (*PubSubSource, error)
  • func (ps *PubSubSource) ErrorOut() <-chan error
  • func (pss *PubSubSource) Out() <-chan StreamMessage[string]
• type Resource
• type WorkflowSource
  • func NewWorkflowSource(ctx context.Context, namespace string, k8sClient K8sClient) (*WorkflowSource, error)
  • func (ws *WorkflowSource) Out() <-chan StreamMessage[*unstructured.Unstructured]

Constants

const PipelineJobLabel = "pipeline_job_id"

Types

type LogEntry

type LogEntry struct {
	Resource Resource `json:"resource"`
}

type PubSubSource

type PubSubSource struct {
	RunsSubscription *pubsub.Subscription
	Logger           logr.Logger
	// contains filtered or unexported fields
}

func NewPubSubSource

func NewPubSubSource(ctx context.Context, project string, subscription string) (*PubSubSource, error)

func (*PubSubSource) ErrorOut

func (ps *PubSubSource) ErrorOut() <-chan error

func (*PubSubSource) Out

func (pss *PubSubSource) Out() <-chan StreamMessage[string]

type Resource

type Resource struct {
	Labels map[string]string `json:"labels"`
}

type WorkflowSource

type WorkflowSource struct {
	K8sClient K8sClient
	Logger    logr.Logger
	// contains filtered or unexported fields
}

func NewWorkflowSource

func NewWorkflowSource(ctx context.Context, namespace string, k8sClient K8sClient) (*WorkflowSource, error)

func (*WorkflowSource) Out

func (ws *WorkflowSource) Out() <-chan StreamMessage[*unstructured.Unstructured]