client

Documentation

Index

• type ResourceClient
  • func NewResourceClient(config *rest.Config) (*ResourceClient, error)
  • func (rc *ResourceClient) AutoWatchByRef(refs []*common.ResourceRef, timeout time.Duration) ([]*WatchResult, error)
  • func (rc *ResourceClient) Create(resources []*unstructured.Unstructured, numCopies int) ([]*common.ResourceRef, error)
• type WatchResult

Types

type ResourceClient

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

ResourceClient interacts with the cluster and performs resource operations

func NewResourceClient

func NewResourceClient(config *rest.Config) (*ResourceClient, error)

NewResourceClient creates a new ResourceClient

func (*ResourceClient) AutoWatchByRef

func (rc *ResourceClient) AutoWatchByRef(refs []*common.ResourceRef, timeout time.Duration) ([]*WatchResult, error)

AutoWatchByRef automatically watches a list of resources identified by ResourceRef. Only supported types of resources are watched, others are ignored.

func (*ResourceClient) Create

func (rc *ResourceClient) Create(resources []*unstructured.Unstructured, numCopies int) ([]*common.ResourceRef, error)

Create creates a list of resources to k8s cluster

type WatchResult

type WatchResult struct {
	ResourceRef *common.ResourceRef               `json:"resourceRef"`
	Status      condition.ResourceConditionStatus `json:"status"`
	Error       error                             `json:"-"`
}

WatchResult is the result of auto-watch