logging

Documentation

Index

• type ChartConfig
  • func (c ChartConfig) Validate() error
• type ChartsConfig
• type Config
  • func (c Config) Validate() error
• type ImageConfig
  • func (c ImageConfig) Validate() error
• type ImagesConfig
• type IntegratedServiceOperator
  • func MakeIntegratedServicesOperator(clusterGetter integratedserviceadapter.ClusterGetter, ...) IntegratedServiceOperator
  • func (op IntegratedServiceOperator) Apply(ctx context.Context, clusterID uint, ...) error
  • func (op IntegratedServiceOperator) Deactivate(ctx context.Context, clusterID uint, ...) error
  • func (IntegratedServiceOperator) Name() string
• type IntegratedServicesManager
  • func MakeIntegratedServiceManager(clusterGetter integratedserviceadapter.ClusterGetter, ...) IntegratedServicesManager
  • func (m IntegratedServicesManager) GetOutput(ctx context.Context, clusterID uint, ...) (integratedservices.IntegratedServiceOutput, error)
  • func (IntegratedServicesManager) Name() string
  • func (IntegratedServicesManager) PrepareSpec(ctx context.Context, clusterID uint, ...) (integratedservices.IntegratedServiceSpec, error)
  • func (IntegratedServicesManager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error
• type KubernetesService

Types

type ChartConfig

type ChartConfig struct {
	Chart   string
	Version string
	Values  map[string]interface{}
}

func (ChartConfig) Validate

func (c ChartConfig) Validate() error

type ChartsConfig

type ChartsConfig struct {
	Operator ChartConfig
	Loki     ChartConfig
}

type Config

type Config struct {
	Namespace string
	Charts    ChartsConfig
	Images    ImagesConfig
}

Config contains configuration for the logging integrated service.

func (Config) Validate

func (c Config) Validate() error

type ImageConfig

type ImageConfig struct {
	Repository string
	Tag        string
}

func (ImageConfig) Validate

func (c ImageConfig) Validate() error

type ImagesConfig

type ImagesConfig struct {
	Operator  ImageConfig
	Loki      ImageConfig
	Fluentbit ImageConfig
	Fluentd   ImageConfig
}

type IntegratedServiceOperator

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

IntegratedServiceOperator implements the Logging integrated service operator

func MakeIntegratedServicesOperator

func MakeIntegratedServicesOperator(
	clusterGetter integratedserviceadapter.ClusterGetter,
	clusterService integratedservices.ClusterService,
	helmService services.HelmService,
	kubernetesService KubernetesService,
	endpointsService endpoints.EndpointService,
	config Config,
	logger common.Logger,
	secretStore services.SecretStore,
) IntegratedServiceOperator

MakeIntegratedServicesOperator returns a Logging integrated service operator

func (IntegratedServiceOperator) Apply

func (op IntegratedServiceOperator) Apply(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Apply applies the provided specification to the integrated service

func (IntegratedServiceOperator) Deactivate

func (op IntegratedServiceOperator) Deactivate(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) error

Deactivate deactivates the integrated service

func (IntegratedServiceOperator) Name

func (IntegratedServiceOperator) Name() string

Name returns the name of the Logging integrated service

type IntegratedServicesManager

type IntegratedServicesManager struct {
	integratedservices.PassthroughIntegratedServiceSpecPreparer
	// contains filtered or unexported fields
}

IntegratedServiceManager implements the Logging integrated service manager

func MakeIntegratedServiceManager

func MakeIntegratedServiceManager(
	clusterGetter integratedserviceadapter.ClusterGetter,
	secretStore services.SecretStore,
	endpointsService endpoints.EndpointService,
	config Config,
	logger common.Logger,
) IntegratedServicesManager

func (IntegratedServicesManager) GetOutput

func (m IntegratedServicesManager) GetOutput(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) (integratedservices.IntegratedServiceOutput, error)

func (IntegratedServicesManager) Name

func (IntegratedServicesManager) Name() string

Name returns the integrated service' name

func (IntegratedServicesManager) PrepareSpec

func (IntegratedServicesManager) PrepareSpec(ctx context.Context, clusterID uint, spec integratedservices.IntegratedServiceSpec) (integratedservices.IntegratedServiceSpec, error)

func (IntegratedServicesManager) ValidateSpec

func (IntegratedServicesManager) ValidateSpec(ctx context.Context, spec integratedservices.IntegratedServiceSpec) error

type KubernetesService

type KubernetesService interface {
	// EnsureObject makes sure that a given Object is on the cluster and returns it.
	EnsureObject(ctx context.Context, clusterID uint, o client.Object) error

	// Update updates a given Object on the cluster and returns it.
	Update(ctx context.Context, clusterID uint, o client.Object) error

	// DeleteObject deletes an Object from a specific cluster.
	DeleteObject(ctx context.Context, clusterID uint, o client.Object) error

	// GetObject gets an Object from a specific cluster.
	GetObject(ctx context.Context, clusterID uint, objRef corev1.ObjectReference, obj client.Object) error

	// List lists Objects on specific cluster.
	List(ctx context.Context, clusterID uint, labels map[string]string, o client.ObjectList) error
}