syslogng

Documentation

Index

• Constants
• func RegisterWatches(builder *builder.Builder) *builder.Builder
• type ConfigCheckResult
• type DataProvider
  • func NewDataProvider(client client.Client, logging *v1beta1.Logging, ...) *DataProvider
  • func (p *DataProvider) GetReplicaCount(ctx context.Context) (*int32, error)
• type Desire
• type Reconciler
  • func New(client client.Client, log logr.Logger, logging *v1beta1.Logging, ...) *Reconciler
  • func (r *Reconciler) CheckForObjectExistence(ctx context.Context, object client.Object) (*ConfigCheckResult, error)
  • func (r *Reconciler) Reconcile(ctx context.Context) (*reconcile.Result, error)
  • func (r *Reconciler) SyslogNGObjectMeta(name, component string) metav1.ObjectMeta
  • func (r *Reconciler) SyslogNGObjectMetaClusterScope(name, component string) metav1.ObjectMeta

Constants

const (
	ComponentSyslogNG    = "syslog-ng"
	ComponentConfigCheck = "syslog-ng-configcheck"
	ComponentPlaceholder = "syslog-ng-placeholder"
)

const (
	ServiceName = "syslog-ng"
	ServicePort = 601

	StatefulSetName = "syslog-ng"

	OutputSecretPath = "/etc/syslog-ng/secret"
	BufferPath       = "/buffers"

	ContainerName = "syslog-ng"
)

Functions

func RegisterWatches

func RegisterWatches(builder *builder.Builder) *builder.Builder

Types

type ConfigCheckResult

type ConfigCheckResult struct {
	Valid   bool
	Ready   bool
	Message string
}

type DataProvider

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

func NewDataProvider

func NewDataProvider(client client.Client, logging *v1beta1.Logging, syslogNGSConfig *v1beta1.SyslogNGConfig) *DataProvider

func (*DataProvider) GetReplicaCount

func (p *DataProvider) GetReplicaCount(ctx context.Context) (*int32, error)

type Desire

type Desire struct {
	DesiredObject runtime.Object
	DesiredState  reconciler.DesiredState
	// BeforeUpdateHook has the ability to change the desired object
	// or even to change the desired state in case the object should be recreated
	BeforeUpdateHook func(runtime.Object) (reconciler.DesiredState, error)
}

type Reconciler

type Reconciler struct {
	Logging *v1beta1.Logging

	*reconciler.GenericResourceReconciler
	// contains filtered or unexported fields
}

Reconciler holds info what resource to reconcile

func New

func New(
	client client.Client,
	log logr.Logger,
	logging *v1beta1.Logging,
	syslogNGSPec *v1beta1.SyslogNGSpec,
	syslogNGCOnfig *v1beta1.SyslogNGConfig,
	config string,
	secrets *secret.MountSecrets,
	opts reconciler.ReconcilerOpts,
) *Reconciler

func (*Reconciler) CheckForObjectExistence

func (r *Reconciler) CheckForObjectExistence(ctx context.Context, object client.Object) (*ConfigCheckResult, error)

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context) (*reconcile.Result, error)

Reconcile reconciles the syslog-ng resource

func (*Reconciler) SyslogNGObjectMeta

func (r *Reconciler) SyslogNGObjectMeta(name, component string) metav1.ObjectMeta

SyslogNGObjectMeta creates an objectMeta for resource syslog-ng

func (*Reconciler) SyslogNGObjectMetaClusterScope

func (r *Reconciler) SyslogNGObjectMetaClusterScope(name, component string) metav1.ObjectMeta

SyslogNGObjectMetaClusterScope creates an objectMeta for resource syslog-ng