datacollection

Documentation

Index

• Variables
• func Sync(ctx context.Context, c client.Client, scheme *runtime.Scheme, ...) error
• func SyncConfigMap(apps *odigosv1.InstrumentedApplicationList, dests *odigosv1.DestinationList, ...) error
• type DelayManager
  • func (dm *DelayManager) RunSyncDaemonSetWithDelayAndSkipNewCalls(delay time.Duration, retries int, dests *odigosv1.DestinationList, ...)

Variables

var (
	NodeCollectorsLabels = map[string]string{
		consts.OdigosCollectorRoleLabel: string(consts.CollectorsRoleNodeCollector),
	}
)

Functions

func Sync

func Sync(ctx context.Context, c client.Client, scheme *runtime.Scheme, imagePullSecrets []string, odigosVersion string, k8sVersion *version.Version, disableNameProcessor bool) error

func SyncConfigMap

func SyncConfigMap(apps *odigosv1.InstrumentedApplicationList, dests *odigosv1.DestinationList, allProcessors *odigosv1.ProcessorList,
	datacollection *odigosv1.CollectorsGroup, ctx context.Context,
	c client.Client, scheme *runtime.Scheme, disableNameProcessor bool) error

Types

type DelayManager

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

func (*DelayManager) RunSyncDaemonSetWithDelayAndSkipNewCalls

func (dm *DelayManager) RunSyncDaemonSetWithDelayAndSkipNewCalls(delay time.Duration, retries int, dests *odigosv1.DestinationList,
	collection *odigosv1.CollectorsGroup, ctx context.Context, c client.Client, scheme *runtime.Scheme, secrets []string, version string, k8sVersion *version.Version)

RunSyncDaemonSetWithDelayAndSkipNewCalls runs the function with the specified delay and skips new calls until the function execution is finished