rollout

Documentation

Index

• Variables
• type Config
• type CreateIfNotExistObjectAction
  • func (a *CreateIfNotExistObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, ...) error
  • func (a *CreateIfNotExistObjectAction) Name() string
• type CreateOrUpdateObjectAction
  • func (a *CreateOrUpdateObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, ...) error
  • func (a *CreateOrUpdateObjectAction) Name() string
• type DeleteIfExistsObjectAction
  • func (a *DeleteIfExistsObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, ...) error
  • func (a *DeleteIfExistsObjectAction) Name() string
• type ObjectAction
• type Renderer
• type Runner
  • func NewRunner(r prometheus.Registerer, logger log.Logger, client *client.Client, ...) *Runner
  • func (r *Runner) Execute(ctx context.Context, rolloutConfig *Config) (err error)
  • func (r *Runner) SetObjectActions(actions []ObjectAction)

Variables

var (
	DefaultObjectActions = []ObjectAction{
		&CreateOrUpdateObjectAction{},
		&CreateIfNotExistObjectAction{},
		&DeleteIfExistsObjectAction{},
	}
)

Types

type Config

type Config struct {
	RawConfig []byte
	Feedback  feedback.Feedback
}

type CreateIfNotExistObjectAction

type CreateIfNotExistObjectAction struct{}

func (*CreateIfNotExistObjectAction) Execute

func (a *CreateIfNotExistObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, unstructured *unstructured.Unstructured) error

func (*CreateIfNotExistObjectAction) Name

func (a *CreateIfNotExistObjectAction) Name() string

type CreateOrUpdateObjectAction

type CreateOrUpdateObjectAction struct{}

func (*CreateOrUpdateObjectAction) Execute

func (a *CreateOrUpdateObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, unstructured *unstructured.Unstructured) error

func (*CreateOrUpdateObjectAction) Name

func (a *CreateOrUpdateObjectAction) Name() string

type DeleteIfExistsObjectAction

type DeleteIfExistsObjectAction struct{}

func (*DeleteIfExistsObjectAction) Execute

func (a *DeleteIfExistsObjectAction) Execute(ctx context.Context, rc *client.ResourceClient, unstructured *unstructured.Unstructured) error

func (*DeleteIfExistsObjectAction) Name

func (a *DeleteIfExistsObjectAction) Name() string

type ObjectAction

type ObjectAction interface {
	Execute(context.Context, *client.ResourceClient, *unstructured.Unstructured) error
	Name() string
}

type Renderer

type Renderer interface {
	Render(ctx context.Context, config []byte) (*render.Result, error)
}

type Runner

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

func NewRunner

func NewRunner(r prometheus.Registerer, logger log.Logger, client *client.Client, renderer Renderer, checks *checks.Checks, renderOnly bool) *Runner

func (*Runner) Execute

func (r *Runner) Execute(ctx context.Context, rolloutConfig *Config) (err error)

func (*Runner) SetObjectActions

func (r *Runner) SetObjectActions(actions []ObjectAction)