k8s

package

Go to main page

Versions in this module

v0

v0.1.3

Jul 30, 2021

Changes in this version

+ const PodPhaseFailed

+ const PodPhasePending

+ const PodPhaseRunning

+ const PodPhaseSucceeded

+ func DecodeClusterSpec(item *Item) (*any.Any, error)

+ func DecodeItem(item *Item) (*any.Any, error)

+ func DecodeResourceSpec(item *Item) (*any.Any, error)

+ type APIGroup struct

+ Name string

+ type APIGroupList struct

+ Groups []*APIGroup

+ type APIResource struct

+ Name string

+ type APIResourceList struct

+ Resources []*APIResource

+ type Event struct

+ Metadata *Metadata

+ Note string

+ Reason string

+ Regarding *EventRegarding

+ Type string

+ func (e *Event) GetMetadata() *Metadata

+ type EventRegarding struct

+ Kind string

type Item

+ func (i *Item) Name() string

+ func (i *Item) ResourceVersion() string

type KubeClient

+ func (c *KubeClient) GetFull(url string, out interface{}) ([]byte, error)

+ func (c *KubeClient) Watch(path string) (*http.Response, error)

+ type PodItem struct

+ Metadata *Metadata

+ Status struct{ ... }

+ func (i *PodItem) Name() string

+ func (p *PodItem) ExitResult() (*proto.Instance_ExitResult, error)

+ func (p *PodItem) ResourceVersion() string

type Provider

+ func (p *Provider) Name() string

+ func (p *Provider) Resources() operator.ProviderResources

+ type WatchEntry struct

type WatchEvent

+ Raw []byte

type Watcher

+ func NewWatcher(logger hclog.Logger, client *KubeClient, path string, obj itemObj) (*Watcher, error)

+ func (w *Watcher) ForEach(handler func(task *WatchEntry, i interface{}))

+ func (w *Watcher) Get(path string) (*listResponse, error)

+ func (w *Watcher) IsClosed() bool

+ func (w *Watcher) Run(stopCh chan struct{})

+ func (w *Watcher) WithLimit(l int) *Watcher

+ func (w *Watcher) WithList(list bool) *Watcher

v0.1.2

Feb 8, 2021

Changes in this version

type Provider

+ func (p *Provider) WatchUpdates() chan *operator.NodeUpdate

v0.1.1

Jan 25, 2021

Changes in this version

+ type WatchEvent struct

+ Object *Item

+ Type string

+ type Watcher struct

+ func (w *Watcher) Start()

v0.1.0

Dec 9, 2020

Changes in this version

+ func Asset(name string) ([]byte, error)

+ func AssetDir(name string) ([]string, error)

+ func AssetInfo(name string) (os.FileInfo, error)

+ func AssetNames() []string

+ func GetDefaultKubeConfigPath() (string, error)

+ func InCluster() bool

+ func MarshalCRD(c *Crd) ([]byte, error)

+ func MarshalPod(p *Pod) ([]byte, error)

+ func MustAsset(name string) []byte

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

+ func RunTmpl(tmpl string, obj interface{}) ([]byte, error)

+ func RunTmpl2(name string, obj interface{}) ([]byte, error)

+ type Config struct

+ BearerToken string

+ Host string

+ TLSConfig *tls.Config

+ func GetConfig() (*Config, error)

+ func InClusterConfig() (*Config, error)

+ type Crd struct

+ Group string

+ Kind string

+ Plural string

+ Schema *schema.Schema

+ Singular string

+ SpecStr string

+ type Item struct

+ Data map[string]interface{}

+ Kind string

+ Metadata *Metadata

+ Spec map[string]interface{}

+ Status map[string]interface{}

+ type KubeClient struct

+ func NewKubeClient(config *Config) *KubeClient

+ func (c *KubeClient) Delete(path string, obj []byte) ([]byte, error)

+ func (c *KubeClient) Exec(pod, container string, path string, cmdArgs ...string) ([]byte, error)

+ func (c *KubeClient) Get(path string) ([]byte, error)

+ func (c *KubeClient) HTTPReq(method string, path string, obj []byte) ([]byte, error)

+ func (c *KubeClient) HTTPReqWithResponse(method string, path string, obj []byte) (*http.Response, error)

+ func (c *KubeClient) List(path string, opts *ListOpts) (*ListResponse, error)

+ func (c *KubeClient) Post(path string, obj []byte) ([]byte, error)

+ func (c *KubeClient) Put(path string, obj []byte) ([]byte, error)

+ func (c *KubeClient) Track(ctx context.Context, path string) (chan *Item, chan struct{})

+ type KubeConfig struct

+ CAFile string

+ CertFile string

+ Host string

+ KeyFile string

+ func NewKubeConfig(path string, context string) (*KubeConfig, error)

+ func (k *KubeConfig) GetTLSConfig() (*tls.Config, error)

+ func (k *KubeConfig) ToConfig() (*Config, error)

+ type ListMetadata struct

+ Continue string

+ ResourceVersion string

+ type ListOpts struct

+ Continue string

+ Limit int

+ type ListResponse struct

+ Items []*Item

+ Metadata ListMetadata

+ type Metadata struct

+ Annotations map[string]string

+ Generation int

+ Labels map[string]string

+ Name string

+ ResourceVersion string

+ SelfLink string

+ UID string

+ type Pod struct

+ Builder *proto.NodeSpec

+ Ensemble string

+ Name string

+ type Provider struct

+ func K8sFactory(logger hclog.Logger, c map[string]interface{}) (*Provider, error)

+ func (p *Provider) CreateResource(node *proto.Node) (*proto.Node, error)

+ func (p *Provider) DeleteResource(node *proto.Node) (*proto.Node, error)

+ func (p *Provider) Exec(handler string, path string, cmdArgs ...string) error

+ func (p *Provider) FinalizeTask(uuid string) error

+ func (p *Provider) GetTask() (*proto.Task, error)

+ func (p *Provider) LoadCluster(name string) (*proto.Cluster, error)

+ func (p *Provider) Setup() error

+ func (p *Provider) Start() error

+ func (p *Provider) Stop()

+ func (p *Provider) UpdateNodeStatus(node *proto.Node) (*proto.Node, error)

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