clusterlogging

package
v0.0.0-...-8c81107 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 22, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Builder

type Builder struct {
	// ClusterLogging definition. Used to create clusterLogging object with minimum set of required elements.
	Definition *clov1.ClusterLogging
	// Created clusterLogging object on the cluster.
	Object *clov1.ClusterLogging
	// contains filtered or unexported fields
}

Builder provides struct for clusterLogging object.

func NewBuilder

func NewBuilder(
	apiClient *clients.Settings, name, nsname string) *Builder

NewBuilder method creates new instance of builder.

func Pull

func Pull(apiClient *clients.Settings, name, nsname string) (*Builder, error)

Pull retrieves an existing clusterLogging object from the cluster.

func (*Builder) Create

func (builder *Builder) Create() (*Builder, error)

Create makes a clusterLogging in the cluster and stores the created object in struct.

func (*Builder) Delete

func (builder *Builder) Delete() error

Delete removes clusterLogging from a cluster.

func (*Builder) Exists

func (builder *Builder) Exists() bool

Exists checks whether the given clusterLogging exists.

func (*Builder) Get

func (builder *Builder) Get() (*clov1.ClusterLogging, error)

Get returns clusterLogging object if found.

func (*Builder) IsReady

func (builder *Builder) IsReady(timeout time.Duration) bool

IsReady checks for the duration of timeout if the clusterLogging instance state is Ready.

func (*Builder) Update

func (builder *Builder) Update(force bool) (*Builder, error)

Update renovates the existing clusterLogging object with clusterLogging definition in builder.

func (*Builder) WithCollection

func (builder *Builder) WithCollection(
	collection clov1.CollectionSpec) *Builder

WithCollection sets the clusterLogging operator's collection configuration.

func (*Builder) WithLogStore

func (builder *Builder) WithLogStore(
	logStore clov1.LogStoreSpec) *Builder

WithLogStore sets the clusterLogging operator's logStore configuration.

func (*Builder) WithManagementState

func (builder *Builder) WithManagementState(
	managementState clov1.ManagementState) *Builder

WithManagementState sets the clusterLogging operator's managementState configuration.

func (*Builder) WithVisualization

func (builder *Builder) WithVisualization(
	visualization clov1.VisualizationSpec) *Builder

WithVisualization sets the clusterLogging operator's visualization configuration.

type ClusterLogForwarderBuilder

type ClusterLogForwarderBuilder struct {
	// clusterlogforwarder definition, used to create the clusterlogforwarder object.
	Definition *clov1.ClusterLogForwarder
	// Created clusterlogforwarder object.
	Object *clov1.ClusterLogForwarder
	// contains filtered or unexported fields
}

ClusterLogForwarderBuilder provides a struct for clusterlogforwarder object from the cluster and a clusterlogforwarder definition.

func NewClusterLogForwarderBuilder

func NewClusterLogForwarderBuilder(
	apiClient *clients.Settings, name, nsname string) *ClusterLogForwarderBuilder

NewClusterLogForwarderBuilder method creates new instance of builder.

func PullClusterLogForwarder

func PullClusterLogForwarder(apiClient *clients.Settings, name, nsname string) (*ClusterLogForwarderBuilder, error)

PullClusterLogForwarder retrieves an existing clusterlogforwarder object from the cluster.

func (*ClusterLogForwarderBuilder) Create

Create makes a clusterlogforwarder in the cluster and stores the created object in struct.

func (*ClusterLogForwarderBuilder) Delete

func (builder *ClusterLogForwarderBuilder) Delete() error

Delete removes clusterlogforwarder from a cluster.

func (*ClusterLogForwarderBuilder) Exists

func (builder *ClusterLogForwarderBuilder) Exists() bool

Exists checks whether the given clusterlogforwarder exists.

func (*ClusterLogForwarderBuilder) Get

Get returns clusterlogforwarder object if found.

func (*ClusterLogForwarderBuilder) Update

Update renovates the existing clusterlogforwarder object with clusterlogforwarder definition in builder.

func (*ClusterLogForwarderBuilder) WithOutput

func (builder *ClusterLogForwarderBuilder) WithOutput(outputSpec *clov1.OutputSpec) *ClusterLogForwarderBuilder

WithOutput sets the output on the clusterlogforwarder definition.

func (*ClusterLogForwarderBuilder) WithPipeline

func (builder *ClusterLogForwarderBuilder) WithPipeline(pipelineSpec *clov1.PipelineSpec) *ClusterLogForwarderBuilder

WithPipeline sets the pipeline on the clusterlogforwarder definition.

type ElasticsearchBuilder

type ElasticsearchBuilder struct {
	// Elasticsearch definition. Used to create elasticsearch object with minimum set of required elements.
	Definition *eskv1.Elasticsearch
	// Created elasticsearch object on the cluster.
	Object *eskv1.Elasticsearch
	// contains filtered or unexported fields
}

ElasticsearchBuilder provides struct for the elasticsearch object.

func NewElasticsearchBuilder

func NewElasticsearchBuilder(
	apiClient *clients.Settings, name, nsname string) *ElasticsearchBuilder

NewElasticsearchBuilder method creates new instance of builder.

func PullElasticsearch

