configuration

Documentation

Index

• func CheckHealthStatus(status []condition.Condition) bool
• func DeleteConfiguration(ctx context.Context, urls string, dynamicClient *dynamic.DynamicClient, ...) error
• func GetConfiguration(ctx context.Context, logger *zap.SugaredLogger, ...) ([]unstructured.Unstructured, error)
• func GetConfigurations(ctx context.Context, dynamicClient dynamic.Interface) []crossv1.Configuration
• func HealthCheck(ctx context.Context, dc dynamic.Interface, links string, wait bool, ...) error
• func MoveConfigurations(ctx context.Context, logger *zap.SugaredLogger, ...) error
• func ResourceId() schema.GroupVersionResource
• func Watch(ctx context.Context, dc *dynamic.DynamicClient, config *rest.Config, ...) error
• type Configuration
  • func New(name string) *Configuration
  • func (c *Configuration) Apply(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error
  • func (c *Configuration) LoadDirectory(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, ...) error
  • func (c *Configuration) LoadPathArchive(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, ...) error
  • func (c *Configuration) LoadStdinArchive(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, ...) error
  • func (c *Configuration) UpgradeConfiguration(ctx context.Context, config *rest.Config, dc *dynamic.DynamicClient) error

Functions

func CheckHealthStatus

func CheckHealthStatus(status []condition.Condition) bool

func DeleteConfiguration

func DeleteConfiguration(ctx context.Context, urls string, dynamicClient *dynamic.DynamicClient, logger *zap.SugaredLogger) error

func GetConfiguration

func GetConfiguration(ctx context.Context, logger *zap.SugaredLogger, sourceDynamicClient dynamic.Interface, paramsConfiguration kube.ResourceParams) ([]unstructured.Unstructured, error)

func GetConfigurations

func GetConfigurations(ctx context.Context, dynamicClient dynamic.Interface) []crossv1.Configuration

func HealthCheck

func HealthCheck(ctx context.Context, dc dynamic.Interface, links string, wait bool, timeoutChan <-chan time.Time, logger *zap.SugaredLogger) error

RunConfigurationHealthCheck performs a health check on configurations defined by the links string.

func MoveConfigurations

func MoveConfigurations(ctx context.Context, logger *zap.SugaredLogger, destClientset dynamic.Interface, configurations []unstructured.Unstructured, paramsConfiguration kube.ResourceParams) error

func ResourceId

func ResourceId() schema.GroupVersionResource

func Watch

func Watch(ctx context.Context, dc *dynamic.DynamicClient, config *rest.Config, logger *zap.SugaredLogger, path string) error

Types

type Configuration

type Configuration struct {
	Name  string
	Image regv1.Image
	packages.Package
}

func New

func New(name string) *Configuration

func (*Configuration) Apply

func (c *Configuration) Apply(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger) error

func (*Configuration) LoadDirectory

func (c *Configuration) LoadDirectory(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, path string) error

Load configuration package from directory

func (*Configuration) LoadPathArchive

func (c *Configuration) LoadPathArchive(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, path string) error

Load configuration package from path

func (*Configuration) LoadStdinArchive

func (c *Configuration) LoadStdinArchive(ctx context.Context, config *rest.Config, logger *zap.SugaredLogger, stream *bufio.Reader) error

Load configuration package from STDIN

func (*Configuration) UpgradeConfiguration

func (c *Configuration) UpgradeConfiguration(ctx context.Context, config *rest.Config, dc *dynamic.DynamicClient) error