statefulset

Documentation

Overview

Package statefulset manipulates the k8s api of statefulset object

Index

• type Option
  • func WithCompleteParams(addr string, client *httpclient.HTTPClient) Option
• type StatefulSet
  • func New(options ...Option) *StatefulSet
  • func (sts *StatefulSet) Create(statefulset *appsv1.StatefulSet) error
  • func (sts *StatefulSet) Delete(namespace, name string) error
  • func (sts *StatefulSet) Get(namespace, name string) (*appsv1.StatefulSet, error)
  • func (sts *StatefulSet) LimitedListAllNamespace(limit int, cont *string) (*appsv1.StatefulSetList, *string, error)
  • func (sts *StatefulSet) List(namespace string) (appsv1.StatefulSetList, error)
  • func (sts *StatefulSet) Put(statefulset *appsv1.StatefulSet) error
  • func (sts *StatefulSet) WatchAllNamespace(ctx context.Context, addfunc, updatefunc, deletefunc func(*appsv1.StatefulSet)) error

Types

type Option

type Option func(*StatefulSet)

Option configures a StatefulSet

func WithCompleteParams

func WithCompleteParams(addr string, client *httpclient.HTTPClient) Option

WithCompleteParams provides an Option

type StatefulSet

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

StatefulSet is the object to manipulate k8s api of statefulset

func New

func New(options ...Option) *StatefulSet

New news a StatefulSet

func (*StatefulSet) Create

func (sts *StatefulSet) Create(statefulset *appsv1.StatefulSet) error

Create creates a k8s statefulset

func (*StatefulSet) Delete

func (sts *StatefulSet) Delete(namespace, name string) error

Delete deletes a k8s statefulset

func (*StatefulSet) Get

func (sts *StatefulSet) Get(namespace, name string) (*appsv1.StatefulSet, error)

Get gets a k8s statefulset

func (*StatefulSet) LimitedListAllNamespace

func (sts *StatefulSet) LimitedListAllNamespace(limit int, cont *string) (*appsv1.StatefulSetList, *string, error)

func (*StatefulSet) List

func (sts *StatefulSet) List(namespace string) (appsv1.StatefulSetList, error)

func (*StatefulSet) Put

func (sts *StatefulSet) Put(statefulset *appsv1.StatefulSet) error

Put updates a k8s statefulset

func (*StatefulSet) WatchAllNamespace

func (sts *StatefulSet) WatchAllNamespace(ctx context.Context,
	addfunc, updatefunc, deletefunc func(*appsv1.StatefulSet)) error