service

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 22, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ERR_TYPE = fmt.Errorf("type must be *corev1.Service, corev1.Service or string")

Functions

This section is empty.

Types

type Handler

type Handler struct {
	Options *typed.HandlerOptions
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, namespace, kubeconfig string) (handler *Handler, err error)

New returns a Handler handler from kubeconfig or in-cluster config.

func (*Handler) Apply

func (h *Handler) Apply(filename string) (*corev1.Service, error)

Apply apply service from yaml file, alias to "ApplyFromFile".

func (*Handler) ApplyFromBytes

func (h *Handler) ApplyFromBytes(data []byte) (service *corev1.Service, err error)

ApplyFromBytes apply service from bytes.

func (*Handler) ApplyFromFile

func (h *Handler) ApplyFromFile(filename string) (service *corev1.Service, err error)

ApplyFromFile apply service from yaml file.

func (*Handler) ApplyFromRaw

func (h *Handler) ApplyFromRaw(raw map[string]interface{}) (*corev1.Service, error)

ApplyFromRaw apply service from map[string]interface{}.

func (*Handler) Clientset added in v0.2.0

func (h *Handler) Clientset() *kubernetes.Clientset

func (*Handler) Create

func (h *Handler) Create(filename string) (*corev1.Service, error)

Create create service from yaml file, alias to "CreateFromFile".

func (*Handler) CreateFromBytes

func (h *Handler) CreateFromBytes(data []byte) (*corev1.Service, error)

CreateFromBytes create service from bytes.

func (*Handler) CreateFromFile

func (h *Handler) CreateFromFile(filename string) (*corev1.Service, error)

CreateFromFile create service from yaml file.

func (*Handler) CreateFromRaw

func (h *Handler) CreateFromRaw(raw map[string]interface{}) (*corev1.Service, error)

CreateFromRaw create service from map[string]interface{}.

func (*Handler) DeepCopy

func (in *Handler) DeepCopy() *Handler

func (*Handler) Delete

func (h *Handler) Delete(name string) error

Delete delete service by name, alias to "DeleteByName".

func (*Handler) DeleteByName

func (h *Handler) DeleteByName(name string) error

DeleteByName delete service by name.

func (*Handler) DeleteFromBytes

func (h *Handler) DeleteFromBytes(data []byte) error

DeleteFromBytes delete service from bytes.

func (*Handler) DeleteFromFile

func (h *Handler) DeleteFromFile(filename string) error

DeleteFromFile delete service from yaml file.

func (*Handler) DiscoveryClient added in v0.2.0

func (h *Handler) DiscoveryClient() *discovery.DiscoveryClient

func (*Handler) DynamicClient added in v0.2.0

func (h *Handler) DynamicClient() dynamic.Interface

func (*Handler) Get

func (h *Handler) Get(name string) (*corev1.Service, error)

Get get service by name, alias to "GetByName".

func (*Handler) GetAge added in v0.2.0

func (h *Handler) GetAge(object interface{}) (time.Duration, error)

GetAge returns the age of the service.

func (*Handler) GetByName

func (h *Handler) GetByName(name string) (*corev1.Service, error)

GetByName get service by name.

func (*Handler) GetClusterIP added in v0.2.0

func (h *Handler) GetClusterIP(object interface{}) (string, error)

GetClusterIP returns the cluster ip of the service.

func (*Handler) GetExternalIPs added in v0.2.0

func (h *Handler) GetExternalIPs(object interface{}) ([]string, error)

GetExternalIPs returns the external ip list of the service.

func (*Handler) GetFromBytes

func (h *Handler) GetFromBytes(data []byte) (*corev1.Service, error)

GetFromBytes get service from bytes.

func (*Handler) GetFromFile

func (h *Handler) GetFromFile(filename string) (*corev1.Service, error)

GetFromFile get service from yaml file.

func (*Handler) GetPorts added in v0.2.0

func (h *Handler) GetPorts(object interface{}) ([]ServicePort, error)

GetPorts get the port list of the service.

func (*Handler) GetType added in v0.2.0

func (h *Handler) GetType(object interface{}) (string, error)

GetType get the type of the service.

func (*Handler) List

func (h *Handler) List(labels string) (*corev1.ServiceList, error)

List list services by labels, alias to "ListByLabel".

func (*Handler) ListAll

func (h *Handler) ListAll() (*corev1.ServiceList, error)

ListAll list all services in the k8s cluster.

func (*Handler) ListByLabel

func (h *Handler) ListByLabel(labels string) (*corev1.ServiceList, error)

ListByLabel list services by labels.

func (*Handler) ListByNamespace

func (h *Handler) ListByNamespace(namespace string) (*corev1.ServiceList, error)

ListByNamespace list services by labels, alias to "ListByLabel".

func (*Handler) Namespace

func (h *Handler) Namespace() string

func (*Handler) RESTClient added in v0.2.0

func (h *Handler) RESTClient() *rest.RESTClient

func (*Handler) RunInformer

func (h *Handler) RunInformer(
	addFunc func(obj interface{}),
	updateFunc func(oldObj, newObj interface{}),
	deleteFunc func(obj interface{}),
	stopCh chan struct{})

RunInformer

func (*Handler) SetForceDelete

func (h *Handler) SetForceDelete(force bool)

func (*Handler) SetLimit

func (h *Handler) SetLimit(limit int64)

func (*Handler) SetTimeout

func (h *Handler) SetTimeout(timeout int64)

func (*Handler) Update

func (h *Handler) Update(filename string) (*corev1.Service, error)

Update update service from yaml file, alias to "UpdateFromFile".

func (*Handler) UpdateFromBytes

func (h *Handler) UpdateFromBytes(data []byte) (*corev1.Service, error)

UpdateFromBytes update service from bytes.

func (*Handler) UpdateFromFile

func (h *Handler) UpdateFromFile(filename string) (*corev1.Service, error)

UpdateFromFile update service from yaml file.

func (*Handler) UpdateFromRaw

func (h *Handler) UpdateFromRaw(raw map[string]interface{}) (*corev1.Service, error)

UpdateFromRaw update service from map[string]interface{}.

func (*Handler) Watch

func (h *Handler) Watch(name string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

Watch watch services by name, alias to "WatchByName".

func (*Handler) WatchByLabel

func (h *Handler) WatchByLabel(labelSelector string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

WatchByLabel watch services by label.

func (*Handler) WatchByName

func (h *Handler) WatchByName(name string,
	addFunc, modifyFunc, deleteFunc func(x interface{}), x interface{}) (err error)

WatchByName watch services by name.

func (*Handler) WithDryRun

func (h *Handler) WithDryRun() *Handler

func (*Handler) WithNamespace

func (h *Handler) WithNamespace(namespace string) *Handler

type ServicePort added in v0.2.0

type ServicePort struct {
	Name       string
	Protocol   string
	Port       int32
	TargetPort intstr.IntOrString
	NodePort   int32
}

Jump to

Keyboard shortcuts

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