Documentation ¶
Index ¶
- Variables
- type Group
- type Resource
- func (r *Resource) CheckStatus(ctx context.Context, cfg kubectl.Config)
- func (r *Resource) Deadline() time.Duration
- func (r *Resource) HasEncounteredUnrecoverableError() bool
- func (r *Resource) ID() string
- func (r *Resource) IsStatusCheckCompleteOrCancelled() bool
- func (r *Resource) MarkComplete()
- func (r *Resource) Name() string
- func (r *Resource) ReportSinceLastUpdated(isMuted bool) string
- func (r *Resource) Status() Status
- func (r *Resource) StatusCode() proto.StatusCode
- func (r *Resource) StatusMessage() string
- func (r *Resource) String() string
- func (r *Resource) UpdateStatus(ae *proto.ActionableErr)
- func (r *Resource) WithPodStatuses(scs []proto.StatusCode) *Resource
- func (r *Resource) WithValidator(pd diag.Diagnose) *Resource
- type Status
- type Type
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MsgKubectlConnection = "kubectl connection error\n" ResourceTypes = struct { StandalonePods Type Deployment Type StatefulSet Type ConfigConnector Type CustomResource Type }{ StandalonePods: "standalone-pods", Deployment: "deployment", StatefulSet: "statefulset", ConfigConnector: "config-connector-resource", CustomResource: "custom-resource", } )
Functions ¶
This section is empty.
Types ¶
type Resource ¶
type Resource struct {
// contains filtered or unexported fields
}
func NewResource ¶
func (*Resource) CheckStatus ¶
func (*Resource) HasEncounteredUnrecoverableError ¶
HasEncounteredUnrecoverableError goes through all pod statuses and return true if any cannot be recovered
func (*Resource) IsStatusCheckCompleteOrCancelled ¶
func (*Resource) MarkComplete ¶
func (r *Resource) MarkComplete()
func (*Resource) ReportSinceLastUpdated ¶
func (*Resource) StatusCode ¶
func (r *Resource) StatusCode() proto.StatusCode
StatusCode returns the rollout status code if the status check is cancelled or if no pod data exists for this rollout. If pods are fetched, this function returns the error code a pod container encountered.
func (*Resource) StatusMessage ¶
func (*Resource) UpdateStatus ¶
func (r *Resource) UpdateStatus(ae *proto.ActionableErr)
func (*Resource) WithPodStatuses ¶
type Status ¶
type Status struct {
// contains filtered or unexported fields
}
func (Status) ActionableError ¶
func (rs Status) ActionableError() *proto.ActionableErr
Click to show internal directories.
Click to hide internal directories.