deploy

Documentation

Index

• Constants
• type ResourcesWaiter
  • func NewResourcesWaiter(client *helm_kube.Client, logsFromTime time.Time, ...) *ResourcesWaiter
  • func (waiter *ResourcesWaiter) Wait(ctx context.Context, resources helm_kube.ResourceList, timeout time.Duration) error
  • func (waiter *ResourcesWaiter) WaitUntilDeleted(ctx context.Context, specs []*helm_kube.ResourcesWaiterDeleteResourceSpec, ...) error
  • func (waiter *ResourcesWaiter) WatchUntilReady(ctx context.Context, resources helm_kube.ResourceList, timeout time.Duration) error
• type StagesSplitter
  • func NewStagesSplitter() *StagesSplitter
  • func (s *StagesSplitter) Split(resources kube.ResourceList) (stages.SortedStageList, error)

Constants

const (
	TrackTerminationModeAnnoName = "werf.io/track-termination-mode"

	FailModeAnnoName                  = "werf.io/fail-mode"
	FailuresAllowedPerReplicaAnnoName = "werf.io/failures-allowed-per-replica"

	LogRegexAnnoName      = "werf.io/log-regex"
	LogRegexForAnnoPrefix = "werf.io/log-regex-for-"

	IgnoreReadinessProbeFailsForPrefix = "werf.io/ignore-readiness-probe-fails-for-"

	NoActivityTimeoutName = "werf.io/no-activity-timeout"

	SkipLogsAnnoName              = "werf.io/skip-logs"
	SkipLogsForContainersAnnoName = "werf.io/skip-logs-for-containers"
	ShowLogsOnlyForContainers     = "werf.io/show-logs-only-for-containers"
	ShowLogsUntilAnnoName         = "werf.io/show-logs-until"

	ShowEventsAnnoName = "werf.io/show-service-messages"

	ReplicasOnCreationAnnoName = "werf.io/replicas-on-creation"

	StageWeightAnnoName = "werf.io/weight"

	ExternalDependencyResourceAnnoName  = "external-dependency.werf.io/resource"
	ExternalDependencyNamespaceAnnoName = "external-dependency.werf.io/namespace"
)

Types

type ResourcesWaiter

type ResourcesWaiter struct {
	Client                    *helm_kube.Client
	LogsFromTime              time.Time
	StatusProgressPeriod      time.Duration
	HooksStatusProgressPeriod time.Duration
}

func NewResourcesWaiter

func NewResourcesWaiter(client *helm_kube.Client, logsFromTime time.Time, statusProgressPeriod, hooksStatusProgressPeriod time.Duration) *ResourcesWaiter

func (*ResourcesWaiter) Wait

func (waiter *ResourcesWaiter) Wait(ctx context.Context, resources helm_kube.ResourceList, timeout time.Duration) error

func (*ResourcesWaiter) WaitUntilDeleted

func (waiter *ResourcesWaiter) WaitUntilDeleted(ctx context.Context, specs []*helm_kube.ResourcesWaiterDeleteResourceSpec, timeout time.Duration) error

func (*ResourcesWaiter) WatchUntilReady

func (waiter *ResourcesWaiter) WatchUntilReady(ctx context.Context, resources helm_kube.ResourceList, timeout time.Duration) error

type StagesSplitter

type StagesSplitter struct{}

func NewStagesSplitter

func NewStagesSplitter() *StagesSplitter

func (*StagesSplitter) Split

func (s *StagesSplitter) Split(resources kube.ResourceList) (stages.SortedStageList, error)