resources

Documentation

Index

• func GetResources(ctx context.Context, client interfaces.Client, ...) ([]engine.Res, error)
• func SetResources(ctx context.Context, client interfaces.Client, hostname string, ...) error
• func WatchResources(ctx context.Context, client interfaces.Client) (chan error, error)

Functions

func GetResources

func GetResources(ctx context.Context, client interfaces.Client, hostnameFilter, kindFilter []string) ([]engine.Res, error)

GetResources collects all of the resources which match a filter from etcd. If the kindfilter or hostnameFilter is empty, then it assumes no filtering... TODO: Expand this with a more powerful filter based on what we eventually support in our collect DSL. Ideally a server side filter like WithFilter() could do this if the pattern was $NS/exported/$kind/$hostname/$uid = $data.

func SetResources

func SetResources(ctx context.Context, client interfaces.Client, hostname string, resourceList []engine.Res) error

SetResources exports all of the resources which we pass in to etcd.

func WatchResources

func WatchResources(ctx context.Context, client interfaces.Client) (chan error, error)

WatchResources returns a channel that outputs events when exported resources change. TODO: Filter our watch (on the server side if possible) based on the collection prefixes and filters that we care about...