model

Documentation

Index

• func CreateSystem(resources LoggingResources, secrets SecretLoaderFactory, logger logr.Logger) (*types.System, error)
• func FlowForClusterFlow(flow v1beta1.ClusterFlow, clusterOutputs ClusterOutputs, ...) (*types.Flow, error)
• func FlowForDefaultFlow(logging v1beta1.Logging, clusterOutputs ClusterOutputs, ...) (*types.Flow, error)
• func FlowForFlow(flow v1beta1.Flow, clusterOutputs ClusterOutputs, outputs Outputs, ...) (*types.Flow, error)
• func NewValidationReconciler(ctx context.Context, repo client.StatusClient, resources LoggingResources, ...) func() (*reconcile.Result, error)
• type ClusterOutputs
  • func (c ClusterOutputs) FindByName(name string) *v1beta1.ClusterOutput
• type LoggingResourceRepository
  • func NewLoggingResourceRepository(client client.Reader) *LoggingResourceRepository
  • func (r LoggingResourceRepository) ClusterFlowsFor(ctx context.Context, logging v1beta1.Logging) ([]v1beta1.ClusterFlow, error)
  • func (r LoggingResourceRepository) ClusterOutputsFor(ctx context.Context, logging v1beta1.Logging) ([]v1beta1.ClusterOutput, error)
  • func (r LoggingResourceRepository) FlowsInNamespaceFor(ctx context.Context, namespace string, logging v1beta1.Logging) ([]v1beta1.Flow, error)
  • func (r LoggingResourceRepository) LoggingResourcesFor(ctx context.Context, logging v1beta1.Logging) (res LoggingResources, errs error)
  • func (r LoggingResourceRepository) OutputsInNamespaceFor(ctx context.Context, namespace string, logging v1beta1.Logging) ([]v1beta1.Output, error)
• type LoggingResources
• type Outputs
  • func (c Outputs) FindByNamespacedName(namespace string, name string) *v1beta1.Output
• type SecretLoaderFactory

Functions

func CreateSystem

func CreateSystem(resources LoggingResources, secrets SecretLoaderFactory, logger logr.Logger) (*types.System, error)

func FlowForClusterFlow

func FlowForClusterFlow(flow v1beta1.ClusterFlow, clusterOutputs ClusterOutputs, secrets SecretLoaderFactory) (*types.Flow, error)

func FlowForDefaultFlow

func FlowForDefaultFlow(logging v1beta1.Logging, clusterOutputs ClusterOutputs, secrets SecretLoaderFactory) (*types.Flow, error)

func FlowForFlow

func FlowForFlow(flow v1beta1.Flow, clusterOutputs ClusterOutputs, outputs Outputs, secrets SecretLoaderFactory) (*types.Flow, error)

func NewValidationReconciler

func NewValidationReconciler(
	ctx context.Context,
	repo client.StatusClient,
	resources LoggingResources,
	secrets SecretLoaderFactory,
) func() (*reconcile.Result, error)

Types

type ClusterOutputs

type ClusterOutputs []v1beta1.ClusterOutput

func (ClusterOutputs) FindByName

func (c ClusterOutputs) FindByName(name string) *v1beta1.ClusterOutput

type LoggingResourceRepository

type LoggingResourceRepository struct {
	Client client.Reader
}

func NewLoggingResourceRepository

func NewLoggingResourceRepository(client client.Reader) *LoggingResourceRepository

func (LoggingResourceRepository) ClusterFlowsFor

func (r LoggingResourceRepository) ClusterFlowsFor(ctx context.Context, logging v1beta1.Logging) ([]v1beta1.ClusterFlow, error)

func (LoggingResourceRepository) ClusterOutputsFor

func (r LoggingResourceRepository) ClusterOutputsFor(ctx context.Context, logging v1beta1.Logging) ([]v1beta1.ClusterOutput, error)

func (LoggingResourceRepository) FlowsInNamespaceFor

func (r LoggingResourceRepository) FlowsInNamespaceFor(ctx context.Context, namespace string, logging v1beta1.Logging) ([]v1beta1.Flow, error)

func (LoggingResourceRepository) LoggingResourcesFor

func (r LoggingResourceRepository) LoggingResourcesFor(ctx context.Context, logging v1beta1.Logging) (res LoggingResources, errs error)

func (LoggingResourceRepository) OutputsInNamespaceFor

func (r LoggingResourceRepository) OutputsInNamespaceFor(ctx context.Context, namespace string, logging v1beta1.Logging) ([]v1beta1.Output, error)

type LoggingResources

type LoggingResources struct {
	Logging        v1beta1.Logging
	Outputs        Outputs
	Flows          []v1beta1.Flow
	ClusterOutputs ClusterOutputs
	ClusterFlows   []v1beta1.ClusterFlow
}

type Outputs

type Outputs []v1beta1.Output

func (Outputs) FindByNamespacedName

func (c Outputs) FindByNamespacedName(namespace string, name string) *v1beta1.Output

type SecretLoaderFactory

type SecretLoaderFactory interface {
	OutputSecretLoaderForNamespace(namespace string) secret.SecretLoader
}