skrresources

Documentation

Index

• Variables
• func HasDiff(oldResources []shared.Resource, newResources []shared.Resource) bool
• func SyncResources(ctx context.Context, skrClient client.Client, manifest *v1beta2.Manifest, ...) error
• type ConcurrentDefaultSSA
  • func ConcurrentSSA(clnt client.Client, owner client.FieldOwner) *ConcurrentDefaultSSA
  • func (c *ConcurrentDefaultSSA) Run(ctx context.Context, resources []*resource.Info) error
• type DefaultInfoToResourceConverter
  • func NewInfoToResourceConverter() *DefaultInfoToResourceConverter
  • func (c *DefaultInfoToResourceConverter) InfosToResources(infos []*resource.Info) []shared.Resource
• type DefaultResourceToInfoConverter
  • func NewResourceToInfoConverter(converter ResourceInfoConverter, defaultNamespace string) *DefaultResourceToInfoConverter
  • func (c *DefaultResourceToInfoConverter) ResourcesToInfos(resources []shared.Resource) ([]*resource.Info, error)
  • func (c *DefaultResourceToInfoConverter) UnstructuredToInfos(resources []*unstructured.Unstructured) ([]*resource.Info, error)
• type InfoToResourceConverter
• type ResourceInfoConverter
• type ResourceToInfoConverter
• type SSA

Variables

var (
	ErrClientObjectConversionFailed = errors.New("client object conversion failed")
	ErrServerSideApplyFailed        = errors.New("ServerSideApply failed")
	ErrClientUnauthorized           = errors.New("ServerSideApply is unauthorized")
)

var ErrWarningResourceSyncStateDiff = errors.New("resource syncTarget state diff detected")

Functions

func HasDiff

func HasDiff(oldResources []shared.Resource, newResources []shared.Resource) bool

func SyncResources

func SyncResources(ctx context.Context, skrClient client.Client, manifest *v1beta2.Manifest,
	target []*resource.Info,
) error

Types

type ConcurrentDefaultSSA

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

func ConcurrentSSA

func ConcurrentSSA(clnt client.Client, owner client.FieldOwner) *ConcurrentDefaultSSA

func (*ConcurrentDefaultSSA) Run

func (c *ConcurrentDefaultSSA) Run(ctx context.Context, resources []*resource.Info) error

type DefaultInfoToResourceConverter

type DefaultInfoToResourceConverter struct{}

func NewInfoToResourceConverter

func NewInfoToResourceConverter() *DefaultInfoToResourceConverter

func (*DefaultInfoToResourceConverter) InfosToResources

func (c *DefaultInfoToResourceConverter) InfosToResources(infos []*resource.Info) []shared.Resource

type DefaultResourceToInfoConverter

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

func NewResourceToInfoConverter

func NewResourceToInfoConverter(
	converter ResourceInfoConverter, defaultNamespace string,
) *DefaultResourceToInfoConverter

func (*DefaultResourceToInfoConverter) ResourcesToInfos

func (c *DefaultResourceToInfoConverter) ResourcesToInfos(resources []shared.Resource) ([]*resource.Info, error)

func (*DefaultResourceToInfoConverter) UnstructuredToInfos

func (c *DefaultResourceToInfoConverter) UnstructuredToInfos(
	resources []*unstructured.Unstructured,
) ([]*resource.Info, error)

type InfoToResourceConverter

type InfoToResourceConverter interface {
	InfosToResources(resourceInfo []*resource.Info) []shared.Resource
}

type ResourceInfoConverter

type ResourceInfoConverter interface {
	ResourceInfo(obj *unstructured.Unstructured, retryOnNoMatch bool) (*resource.Info, error)
}

type ResourceToInfoConverter

type ResourceToInfoConverter interface {
	ResourcesToInfos(resource []shared.Resource) ([]*resource.Info, error)
	UnstructuredToInfos(obj []*unstructured.Unstructured) ([]*resource.Info, error)
}

type SSA

type SSA interface {
	Run(ctx context.Context, resourceInfo []*resource.Info) error
}