logset

Documentation

Overview

Copyright 2024 Matrix Origin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2024 Matrix Origin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2024 Matrix Origin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Constants
• func HaKeeperAdds(ls *v1alpha1.LogSet) []string
• type Actor
  • func (r *Actor) Create(ctx *recon.Context[*v1alpha1.LogSet]) error
  • func (r *Actor) Finalize(ctx *recon.Context[*v1alpha1.LogSet]) (bool, error)
  • func (r *Actor) Observe(ctx *recon.Context[*v1alpha1.LogSet]) (recon.Action[*v1alpha1.LogSet], error)
  • func (r *Actor) Reconcile(mgr manager.Manager) error
• type WithResources
  • func (r *WithResources) Repair(ctx *recon.Context[*v1alpha1.LogSet]) error
  • func (r *WithResources) Scale(ctx *recon.Context[*v1alpha1.LogSet]) error
  • func (r *WithResources) Update(ctx *recon.Context[*v1alpha1.LogSet]) error

Constants

const (
	PodNameEnvKey     = "POD_NAME"
	HeadlessSvcEnvKey = "HEADLESS_SERVICE_NAME"
	NamespaceEnvKey   = "NAMESPACE"
	PodIPEnvKey       = "POD_IP"
)

Functions

func HaKeeperAdds

func HaKeeperAdds(ls *v1alpha1.LogSet) []string

Types

type Actor

type Actor struct {
	FailoverEnabled bool
}

func (*Actor) Create

func (r *Actor) Create(ctx *recon.Context[*v1alpha1.LogSet]) error

func (*Actor) Finalize

func (r *Actor) Finalize(ctx *recon.Context[*v1alpha1.LogSet]) (bool, error)

func (*Actor) Observe

func (r *Actor) Observe(ctx *recon.Context[*v1alpha1.LogSet]) (recon.Action[*v1alpha1.LogSet], error)

func (*Actor) Reconcile

func (r *Actor) Reconcile(mgr manager.Manager) error

type WithResources

type WithResources struct {
	*Actor
	// contains filtered or unexported fields
}

func (*WithResources) Repair

func (r *WithResources) Repair(ctx *recon.Context[*v1alpha1.LogSet]) error

Repair repairs failed log set pods to match the desired state

func (*WithResources) Scale

func (r *WithResources) Scale(ctx *recon.Context[*v1alpha1.LogSet]) error

Scale scale-out/in the log set pods to match the desired state TODO(aylei): special treatment for scale-in

func (*WithResources) Update

func (r *WithResources) Update(ctx *recon.Context[*v1alpha1.LogSet]) error

Update rolling-update the log set pods to match the desired state TODO(aylei): should logset controller take care of graceful rolling?