storage

package

v0.3.0 Latest Latest Go to latest Published: Jul 8, 2026 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Azure/adx-mon

Links

Documentation ¶

Index ¶

Constants
func ConvertToTypedList(objects []client.Object, list client.ObjectList) error
func FilterCompleted(obj client.Object) bool
func NewFunctions(client client.Client, elector scheduler.Elector) *functions
type CRDHandler
- func NewCRDHandler(client client.Client, elector scheduler.Elector) CRDHandler
type Functions
type ListFilterFunc

Constants ¶

View Source

const (
	// name of our custom finalizer
	FinalizerName = "function.adx-mon.azure.com/finalizer"
)

Variables ¶

This section is empty.

Functions ¶

func ConvertToTypedList ¶ added in v0.2.0

func ConvertToTypedList(objects []client.Object, list client.ObjectList) error

func FilterCompleted ¶ added in v0.2.0

func FilterCompleted(obj client.Object) bool

FilterCompleted will filter out objects that are completed, as determined by their Conditions being in a "True" state and the ObservedGeneration matching the current generation of the object.

func NewFunctions ¶

func NewFunctions(client client.Client, elector scheduler.Elector) *functions

Types ¶

type CRDHandler ¶ added in v0.2.0

type CRDHandler interface {
	List(ctx context.Context, list client.ObjectList, filters ...ListFilterFunc) error
	UpdateStatus(ctx context.Context, obj client.Object, errStatus error) error
	UpdateStatusWithKustoErrorParsing(ctx context.Context, obj client.Object, errStatus error) error
}

func NewCRDHandler ¶ added in v0.2.0

func NewCRDHandler(client client.Client, elector scheduler.Elector) CRDHandler

type Functions ¶

type Functions interface {
	UpdateStatus(ctx context.Context, fn *adxmonv1.Function) error
	Update(ctx context.Context, fn *adxmonv1.Function) error
	List(ctx context.Context) ([]*adxmonv1.Function, error)
	UpdateCondition(ctx context.Context, fn *adxmonv1.Function, condition metav1.Condition) error
}

type ListFilterFunc ¶ added in v0.2.0

type ListFilterFunc func(client.Object) bool

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL