Documentation ¶
Index ¶
- type Builder
- func (builder *Builder) Create() (*Builder, error)
- func (builder *Builder) Delete() error
- func (builder *Builder) Exists() bool
- func (builder *Builder) Get() (*clov1.ClusterLogging, error)
- func (builder *Builder) IsReady(timeout time.Duration) bool
- func (builder *Builder) Update(force bool) (*Builder, error)
- func (builder *Builder) WithCollection(collection clov1.CollectionSpec) *Builder
- func (builder *Builder) WithLogStore(logStore clov1.LogStoreSpec) *Builder
- func (builder *Builder) WithManagementState(managementState clov1.ManagementState) *Builder
- func (builder *Builder) WithVisualization(visualization clov1.VisualizationSpec) *Builder
- type ClusterLogForwarderBuilder
- func (builder *ClusterLogForwarderBuilder) Create() (*ClusterLogForwarderBuilder, error)
- func (builder *ClusterLogForwarderBuilder) Delete() error
- func (builder *ClusterLogForwarderBuilder) Exists() bool
- func (builder *ClusterLogForwarderBuilder) Get() (*clov1.ClusterLogForwarder, error)
- func (builder *ClusterLogForwarderBuilder) Update(force bool) (*ClusterLogForwarderBuilder, error)
- func (builder *ClusterLogForwarderBuilder) WithOutput(outputSpec *clov1.OutputSpec) *ClusterLogForwarderBuilder
- func (builder *ClusterLogForwarderBuilder) WithPipeline(pipelineSpec *clov1.PipelineSpec) *ClusterLogForwarderBuilder
- type ElasticsearchBuilder
- func (builder *ElasticsearchBuilder) Create() (*ElasticsearchBuilder, error)
- func (builder *ElasticsearchBuilder) Delete() error
- func (builder *ElasticsearchBuilder) Exists() bool
- func (builder *ElasticsearchBuilder) Get() (*eskv1.Elasticsearch, error)
- func (builder *ElasticsearchBuilder) GetManagementState() (*eskv1.ManagementState, error)
- func (builder *ElasticsearchBuilder) Update() (*ElasticsearchBuilder, error)
- func (builder *ElasticsearchBuilder) WithManagementState(expectedManagementState eskv1.ManagementState) *ElasticsearchBuilder
- type LokiStackBuilder
- func (builder *LokiStackBuilder) Create() (*LokiStackBuilder, error)
- func (builder *LokiStackBuilder) Delete() (*LokiStackBuilder, error)
- func (builder *LokiStackBuilder) Exists() bool
- func (builder *LokiStackBuilder) Get() (*lokiv1.LokiStack, error)
- func (builder *LokiStackBuilder) IsReady(timeout time.Duration) bool
- func (builder *LokiStackBuilder) Update() (*LokiStackBuilder, error)
- func (builder *LokiStackBuilder) WithLimits(limits lokiv1.LimitsSpec) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithManagementState(managementState lokiv1.ManagementStateType) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithRules(rules lokiv1.RulesSpec) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithSize(size lokiv1.LokiStackSizeType) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithStorage(storage lokiv1.ObjectStorageSpec) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithStorageClassName(storageClassName string) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithTemplate(template lokiv1.LokiTemplateSpec) *LokiStackBuilder
- func (builder *LokiStackBuilder) WithTenants(tenants lokiv1.TenantsSpec) *LokiStackBuilder
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 ¶
NewBuilder method creates new instance of builder.
func (*Builder) Create ¶
Create makes a clusterLogging in the cluster and stores the created object in struct.
func (*Builder) Get ¶
func (builder *Builder) Get() (*clov1.ClusterLogging, error)
Get returns clusterLogging object if found.
func (*Builder) IsReady ¶
IsReady checks for the duration of timeout if the clusterLogging instance state is Ready.
func (*Builder) Update ¶
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 ¶
func (builder *ClusterLogForwarderBuilder) Create() (*ClusterLogForwarderBuilder, error)
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 ¶
func (builder *ClusterLogForwarderBuilder) Get() (*clov1.ClusterLogForwarder, error)
Get returns clusterlogforwarder object if found.
func (*ClusterLogForwarderBuilder) Update ¶
func (builder *ClusterLogForwarderBuilder) Update(force bool) (*ClusterLogForwarderBuilder, error)
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.