k8s

Documentation

Index

• Constants
• type Client
  • func NewClient(sharedInformers informers.SharedInformerFactory, ...) *Client
  • func (c *Client) DSToWorkload(ds *appsv1.DaemonSet) *pb.Workload
  • func (c *Client) DeployToWorkload(deploy *appsv1.Deployment) *pb.Workload
  • func (c *Client) EventToPB(event *v1.Event) (*pb.Event, error)
  • func (c *Client) GetAuthorizationPolicies(ctx context.Context) ([]*pb.AuthorizationPolicy, error)
  • func (c *Client) GetControlPlaneCerts(ctx context.Context) (*pb.ControlPlaneCerts, error)
  • func (c *Client) GetK8sServiceManifest(ctx context.Context) (*pb.Service, error)
  • func (c *Client) GetLinkerdConfigMap(ctx context.Context) (*pb.ConfigMap, error)
  • func (c *Client) GetMeshTLSAuthentications(ctx context.Context) ([]*pb.MeshTLSAuthentication, error)
  • func (c *Client) GetMulticlusterLinks(ctx context.Context) ([]*pb.MulticlusterLink, error)
  • func (c *Client) GetNetworkAuthentications(ctx context.Context) ([]*pb.NetworkAuthentication, error)
  • func (c *Client) GetNodeManifests(ctx context.Context) ([]*pb.Node, error)
  • func (c *Client) GetPodSpec(ctx context.Context, podName, namespace string) (*pb.Pod, error)
  • func (c *Client) GetPrometheusScrape(ctx context.Context, podName, namespace string) ([][]byte, error)
  • func (c *Client) GetProxyLogs(ctx context.Context, podName, namespace string, includeTimestamps bool, ...) ([]byte, error)
  • func (c *Client) GetServerAuths(ctx context.Context) ([]*pb.ServerAuthorization, error)
  • func (c *Client) GetServers(ctx context.Context) ([]*pb.Server, error)
  • func (c *Client) GetServiceProfiles(ctx context.Context) ([]*pb.ServiceProfile, error)
  • func (c *Client) GetTrafficSplits(ctx context.Context) ([]*pb.TrafficSplit, error)
  • func (c *Client) ListWorkloads() ([]*pb.Workload, error)
  • func (c *Client) STSToWorkload(sts *appsv1.StatefulSet) *pb.Workload
  • func (c *Client) Sync(stopCh <-chan struct{}, timeout time.Duration) error

Constants

const (
	DaemonSet   = "DaemonSet"
	Deployment  = "Deployment"
	Namespace   = "Namespace"
	Pod         = "Pod"
	ReplicaSet  = "ReplicaSet"
	StatefulSet = "StatefulSet"

	// AgentNamespace is the namespace where the Buoyant Cloud agent is installed.
	AgentNamespace = "buoyant-cloud"
	// AgentIDKey is the key for the agent id in the agent metadata config map
	AgentIDKey = "agent_id"
	// AgentNameKey is the key for the agent name in the agent metadata config map
	AgentNameKey = "agent_name"
)

Types

type Client

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

func NewClient

func NewClient(sharedInformers informers.SharedInformerFactory, k8sClient *l5dk8s.KubernetesAPI, l5dClient l5dApi.Interface, tsClient tsclient.Interface, local bool) *Client

func (*Client) DSToWorkload

func (c *Client) DSToWorkload(ds *appsv1.DaemonSet) *pb.Workload

DSToWorkload serializes a k8s DaemonSet object and wraps it in a bcloud API proto message.

func (*Client) DeployToWorkload

func (c *Client) DeployToWorkload(deploy *appsv1.Deployment) *pb.Workload

DeployToWorkload serializes a k8s Deployment object and wraps it in a bcloud API proto message.

func (*Client) EventToPB

func (c *Client) EventToPB(event *v1.Event) (*pb.Event, error)

EventToPB converts a Kubernetes event to a bcloud protobuf event. If the owner of the event is not a DeamonSet, Deployment, or StatefulSet, return a nil event without error.

func (*Client) GetAuthorizationPolicies

func (c *Client) GetAuthorizationPolicies(ctx context.Context) ([]*pb.AuthorizationPolicy, error)

func (*Client) GetControlPlaneCerts

func (c *Client) GetControlPlaneCerts(ctx context.Context) (*pb.ControlPlaneCerts, error)

func (*Client) GetK8sServiceManifest

func (c *Client) GetK8sServiceManifest(ctx context.Context) (*pb.Service, error)

GetK8sServiceManifest the manifest of the kubernetes service residing in the default namespace

func (*Client) GetLinkerdConfigMap

func (c *Client) GetLinkerdConfigMap(ctx context.Context) (*pb.ConfigMap, error)

GetLinkerdConfigMap retrieves Linkerd config map

func (*Client) GetMeshTLSAuthentications

func (c *Client) GetMeshTLSAuthentications(ctx context.Context) ([]*pb.MeshTLSAuthentication, error)

func (*Client) GetMulticlusterLinks

func (c *Client) GetMulticlusterLinks(ctx context.Context) ([]*pb.MulticlusterLink, error)

func (*Client) GetNetworkAuthentications

func (c *Client) GetNetworkAuthentications(ctx context.Context) ([]*pb.NetworkAuthentication, error)

func (*Client) GetNodeManifests

func (c *Client) GetNodeManifests(ctx context.Context) ([]*pb.Node, error)

GetNodeManifests retrieves all nodes in the cluster

func (*Client) GetPodSpec

func (c *Client) GetPodSpec(ctx context.Context, podName, namespace string) (*pb.Pod, error)

GetPodSpec retrieves pod manifest

func (*Client) GetPrometheusScrape

func (c *Client) GetPrometheusScrape(ctx context.Context, podName, namespace string) ([][]byte, error)

GetPrometheusScrape retrieves the raw prom scrape from the proxy of a pod

func (*Client) GetProxyLogs

func (c *Client) GetProxyLogs(ctx context.Context, podName, namespace string, includeTimestamps bool, tailLines *int64) ([]byte, error)

GetProxyLogs retrieves the proxy logs of a pod

func (*Client) GetServerAuths

func (c *Client) GetServerAuths(ctx context.Context) ([]*pb.ServerAuthorization, error)

func (*Client) GetServers

func (c *Client) GetServers(ctx context.Context) ([]*pb.Server, error)

func (*Client) GetServiceProfiles

func (c *Client) GetServiceProfiles(ctx context.Context) ([]*pb.ServiceProfile, error)

func (*Client) GetTrafficSplits

func (c *Client) GetTrafficSplits(ctx context.Context) ([]*pb.TrafficSplit, error)

func (*Client) ListWorkloads

func (c *Client) ListWorkloads() ([]*pb.Workload, error)

func (*Client) STSToWorkload

func (c *Client) STSToWorkload(sts *appsv1.StatefulSet) *pb.Workload

STSToWorkload serializes a k8s StatefulSet object and wraps it in a bcloud API proto message.

func (*Client) Sync

func (c *Client) Sync(stopCh <-chan struct{}, timeout time.Duration) error