Documentation
¶
Index ¶
- func GetCoolOff(ctx context.Context) time.Duration
- func SetCoolOff(ctx context.Context, coolOff time.Duration) context.Context
- func WorkloadKindFrombject(obj metav1.Object) k8sconsts.WorkloadKind
- type BaseTransition
- type InstrumentationEnded
- type InstrumentationStarted
- type Orchestrator
- type PostCheck
- type PreflightCheck
- type RequestLangDetection
- type State
- type Transition
- type WaitForLangDetection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WorkloadKindFrombject ¶
func WorkloadKindFrombject(obj metav1.Object) k8sconsts.WorkloadKind
Types ¶
type BaseTransition ¶
type BaseTransition struct {
// contains filtered or unexported fields
}
type InstrumentationEnded ¶
type InstrumentationEnded struct {
BaseTransition
}
func (*InstrumentationEnded) From ¶
func (i *InstrumentationEnded) From() State
func (*InstrumentationEnded) GetTransitionState ¶
func (*InstrumentationEnded) To ¶
func (i *InstrumentationEnded) To() State
type InstrumentationStarted ¶
type InstrumentationStarted struct {
BaseTransition
}
func (*InstrumentationStarted) From ¶
func (i *InstrumentationStarted) From() State
func (*InstrumentationStarted) GetTransitionState ¶
func (*InstrumentationStarted) To ¶
func (i *InstrumentationStarted) To() State
type Orchestrator ¶
type Orchestrator struct {
Client *kube.Client
OdigosNamespace string
TransitionsMap map[State]Transition
Remote bool
}
func NewOrchestrator ¶
type PostCheck ¶
type PostCheck struct {
BaseTransition
}
func (*PostCheck) GetTransitionState ¶
type PreflightCheck ¶
type PreflightCheck struct {
BaseTransition
}
func (*PreflightCheck) From ¶
func (p *PreflightCheck) From() State
func (*PreflightCheck) GetTransitionState ¶
func (*PreflightCheck) To ¶
func (p *PreflightCheck) To() State
type RequestLangDetection ¶
type RequestLangDetection struct {
BaseTransition
}
func (*RequestLangDetection) From ¶
func (r *RequestLangDetection) From() State
func (*RequestLangDetection) GetTransitionState ¶
func (*RequestLangDetection) To ¶
func (r *RequestLangDetection) To() State
type State ¶
type State int
const ( // Unknown is an error state. StateUnknown State = iota // NoSourceCreated is the initial state before instrumentation starts. StateNoSourceCreated // PreflightChecksPassed indicates the workload is healthy and can be instrumented. StatePreflightChecksPassed // SourceCreated indicates the Source object has been created for the workload and language detection is in progress. StateSourceCreated // LangDetected indicates the language detection has completed and the workload is eligible for instrumentation. StateLangDetected // InstrumentationInProgress indicates the instrumentation is in progress, but the pods are not yet running. StateInstrumentationInProgress // Instrumented indicates the instrumentation has completed and the workload is instrumented. StateInstrumented // PostCheckPassed indicates all pods in the workload are healthy and the post check has completed and the workload is ready for use. StatePostCheckPassed )
type Transition ¶
type WaitForLangDetection ¶
type WaitForLangDetection struct {
BaseTransition
}
func (*WaitForLangDetection) From ¶
func (w *WaitForLangDetection) From() State
func (*WaitForLangDetection) GetTransitionState ¶
func (*WaitForLangDetection) To ¶
func (w *WaitForLangDetection) To() State
Source Files
Click to show internal directories.
Click to hide internal directories.