Documentation ¶
Overview ¶
Copyright 2019, 2021 The Multi-Cluster App Dispatcher Authors.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- func GetListOfPodResourcesFromOneGenericItem(awr *arbv1.AppWrapperGenericResource) (resource []*clusterstateapi.Resource, er error)
- func GetResources(awr *arbv1.AppWrapperGenericResource) (resource *clusterstateapi.Resource, er error)
- type GenericResources
- func (gr *GenericResources) Cleanup(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperGenericResource) (genericResourceName string, groupversionkind *schema.GroupVersionKind, ...)
- func (gr *GenericResources) IsItemCompleted(awgr *arbv1.AppWrapperGenericResource, namespace string, appwrapperName string, ...) (completed bool)
- func (gr *GenericResources) SyncQueueJob(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperGenericResource) (podList []*v1.Pod, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetListOfPodResourcesFromOneGenericItem ¶
func GetListOfPodResourcesFromOneGenericItem(awr *arbv1.AppWrapperGenericResource) (resource []*clusterstateapi.Resource, er error)
func GetResources ¶
func GetResources(awr *arbv1.AppWrapperGenericResource) (resource *clusterstateapi.Resource, er error)
Types ¶
type GenericResources ¶
type GenericResources struct {
// contains filtered or unexported fields
}
func NewAppWrapperGenericResource ¶
func NewAppWrapperGenericResource(config *rest.Config) *GenericResources
func (*GenericResources) Cleanup ¶
func (gr *GenericResources) Cleanup(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperGenericResource) (genericResourceName string, groupversionkind *schema.GroupVersionKind, erro error)
func (*GenericResources) IsItemCompleted ¶
func (gr *GenericResources) IsItemCompleted(awgr *arbv1.AppWrapperGenericResource, namespace string, appwrapperName string, genericItemName string) (completed bool)
returns status of an item present in etcd
func (*GenericResources) SyncQueueJob ¶
func (gr *GenericResources) SyncQueueJob(aw *arbv1.AppWrapper, awr *arbv1.AppWrapperGenericResource) (podList []*v1.Pod, err error)
SyncQueueJob uses dynamic clients to unwrap (spawn) items inside genericItems block, it is used to create resources inside etcd and return errors when unwrapping fails. More context here: https://github.com/project-codeflare/multi-cluster-app-dispatcher/issues/598