Documentation
¶
Index ¶
- Constants
- type 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 ¶
View Source
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" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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 ¶
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 ¶ added in v0.8.1
func (*Client) GetControlPlaneCerts ¶ added in v0.2.0
func (*Client) GetK8sServiceManifest ¶ added in v0.4.1
GetK8sServiceManifest the manifest of the kubernetes service residing in the default namespace
func (*Client) GetLinkerdConfigMap ¶ added in v0.4.1
GetLinkerdConfigMap retrieves Linkerd config map
func (*Client) GetMeshTLSAuthentications ¶ added in v0.8.1
func (*Client) GetMulticlusterLinks ¶ added in v0.5.0
func (*Client) GetNetworkAuthentications ¶ added in v0.8.1
func (*Client) GetNodeManifests ¶ added in v0.4.1
GetNodeManifests retrieves all nodes in the cluster
func (*Client) GetPodSpec ¶ added in v0.4.1
GetPodSpec retrieves pod manifest
func (*Client) GetPrometheusScrape ¶ added in v0.4.1
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 ¶ added in v0.4.1
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 ¶ added in v0.5.0
func (*Client) GetServers ¶ added in v0.5.0
func (*Client) GetServiceProfiles ¶ added in v0.5.0
func (*Client) GetTrafficSplits ¶ added in v0.5.0
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.
Source Files
Click to show internal directories.
Click to hide internal directories.