Fountain

English

Tiếng Việt

English

Tiếng Việt

Appearance

Import path: gitlab.soludian.com/soludian/fountain/libs/k8f

k8f ​

go
import "gitlab.soludian.com/soludian/fountain/libs/k8f"

Index ​

Constants ​

go
const (
    KKindPods      = "pods"
    KKindEndpoints = "endpoints"
)

go
const KPackageName = "k8f"

Variables ​

go
var GetFountainClientInternal = LibInternal.GetFountainInstance

go
var GetFountainInstance = Lib.GetFountainInstance

Sử dụng khi config instance ở dạng key:value; Nếu config instance ở dạng key:array thì sử dụng hàm InstallFountainInstances Nếu config ở dạng key:array thì sẽ chỉ install config phần tử đầu tiên mà thôi

Install with config format <key>:<value>; eg: k8f:<value>

Usage:

config.yaml:

	k8f:
	  name: default_name
	  ...

	code.go

	k8f.InstallFountainInstance()

 k8f.WithConfigKey("k8f").InstallFountainInstance()
go
var InstallFountainClientInternal = LibInternal.InstallFountainInstance

Sử dụng khi config instance ở dạng key:value; Nếu config instance ở dạng key:array thì sử dụng hàm InstallFountainInstances Nếu config ở dạng key:array thì sẽ chỉ install config phần tử đầu tiên mà thôi

Install with config format <key>:<value>; eg: k8f:<value>

Usage:

config.yaml:

	k8f:
	  name: default_name
	  ...

	code.go

	k8f.InstallFountainInstance()

 k8f.WithConfigKey("k8f").InstallFountainInstance()
go
var InstallFountainInstance = Lib.InstallFountainInstance

Truy cập thẳng tới bộ quản lý thư viện

go
var Lib = lib_3rd.NewLib(newClient, lib_3rd.WithDefaultConfigFunc[config, Client](DefaultConfig))

Truy cập thẳng tới bộ quản lý thư viện

go
var LibInternal = lib_3rd.NewLib(newClientInternal, lib_3rd.WithDefaultConfigFunc[config, Client](DefaultConfig))

go
var WithConfigKey = Lib.WithConfigKey

func InClusterConfig ​

go
func InClusterConfig() (*rest.Config, error)

InClusterConfig returns a config object which uses the service account kubernetes gives to pods. It's intended for clients that expect to be running inside a pod running on kubernetes. It will return ErrNotInCluster if called from a process not running in a kubernetes environment.

func WithAddr ​

go
func WithAddr(addr string) lib_3rd.Option[config]

func WithConfig ​

go
func WithConfig(conf *config) lib_3rd.Option[config]

func WithDeploymentPrefix ​

go
func WithDeploymentPrefix(deploymentPrefix string) lib_3rd.Option[config]

func WithEnvironment ​

go
func WithEnvironment(env string) lib_3rd.Option[config]

func WithLoadFromLocalConfigFile ​

go
func WithLoadFromLocalConfigFile(loadFromLocalConfigFile bool) lib_3rd.Option[config]

func WithLogger ​

go
func WithLogger(logger ...flog.FlogInf) lib_3rd.Option[config]

func WithName ​

go
func WithName(name string) lib_3rd.Option[config]

func WithNamespaces ​

go
func WithNamespaces(namespaces []string) lib_3rd.Option[config]

func WithTLSClientConfigInsecure ​

go
func WithTLSClientConfigInsecure(insecure bool) lib_3rd.Option[config]

func WithToken ​

go
func WithToken(token string) lib_3rd.Option[config]

type Client ​

K8F ...

go
type Client struct {
    *kubernetes.Clientset

    Namespaces       []string
    DeploymentPrefix string
    // contains filtered or unexported fields
}

func (*Client) CreatePod ​

go
func (c *Client) CreatePod(namespace string, pod *v1.Pod) error

func (*Client) ListEndpoints ​

go
func (c *Client) ListEndpoints(option ListOptions) (endPoints []*v1.EndpointsList, err error)

func (*Client) ListEndpointsByName ​

go
func (c *Client) ListEndpointsByName(name string) (endPoints []*v1.Endpoints, err error)

func (*Client) ListPods ​

go
func (c *Client) ListPods(option ListOptions) (pods []*v1.PodList, err error)

func (*Client) ListPodsByName ​

go
func (c *Client) ListPodsByName(name string) (pods []*v1.Pod, err error)

type ListOptions ​

go
type ListOptions = metav1.ListOptions

Generated by gomarkdoc