types

Documentation

Index

• type Args
  • func NewArgs(args_ []string) *Args
  • func (args Args) GetValue(name string) string
  • func (args Args) GetValueOrDefault(name, defaultValue string) string
• type Client
  • func (c Client) Exec(podName, containerName string, cmd []string) error
  • func (c Client) GetDaemonSet(ctx context.Context, name string) (appsv1.DaemonSet, error)
  • func (c Client) GetDeployment(ctx context.Context, name string) (appsv1.Deployment, error)
  • func (c Client) GetNamespace() string
  • func (c Client) GetNode(ctx context.Context, name string) (corev1.Node, error)
  • func (c Client) ListAllCommunities(ctx context.Context) ([]apisv1.Community, error)
  • func (c Client) ListClusters(ctx context.Context) ([]apisv1.Cluster, error)
  • func (c Client) ListNodes(ctx context.Context, labels client.MatchingLabels) ([]corev1.Node, error)
• type ClientFactory
  • func NewClientFlags() *ClientFactory
  • func (cfg *ClientFactory) AddFlags(fs *pflag.FlagSet)
  • func (cfg ClientFactory) GetClient() (*Client, error)
  • func (cfg ClientFactory) GetConfig() (*rest.Config, error)
• type ClientGetter
• type Cluster
  • func NewCluster(client *Client) *Cluster
  • func (cluster *Cluster) ExtractArgumentsFromFabEdge() error
  • func (cluster *Cluster) LoadCommunities() error
• type ExecResult
• type ObjectKey

Types

type Args

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

func NewArgs

func NewArgs(args_ []string) *Args

func (Args) GetValue

func (args Args) GetValue(name string) string

func (Args) GetValueOrDefault

func (args Args) GetValueOrDefault(name, defaultValue string) string

type Client

type Client struct {
	client.Client
	// contains filtered or unexported fields
}

func (Client) Exec

func (c Client) Exec(podName, containerName string, cmd []string) error

func (Client) GetDaemonSet

func (c Client) GetDaemonSet(ctx context.Context, name string) (appsv1.DaemonSet, error)

func (Client) GetDeployment

func (c Client) GetDeployment(ctx context.Context, name string) (appsv1.Deployment, error)

func (Client) GetNamespace

func (c Client) GetNamespace() string

func (Client) GetNode

func (c Client) GetNode(ctx context.Context, name string) (corev1.Node, error)

func (Client) ListAllCommunities

func (c Client) ListAllCommunities(ctx context.Context) ([]apisv1.Community, error)

func (Client) ListClusters

func (c Client) ListClusters(ctx context.Context) ([]apisv1.Cluster, error)

func (Client) ListNodes

func (c Client) ListNodes(ctx context.Context, labels client.MatchingLabels) ([]corev1.Node, error)

type ClientFactory

type ClientFactory struct {
	Namespace string
}

func NewClientFlags

func NewClientFlags() *ClientFactory

func (*ClientFactory) AddFlags

func (cfg *ClientFactory) AddFlags(fs *pflag.FlagSet)

func (ClientFactory) GetClient

func (cfg ClientFactory) GetClient() (*Client, error)

func (ClientFactory) GetConfig

func (cfg ClientFactory) GetConfig() (*rest.Config, error)

type ClientGetter

type ClientGetter interface {
	GetConfig() (*rest.Config, error)
	GetClient() (*Client, error)
}

type Cluster

type Cluster struct {
	Name              string
	CNIType           string
	EdgeLabels        map[string]string
	EndpointIDFormat  string
	NewEndpoint       ftypes.NewEndpointFunc
	EdgeToCommunities map[string][]string
	Communities       map[string]apisv1.Community
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(client *Client) *Cluster

func (*Cluster) ExtractArgumentsFromFabEdge

func (cluster *Cluster) ExtractArgumentsFromFabEdge() error

func (*Cluster) LoadCommunities

func (cluster *Cluster) LoadCommunities() error

type ExecResult

type ExecResult struct {
	Stdout string
	Stderr string
	Err    error
}

type ObjectKey

type ObjectKey = client.ObjectKey