dyntracker

Documentation

Index

• type DynamicAbsenceTracker
  • func NewDynamicAbsenceTracker(taskState *util.Concurrent[*statestore.AbsenceTaskState], ...) *DynamicAbsenceTracker
  • func (t *DynamicAbsenceTracker) Track(ctx context.Context) error
• type DynamicAbsenceTrackerOptions
• type DynamicPresenceTracker
  • func NewDynamicPresenceTracker(taskState *util.Concurrent[*statestore.PresenceTaskState], ...) *DynamicPresenceTracker
  • func (t *DynamicPresenceTracker) Track(ctx context.Context) error
• type DynamicPresenceTrackerOptions
• type DynamicReadinessTracker
  • func NewDynamicReadinessTracker(ctx context.Context, ...) (*DynamicReadinessTracker, error)
  • func (t *DynamicReadinessTracker) Track(ctx context.Context) error
• type DynamicReadinessTrackerOptions

Types

type DynamicAbsenceTracker

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

func NewDynamicAbsenceTracker

func NewDynamicAbsenceTracker(
	taskState *util.Concurrent[*statestore.AbsenceTaskState],
	dynamicClient dynamic.Interface,
	mapper meta.ResettableRESTMapper,
	opts DynamicAbsenceTrackerOptions,
) *DynamicAbsenceTracker

func (*DynamicAbsenceTracker) Track

func (t *DynamicAbsenceTracker) Track(ctx context.Context) error

type DynamicAbsenceTrackerOptions

type DynamicAbsenceTrackerOptions struct {
	Timeout    time.Duration
	PollPeriod time.Duration
}

type DynamicPresenceTracker

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

func NewDynamicPresenceTracker

func NewDynamicPresenceTracker(
	taskState *util.Concurrent[*statestore.PresenceTaskState],
	dynamicClient dynamic.Interface,
	mapper meta.ResettableRESTMapper,
	opts DynamicPresenceTrackerOptions,
) *DynamicPresenceTracker

func (*DynamicPresenceTracker) Track

func (t *DynamicPresenceTracker) Track(ctx context.Context) error

type DynamicPresenceTrackerOptions

type DynamicPresenceTrackerOptions struct {
	Timeout    time.Duration
	PollPeriod time.Duration
}

type DynamicReadinessTracker

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

func NewDynamicReadinessTracker

func NewDynamicReadinessTracker(
	ctx context.Context,
	taskState *util.Concurrent[*statestore.ReadinessTaskState],
	logStore *util.Concurrent[*logstore.LogStore],
	staticClient kubernetes.Interface,
	dynamicClient dynamic.Interface,
	discoveryClient discovery.CachedDiscoveryInterface,
	mapper meta.ResettableRESTMapper,
	opts DynamicReadinessTrackerOptions,
) (*DynamicReadinessTracker, error)

func (*DynamicReadinessTracker) Track

func (t *DynamicReadinessTracker) Track(ctx context.Context) error

type DynamicReadinessTrackerOptions

type DynamicReadinessTrackerOptions struct {
	Timeout                                  time.Duration
	NoActivityTimeout                        time.Duration
	IgnoreReadinessProbeFailsByContainerName map[string]time.Duration
	CaptureLogsFromTime                      time.Time
	SaveLogsOnlyForContainers                []string
	SaveLogsByRegex                          *regexp.Regexp
	SaveLogsByRegexForContainers             map[string]*regexp.Regexp
	IgnoreLogs                               bool
	IgnoreLogsForContainers                  []string
	SaveEvents                               bool
}