synchronize

Documentation

Index

• type BlockObject
  • func NewBlockObject(excludedBoms []types.NamespacedName, syncDisabled bool) *BlockObject
  • func (r *BlockObject) Block(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient, ...) (bool, time.Duration, error)
  • func (r *BlockObject) DeleteBlock(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient) error
  • func (r *BlockObject) Reblock(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient, ...) (bool, error)
  • func (r *BlockObject) Release(ctx context.Context, clusterbomKey *types.NamespacedName, ...)
• type UncachedClient
  • func NewUncachedClient(config *rest.Config, options client.Options) (UncachedClient, error)

Types

type BlockObject

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

func NewBlockObject

func NewBlockObject(excludedBoms []types.NamespacedName, syncDisabled bool) *BlockObject

func (*BlockObject) Block

func (r *BlockObject) Block(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient,
	duration time.Duration, ignoreExclusionList bool) (bool, time.Duration, error)

try to get block in case of an error returns (false, undefined, error) in case of successful getting the log return (true, undefined, nil) otherwise return (false, duration to wait until retry, nil)

func (*BlockObject) DeleteBlock

func (r *BlockObject) DeleteBlock(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient) error

func (*BlockObject) Reblock

func (r *BlockObject) Reblock(ctx context.Context, clusterbomKey *types.NamespacedName, clt UncachedClient, duration time.Duration, ignoreExclusionList bool) (bool, error)

func (*BlockObject) Release

func (r *BlockObject) Release(ctx context.Context, clusterbomKey *types.NamespacedName, ignoreExclusionList bool)

type UncachedClient

type UncachedClient interface {
	GetUncached(ctx context.Context, key types.NamespacedName, obj client.Object) error
	ListUncached(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
	Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
	Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
	Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
}

func NewUncachedClient

func NewUncachedClient(config *rest.Config, options client.Options) (UncachedClient, error)