func PullElasticsearch(apiClient *clients.Settings, name, nsname string) (*ElasticsearchBuilder, error)

PullElasticsearch retrieves an existing elasticsearch object from the cluster.

func (*ElasticsearchBuilder) Create

func (builder *ElasticsearchBuilder) Create() (*ElasticsearchBuilder, error)

Create makes a elasticsearch in the cluster and stores the created object in struct.

func (*ElasticsearchBuilder) Delete

func (builder *ElasticsearchBuilder) Delete() error

Delete removes elasticsearch from a cluster.

func (*ElasticsearchBuilder) Exists

func (builder *ElasticsearchBuilder) Exists() bool

Exists checks whether the given elasticsearch exists.

func (*ElasticsearchBuilder) Get

func (builder *ElasticsearchBuilder) Get() (*eskv1.Elasticsearch, error)

Get returns elasticsearch object if found.

func (*ElasticsearchBuilder) GetManagementState

func (builder *ElasticsearchBuilder) GetManagementState() (*eskv1.ManagementState, error)

GetManagementState fetches elasticsearch ManagementState.

func (*ElasticsearchBuilder) Update

func (builder *ElasticsearchBuilder) Update() (*ElasticsearchBuilder, error)

Update renovates the existing elasticsearch object with elasticsearch definition in builder.

func (*ElasticsearchBuilder) WithManagementState

func (builder *ElasticsearchBuilder) WithManagementState(
	expectedManagementState eskv1.ManagementState) *ElasticsearchBuilder

WithManagementState sets the elasticsearch operator's management state.

type LokiStackBuilder

type LokiStackBuilder struct {
	// LokiStack definition. Used to create lokiStack object with minimum set of required elements.
	Definition *lokiv1.LokiStack
	// Created lokiStack object on the cluster.
	Object *lokiv1.LokiStack
	// contains filtered or unexported fields
}

LokiStackBuilder provides struct for the lokiStack object.

func NewLokiStackBuilder

func NewLokiStackBuilder(
	apiClient *clients.Settings, name, nsname string) *LokiStackBuilder

NewLokiStackBuilder creates new instance of builder.

func PullLokiStack

func PullLokiStack(apiClient *clients.Settings, name, nsname string) (*LokiStackBuilder, error)

PullLokiStack retrieves an existing lokiStack object from the cluster.

func (*LokiStackBuilder) Create

func (builder *LokiStackBuilder) Create() (*LokiStackBuilder, error)

Create makes a lokiStack in the cluster and stores the created object in struct.

func (*LokiStackBuilder) Delete

func (builder *LokiStackBuilder) Delete() (*LokiStackBuilder, error)

Delete removes lokiStack from a cluster.

func (*LokiStackBuilder) Exists

func (builder *LokiStackBuilder) Exists() bool

Exists checks whether the given lokiStack exists.

func (*LokiStackBuilder) Get

func (builder *LokiStackBuilder) Get() (*lokiv1.LokiStack, error)

Get returns lokiStack object if found.

func (*LokiStackBuilder) IsReady

func (builder *LokiStackBuilder) IsReady(timeout time.Duration) bool

IsReady checks for the duration of timeout if the lokiStack state is Ready.

func (*LokiStackBuilder) Update

func (builder *LokiStackBuilder) Update() (*LokiStackBuilder, error)

Update renovates the existing lokiStack object with lokiStack definition in builder.

func (*LokiStackBuilder) WithLimits

func (builder *LokiStackBuilder) WithLimits(
	limits lokiv1.LimitsSpec) *LokiStackBuilder

WithLimits sets the lokiStack operator's limits configuration.

func (*LokiStackBuilder) WithManagementState

func (builder *LokiStackBuilder) WithManagementState(
	managementState lokiv1.ManagementStateType) *LokiStackBuilder

WithManagementState sets the lokiStack operator's rules configuration.

func (*LokiStackBuilder) WithRules

func (builder *LokiStackBuilder) WithRules(
	rules lokiv1.RulesSpec) *LokiStackBuilder

WithRules sets the lokiStack operator's rules configuration.

func (*LokiStackBuilder) WithSize

func (builder *LokiStackBuilder) WithSize(
	size lokiv1.LokiStackSizeType) *LokiStackBuilder

WithSize sets the lokiStack operator's size.

func (*LokiStackBuilder) WithStorage

func (builder *LokiStackBuilder) WithStorage(
	storage lokiv1.ObjectStorageSpec) *LokiStackBuilder

WithStorage sets the lokiStack operator's storage configuration.

func (*LokiStackBuilder) WithStorageClassName

func (builder *LokiStackBuilder) WithStorageClassName(
	storageClassName string) *LokiStackBuilder

WithStorageClassName sets the lokiStack operator's storage class name configuration.

func (*LokiStackBuilder) WithTemplate

func (builder *LokiStackBuilder) WithTemplate(
	template lokiv1.LokiTemplateSpec) *LokiStackBuilder

WithTemplate sets the lokiStack operator's template configuration.

func (*LokiStackBuilder) WithTenants

func (builder *LokiStackBuilder) WithTenants(
	tenants lokiv1.TenantsSpec) *LokiStackBuilder

WithTenants sets the lokiStack operator's tenants configuration.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL