k8sapi

Aug 25, 2022

Changes in this version

+ func RecordWorkloadInfo(span trace.Span, wl Workload)

May 17, 2022

Changes in this version

+ type UnsupportedWorkloadKindError string

+ func (u UnsupportedWorkloadKindError) Error() string

May 13, 2022

Changes in this version

type Object

+ Selector func() (labels.Selector, error)

+ type StateListener struct

+ Cb func()

+ type Watcher struct

+ func NewWatcher(resource, namespace string, getter cache.Getter, objType runtime.Object, ...) *Watcher

+ func (w *Watcher) Active() bool

+ func (w *Watcher) AddStateListener(l *StateListener)

+ func (w *Watcher) Cancel()

+ func (w *Watcher) EnsureStarted(c context.Context, cb func(bool))

+ func (w *Watcher) Get(c context.Context, obj interface{}) (interface{}, bool, error)

+ func (w *Watcher) HasSynced() bool

+ func (w *Watcher) List(c context.Context) []interface{}

+ func (w *Watcher) RemoveStateListener(rl *StateListener)

+ func (w *Watcher) Watch(c context.Context, ready *sync.WaitGroup)

Feb 19, 2022

Changes in this version

+ func DeploymentImpl(o Object) (*apps.Deployment, bool)

+ func GetAppProto(ctx context.Context, aps AppProtocolStrategy, p *core.ServicePort) string

+ func GetClusterID(ctx context.Context) (clusterID string, err error)

+ func GetK8sInterface(ctx context.Context) kubernetes.Interface

+ func GetPort(cn *core.Container, portName string) (*core.ContainerPort, error)

+ func ObjErrorf(o Object, format string, args ...interface{}) error

+ func PodImpl(o Object) (*core.Pod, bool)

+ func ReplicaSetImpl(o Object) (*apps.ReplicaSet, bool)

+ func ServiceImpl(o Object) (*core.Service, bool)

+ func StatefulSetImpl(o Object) (*apps.StatefulSet, bool)

+ func WithK8sInterface(ctx context.Context, ki kubernetes.Interface) context.Context

+ type AppProtocolStrategy int

+ const Http

+ const Http2

+ const Http2Probe

+ const PortName

+ func NewAppProtocolStrategy(s string) (AppProtocolStrategy, error)

+ func (aps *AppProtocolStrategy) EnvDecode(val string) (err error)

+ func (aps *AppProtocolStrategy) UnmarshalYAML(node *yaml.Node) (err error)

+ func (aps AppProtocolStrategy) MarshalYAML() (interface{}, error)

+ func (aps AppProtocolStrategy) String() string

+ type Object interface

+ Delete func(context.Context) error

+ GetAnnotations func() map[string]string

+ GetKind func() string

+ Patch func(context.Context, types.PatchType, []byte, ...string) error

+ Refresh func(context.Context) error

+ Update func(context.Context) error

+ func GetPod(c context.Context, name, namespace string) (Object, error)

+ func GetService(c context.Context, name, namespace string) (Object, error)

+ func Pod(d *core.Pod) Object

+ func Pods(c context.Context, namespace string) ([]Object, error)

+ func Service(d *core.Service) Object

+ func Services(c context.Context, namespace string) ([]Object, error)

+ type Workload interface

+ GetPodTemplate func() *core.PodTemplateSpec

+ Replicas func() int

+ Updated func(int64) bool

+ func Deployment(d *apps.Deployment) Workload

+ func Deployments(c context.Context, namespace string, labelSelector labels.Set) ([]Workload, error)

+ func GetDeployment(c context.Context, name, namespace string) (Workload, error)

+ func GetReplicaSet(c context.Context, name, namespace string) (Workload, error)

+ func GetStatefulSet(c context.Context, name, namespace string) (Workload, error)

+ func GetWorkload(c context.Context, name, namespace, workloadKind string) (obj Workload, err error)

+ func ReplicaSet(d *apps.ReplicaSet) Workload

+ func ReplicaSets(c context.Context, namespace string, labelSelector labels.Set) ([]Workload, error)

+ func StatefulSet(d *apps.StatefulSet) Workload

+ func StatefulSets(c context.Context, namespace string, labelSelector labels.Set) ([]Workload, error)

+ func WrapWorkload(workload runtime.Object) (Workload, error)