Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
Source Files
Click to show internal directories.
Click to hide internal directories.