bcloud

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Api_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buoyant.cloud.Api",
	HandlerType: (*ApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddEvent",
			Handler:    _Api_AddEvent_Handler,
		},
		{
			MethodName: "LinkerdInfo",
			Handler:    _Api_LinkerdInfo_Handler,
		},
		{
			MethodName: "ProxyDiagnostics",
			Handler:    _Api_ProxyDiagnostics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WorkloadStream",
			Handler:       _Api_WorkloadStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ManageAgent",
			Handler:       _Api_ManageAgent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "buoyant-cloud-api.proto",
}

Api_ServiceDesc is the grpc.ServiceDesc for Api service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_buoyant_cloud_api_proto protoreflect.FileDescriptor

Functions

func RegisterApiServer 

func RegisterApiServer(s grpc.ServiceRegistrar, srv ApiServer)

Types

type AddWorkload 

type AddWorkload struct {
	Workload *Workload `protobuf:"bytes,1,opt,name=workload,proto3" json:"workload,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkload) Descriptor deprecated 

func (*AddWorkload) Descriptor() ([]byte, []int)

Deprecated: Use AddWorkload.ProtoReflect.Descriptor instead.

func (*AddWorkload) GetWorkload 

func (x *AddWorkload) GetWorkload() *Workload

func (*AddWorkload) ProtoMessage 

func (*AddWorkload) ProtoMessage()

func (*AddWorkload) ProtoReflect 

func (x *AddWorkload) ProtoReflect() protoreflect.Message

func (*AddWorkload) Reset 

func (x *AddWorkload) Reset()

func (*AddWorkload) String 

func (x *AddWorkload) String() string

type AgentCommand added in v0.4.1 

type AgentCommand struct {

	// Types that are assignable to Command:
	//	*AgentCommand_GetProxyDiagnostics
	Command isAgentCommand_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*AgentCommand) Descriptor deprecated added in v0.4.1 

func (*AgentCommand) Descriptor() ([]byte, []int)

Deprecated: Use AgentCommand.ProtoReflect.Descriptor instead.

func (*AgentCommand) GetCommand added in v0.4.1 

func (m *AgentCommand) GetCommand() isAgentCommand_Command

func (*AgentCommand) GetGetProxyDiagnostics added in v0.4.1 

func (x *AgentCommand) GetGetProxyDiagnostics() *GetProxyDiagnostics

func (*AgentCommand) ProtoMessage added in v0.4.1 

func (*AgentCommand) ProtoMessage()

func (*AgentCommand) ProtoReflect added in v0.4.1 

func (x *AgentCommand) ProtoReflect() protoreflect.Message

func (*AgentCommand) Reset added in v0.4.1 

func (x *AgentCommand) Reset()

func (*AgentCommand) String added in v0.4.1 

func (x *AgentCommand) String() string

type AgentCommand_GetProxyDiagnostics added in v0.4.1 

type AgentCommand_GetProxyDiagnostics struct {
	GetProxyDiagnostics *GetProxyDiagnostics `protobuf:"bytes,1,opt,name=get_proxy_diagnostics,json=getProxyDiagnostics,proto3,oneof"`
}

type ApiClient 

type ApiClient interface {
	WorkloadStream(ctx context.Context, opts ...grpc.CallOption) (Api_WorkloadStreamClient, error)
	AddEvent(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Empty, error)
	LinkerdInfo(ctx context.Context, in *LinkerdMessage, opts ...grpc.CallOption) (*Empty, error)
	ManageAgent(ctx context.Context, in *Auth, opts ...grpc.CallOption) (Api_ManageAgentClient, error)
	ProxyDiagnostics(ctx context.Context, in *ProxyDiagnostic, opts ...grpc.CallOption) (*Empty, error)
}

ApiClient is the client API for Api service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewApiClient 

func NewApiClient(cc grpc.ClientConnInterface) ApiClient

type ApiServer 

type ApiServer interface {
	WorkloadStream(Api_WorkloadStreamServer) error
	AddEvent(context.Context, *Event) (*Empty, error)
	LinkerdInfo(context.Context, *LinkerdMessage) (*Empty, error)
	ManageAgent(*Auth, Api_ManageAgentServer) error
	ProxyDiagnostics(context.Context, *ProxyDiagnostic) (*Empty, error)
	// contains filtered or unexported methods
}

ApiServer is the server API for Api service. All implementations must embed UnimplementedApiServer for forward compatibility

type Api_ManageAgentClient added in v0.4.1 

type Api_ManageAgentClient interface {
	Recv() (*AgentCommand, error)
	grpc.ClientStream
}

type Api_ManageAgentServer added in v0.4.1 

type Api_ManageAgentServer interface {
	Send(*AgentCommand) error
	grpc.ServerStream
}

type Api_WorkloadStreamClient 

type Api_WorkloadStreamClient interface {
	Send(*WorkloadMessage) error
	CloseAndRecv() (*Empty, error)
	grpc.ClientStream
}

type Api_WorkloadStreamServer 

type Api_WorkloadStreamServer interface {
	SendAndClose(*Empty) error
	Recv() (*WorkloadMessage, error)
	grpc.ServerStream
}

type Auth 

type Auth struct {
	AgentId  string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	AgentKey string `protobuf:"bytes,2,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Auth) Descriptor deprecated 

func (*Auth) Descriptor() ([]byte, []int)

Deprecated: Use Auth.ProtoReflect.Descriptor instead.

func (*Auth) GetAgentId 

func (x *Auth) GetAgentId() string

func (*Auth) GetAgentKey 

func (x *Auth) GetAgentKey() string

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) ProtoReflect 

func (x *Auth) ProtoReflect() protoreflect.Message

func (*Auth) Reset 

func (x *Auth) Reset()

func (*Auth) String 

func (x *Auth) String() string

type CertData added in v0.2.0 

type CertData struct {
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// contains filtered or unexported fields
}

This message represents a PEM encoded certificate

func (*CertData) Descriptor deprecated added in v0.2.0 

func (*CertData) Descriptor() ([]byte, []int)

Deprecated: Use CertData.ProtoReflect.Descriptor instead.

func (*CertData) GetRaw added in v0.2.0 

func (x *CertData) GetRaw() []byte

func (*CertData) ProtoMessage added in v0.2.0 

func (*CertData) ProtoMessage()

func (*CertData) ProtoReflect added in v0.2.0 

func (x *CertData) ProtoReflect() protoreflect.Message

func (*CertData) Reset added in v0.2.0 

func (x *CertData) Reset()

func (*CertData) String added in v0.2.0 

func (x *CertData) String() string

type CertificateInfo added in v0.2.0 

type CertificateInfo struct {

	// Types that are assignable to Info:
	//	*CertificateInfo_ControlPlane
	Info isCertificateInfo_Info `protobuf_oneof:"info"`
	// contains filtered or unexported fields
}

func (*CertificateInfo) Descriptor deprecated added in v0.2.0 

func (*CertificateInfo) Descriptor() ([]byte, []int)

Deprecated: Use CertificateInfo.ProtoReflect.Descriptor instead.

func (*CertificateInfo) GetControlPlane added in v0.2.0 

func (x *CertificateInfo) GetControlPlane() *ControlPlaneCerts

func (*CertificateInfo) GetInfo added in v0.2.0 

func (m *CertificateInfo) GetInfo() isCertificateInfo_Info

func (*CertificateInfo) ProtoMessage added in v0.2.0 

func (*CertificateInfo) ProtoMessage()

func (*CertificateInfo) ProtoReflect added in v0.2.0 

func (x *CertificateInfo) ProtoReflect() protoreflect.Message

func (*CertificateInfo) Reset added in v0.2.0 

func (x *CertificateInfo) Reset()

func (*CertificateInfo) String added in v0.2.0 

func (x *CertificateInfo) String() string

type CertificateInfo_ControlPlane added in v0.2.0 

type CertificateInfo_ControlPlane struct {
	ControlPlane *ControlPlaneCerts `protobuf:"bytes,1,opt,name=control_plane,json=controlPlane,proto3,oneof"`
}

type ConfigMap added in v0.4.1 

type ConfigMap struct {
	ConfigMap []byte `protobuf:"bytes,1,opt,name=config_map,json=configMap,proto3" json:"config_map,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigMap) Descriptor deprecated added in v0.4.1 

func (*ConfigMap) Descriptor() ([]byte, []int)

Deprecated: Use ConfigMap.ProtoReflect.Descriptor instead.

func (*ConfigMap) GetConfigMap added in v0.4.1 

func (x *ConfigMap) GetConfigMap() []byte

func (*ConfigMap) ProtoMessage added in v0.4.1 

func (*ConfigMap) ProtoMessage()

func (*ConfigMap) ProtoReflect added in v0.4.1 

func (x *ConfigMap) ProtoReflect() protoreflect.Message

func (*ConfigMap) Reset added in v0.4.1 

func (x *ConfigMap) Reset()

func (*ConfigMap) String added in v0.4.1 

func (x *ConfigMap) String() string

type ControlPlaneCerts added in v0.2.0 

type ControlPlaneCerts struct {

	// This is the identity issuer certificate chain;
	// it does not include a leaf certificate
	IssuerCrtChain []*CertData `protobuf:"bytes,1,rep,name=issuer_crt_chain,json=issuerCrtChain,proto3" json:"issuer_crt_chain,omitempty"`
	// The roots that the control plane has been configured
	// with and will add to newly created proxies
	Roots []*CertData `protobuf:"bytes,2,rep,name=roots,proto3" json:"roots,omitempty"`
	// contains filtered or unexported fields
}

Represents the certificates that the control plane has been configured with.

func (*ControlPlaneCerts) Descriptor deprecated added in v0.2.0 

func (*ControlPlaneCerts) Descriptor() ([]byte, []int)

Deprecated: Use ControlPlaneCerts.ProtoReflect.Descriptor instead.

func (*ControlPlaneCerts) GetIssuerCrtChain added in v0.2.0 

func (x *ControlPlaneCerts) GetIssuerCrtChain() []*CertData

func (*ControlPlaneCerts) GetRoots added in v0.2.0 

func (x *ControlPlaneCerts) GetRoots() []*CertData

func (*ControlPlaneCerts) ProtoMessage added in v0.2.0 

func (*ControlPlaneCerts) ProtoMessage()

func (*ControlPlaneCerts) ProtoReflect added in v0.2.0 

func (x *ControlPlaneCerts) ProtoReflect() protoreflect.Message

func (*ControlPlaneCerts) Reset added in v0.2.0 

func (x *ControlPlaneCerts) Reset()

func (*ControlPlaneCerts) String added in v0.2.0 

func (x *ControlPlaneCerts) String() string

type DaemonSet 

type DaemonSet struct {
	DaemonSet []byte `protobuf:"bytes,1,opt,name=daemon_set,json=daemonSet,proto3" json:"daemon_set,omitempty"`
	Pods      []*Pod `protobuf:"bytes,2,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

func (*DaemonSet) Descriptor deprecated 

func (*DaemonSet) Descriptor() ([]byte, []int)

Deprecated: Use DaemonSet.ProtoReflect.Descriptor instead.

func (*DaemonSet) GetDaemonSet 

func (x *DaemonSet) GetDaemonSet() []byte

func (*DaemonSet) GetPods 

func (x *DaemonSet) GetPods() []*Pod

func (*DaemonSet) ProtoMessage 

func (*DaemonSet) ProtoMessage()

func (*DaemonSet) ProtoReflect 

func (x *DaemonSet) ProtoReflect() protoreflect.Message

func (*DaemonSet) Reset 

func (x *DaemonSet) Reset()

func (*DaemonSet) String 

func (x *DaemonSet) String() string

type DeleteWorkload 

type DeleteWorkload struct {
	Workload *Workload `protobuf:"bytes,1,opt,name=workload,proto3" json:"workload,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkload) Descriptor deprecated 

func (*DeleteWorkload) Descriptor() ([]byte, []int)

Deprecated: Use DeleteWorkload.ProtoReflect.Descriptor instead.

func (*DeleteWorkload) GetWorkload 

func (x *DeleteWorkload) GetWorkload() *Workload

func (*DeleteWorkload) ProtoMessage 

func (*DeleteWorkload) ProtoMessage()

func (*DeleteWorkload) ProtoReflect 

func (x *DeleteWorkload) ProtoReflect() protoreflect.Message

func (*DeleteWorkload) Reset 

func (x *DeleteWorkload) Reset()

func (*DeleteWorkload) String 

func (x *DeleteWorkload) String() string

type Deployment 

type Deployment struct {
	Deployment  []byte        `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
	ReplicaSets []*ReplicaSet `protobuf:"bytes,2,rep,name=replica_sets,json=replicaSets,proto3" json:"replica_sets,omitempty"`
	// contains filtered or unexported fields
}

func (*Deployment) Descriptor deprecated 

func (*Deployment) Descriptor() ([]byte, []int)

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetDeployment 

func (x *Deployment) GetDeployment() []byte

func (*Deployment) GetReplicaSets 

func (x *Deployment) GetReplicaSets() []*ReplicaSet

func (*Deployment) ProtoMessage 

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect 

func (x *Deployment) ProtoReflect() protoreflect.Message

func (*Deployment) Reset 

func (x *Deployment) Reset()

func (*Deployment) String 

func (x *Deployment) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Event 

type Event struct {
	Auth  *Auth     `protobuf:"bytes,1,opt,name=auth,proto3" json:"auth,omitempty"`
	Event []byte    `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	Owner *Workload `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAuth 

func (x *Event) GetAuth() *Auth

func (*Event) GetEvent 

func (x *Event) GetEvent() []byte

func (*Event) GetOwner 

func (x *Event) GetOwner() *Workload

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type GetProxyDiagnostics added in v0.4.1 

type GetProxyDiagnostics struct {
	DiagnosticId string `protobuf:"bytes,1,opt,name=diagnostic_id,json=diagnosticId,proto3" json:"diagnostic_id,omitempty"`
	PodName      string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	PodNamespace string `protobuf:"bytes,3,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProxyDiagnostics) Descriptor deprecated added in v0.4.1 

func (*GetProxyDiagnostics) Descriptor() ([]byte, []int)

Deprecated: Use GetProxyDiagnostics.ProtoReflect.Descriptor instead.

func (*GetProxyDiagnostics) GetDiagnosticId added in v0.4.1 

func (x *GetProxyDiagnostics) GetDiagnosticId() string

func (*GetProxyDiagnostics) GetPodName added in v0.4.1 

func (x *GetProxyDiagnostics) GetPodName() string

func (*GetProxyDiagnostics) GetPodNamespace added in v0.4.1 

func (x *GetProxyDiagnostics) GetPodNamespace() string

func (*GetProxyDiagnostics) ProtoMessage added in v0.4.1 

func (*GetProxyDiagnostics) ProtoMessage()

func (*GetProxyDiagnostics) ProtoReflect added in v0.4.1 

func (x *GetProxyDiagnostics) ProtoReflect() protoreflect.Message

func (*GetProxyDiagnostics) Reset added in v0.4.1 

func (x *GetProxyDiagnostics) Reset()

func (*GetProxyDiagnostics) String added in v0.4.1 

func (x *GetProxyDiagnostics) String() string

type LinkerdMessage added in v0.2.0 

type LinkerdMessage struct {
	Auth *Auth `protobuf:"bytes,1,opt,name=auth,proto3" json:"auth,omitempty"`
	// Types that are assignable to Message:
	//	*LinkerdMessage_CrtInfo
	Message isLinkerdMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*LinkerdMessage) Descriptor deprecated added in v0.2.0 

func (*LinkerdMessage) Descriptor() ([]byte, []int)

Deprecated: Use LinkerdMessage.ProtoReflect.Descriptor instead.

func (*LinkerdMessage) GetAuth added in v0.2.0 

func (x *LinkerdMessage) GetAuth() *Auth

func (*LinkerdMessage) GetCrtInfo added in v0.2.0 

func (x *LinkerdMessage) GetCrtInfo() *CertificateInfo

func (*LinkerdMessage) GetMessage added in v0.2.0 

func (m *LinkerdMessage) GetMessage() isLinkerdMessage_Message

func (*LinkerdMessage) ProtoMessage added in v0.2.0 

func (*LinkerdMessage) ProtoMessage()

func (*LinkerdMessage) ProtoReflect added in v0.2.0 

func (x *LinkerdMessage) ProtoReflect() protoreflect.Message

func (*LinkerdMessage) Reset added in v0.2.0 

func (x *LinkerdMessage) Reset()

func (*LinkerdMessage) String added in v0.2.0 

func (x *LinkerdMessage) String() string

type LinkerdMessage_CrtInfo added in v0.2.0 

type LinkerdMessage_CrtInfo struct {
	CrtInfo *CertificateInfo `protobuf:"bytes,2,opt,name=crt_info,json=crtInfo,proto3,oneof"`
}

type ListWorkloads 

type ListWorkloads struct {
	Workloads []*Workload `protobuf:"bytes,1,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkloads) Descriptor deprecated 

func (*ListWorkloads) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkloads.ProtoReflect.Descriptor instead.

func (*ListWorkloads) GetWorkloads 

func (x *ListWorkloads) GetWorkloads() []*Workload

func (*ListWorkloads) ProtoMessage 

func (*ListWorkloads) ProtoMessage()

func (*ListWorkloads) ProtoReflect 

func (x *ListWorkloads) ProtoReflect() protoreflect.Message

func (*ListWorkloads) Reset 

func (x *ListWorkloads) Reset()

func (*ListWorkloads) String 

func (x *ListWorkloads) String() string

type Node added in v0.4.1 

type Node struct {
	Node []byte `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated added in v0.4.1 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetNode added in v0.4.1 

func (x *Node) GetNode() []byte

func (*Node) ProtoMessage added in v0.4.1 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect added in v0.4.1 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset added in v0.4.1 

func (x *Node) Reset()

func (*Node) String added in v0.4.1 

func (x *Node) String() string

type Pod 

type Pod struct {
	Pod []byte `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	// contains filtered or unexported fields
}

func (*Pod) Descriptor deprecated 

func (*Pod) Descriptor() ([]byte, []int)

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetPod 

func (x *Pod) GetPod() []byte

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect 

func (x *Pod) ProtoReflect() protoreflect.Message

func (*Pod) Reset 

func (x *Pod) Reset()

func (*Pod) String 

func (x *Pod) String() string

type ProxyDiagnostic added in v0.4.1 

type ProxyDiagnostic struct {
	Auth               *Auth      `protobuf:"bytes,1,opt,name=auth,proto3" json:"auth,omitempty"`
	DiagnosticId       string     `protobuf:"bytes,2,opt,name=diagnostic_id,json=diagnosticId,proto3" json:"diagnostic_id,omitempty"`
	Logs               []byte     `protobuf:"bytes,3,opt,name=logs,proto3" json:"logs,omitempty"`
	Metrics            [][]byte   `protobuf:"bytes,4,rep,name=metrics,proto3" json:"metrics,omitempty"`
	PodManifest        *Pod       `protobuf:"bytes,5,opt,name=pod_manifest,json=podManifest,proto3" json:"pod_manifest,omitempty"`
	LinkerdConfigMap   *ConfigMap `protobuf:"bytes,6,opt,name=linkerd_config_map,json=linkerdConfigMap,proto3" json:"linkerd_config_map,omitempty"`
	Nodes              []*Node    `protobuf:"bytes,7,rep,name=nodes,proto3" json:"nodes,omitempty"`
	K8SServiceManifest *Service   `protobuf:"bytes,8,opt,name=k8s_service_manifest,json=k8sServiceManifest,proto3" json:"k8s_service_manifest,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyDiagnostic) Descriptor deprecated added in v0.4.1 

func (*ProxyDiagnostic) Descriptor() ([]byte, []int)

Deprecated: Use ProxyDiagnostic.ProtoReflect.Descriptor instead.

func (*ProxyDiagnostic) GetAuth added in v0.4.1 

func (x *ProxyDiagnostic) GetAuth() *Auth

func (*ProxyDiagnostic) GetDiagnosticId added in v0.4.1 

func (x *ProxyDiagnostic) GetDiagnosticId() string

func (*ProxyDiagnostic) GetK8SServiceManifest added in v0.4.1 

func (x *ProxyDiagnostic) GetK8SServiceManifest() *Service

func (*ProxyDiagnostic) GetLinkerdConfigMap added in v0.4.1 

func (x *ProxyDiagnostic) GetLinkerdConfigMap() *ConfigMap

func (*ProxyDiagnostic) GetLogs added in v0.4.1 

func (x *ProxyDiagnostic) GetLogs() []byte

func (*ProxyDiagnostic) GetMetrics added in v0.4.1 

func (x *ProxyDiagnostic) GetMetrics() [][]byte

func (*ProxyDiagnostic) GetNodes added in v0.4.1 

func (x *ProxyDiagnostic) GetNodes() []*Node

func (*ProxyDiagnostic) GetPodManifest added in v0.4.1 

func (x *ProxyDiagnostic) GetPodManifest() *Pod

func (*ProxyDiagnostic) ProtoMessage added in v0.4.1 

func (*ProxyDiagnostic) ProtoMessage()

func (*ProxyDiagnostic) ProtoReflect added in v0.4.1 

func (x *ProxyDiagnostic) ProtoReflect() protoreflect.Message

func (*ProxyDiagnostic) Reset added in v0.4.1 

func (x *ProxyDiagnostic) Reset()

func (*ProxyDiagnostic) String added in v0.4.1 

func (x *ProxyDiagnostic) String() string

type ReplicaSet 

type ReplicaSet struct {
	ReplicaSet []byte `protobuf:"bytes,1,opt,name=replica_set,json=replicaSet,proto3" json:"replica_set,omitempty"`
	Pods       []*Pod `protobuf:"bytes,2,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicaSet) Descriptor deprecated 

func (*ReplicaSet) Descriptor() ([]byte, []int)

Deprecated: Use ReplicaSet.ProtoReflect.Descriptor instead.

func (*ReplicaSet) GetPods 

func (x *ReplicaSet) GetPods() []*Pod

func (*ReplicaSet) GetReplicaSet 

func (x *ReplicaSet) GetReplicaSet() []byte

func (*ReplicaSet) ProtoMessage 

func (*ReplicaSet) ProtoMessage()

func (*ReplicaSet) ProtoReflect 

func (x *ReplicaSet) ProtoReflect() protoreflect.Message

func (*ReplicaSet) Reset 

func (x *ReplicaSet) Reset()

func (*ReplicaSet) String 

func (x *ReplicaSet) String() string

type Service added in v0.4.1 

type Service struct {
	Service []byte `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated added in v0.4.1 

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetService added in v0.4.1 

func (x *Service) GetService() []byte

func (*Service) ProtoMessage added in v0.4.1 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect added in v0.4.1 

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset added in v0.4.1 

func (x *Service) Reset()

func (*Service) String added in v0.4.1 

func (x *Service) String() string

type StatefulSet 

type StatefulSet struct {
	StatefulSet []byte `protobuf:"bytes,1,opt,name=stateful_set,json=statefulSet,proto3" json:"stateful_set,omitempty"`
	Pods        []*Pod `protobuf:"bytes,2,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

func (*StatefulSet) Descriptor deprecated 

func (*StatefulSet) Descriptor() ([]byte, []int)

Deprecated: Use StatefulSet.ProtoReflect.Descriptor instead.

func (*StatefulSet) GetPods 

func (x *StatefulSet) GetPods() []*Pod

func (*StatefulSet) GetStatefulSet 

func (x *StatefulSet) GetStatefulSet() []byte

func (*StatefulSet) ProtoMessage 

func (*StatefulSet) ProtoMessage()

func (*StatefulSet) ProtoReflect 

func (x *StatefulSet) ProtoReflect() protoreflect.Message

func (*StatefulSet) Reset 

func (x *StatefulSet) Reset()

func (*StatefulSet) String 

func (x *StatefulSet) String() string

type UnimplementedApiServer 

type UnimplementedApiServer struct {
}

UnimplementedApiServer must be embedded to have forward compatible implementations.

func (UnimplementedApiServer) AddEvent 

func (UnimplementedApiServer) AddEvent(context.Context, *Event) (*Empty, error)

func (UnimplementedApiServer) LinkerdInfo added in v0.2.0 

func (UnimplementedApiServer) LinkerdInfo(context.Context, *LinkerdMessage) (*Empty, error)

func (UnimplementedApiServer) ManageAgent added in v0.4.1 

func (UnimplementedApiServer) ManageAgent(*Auth, Api_ManageAgentServer) error

func (UnimplementedApiServer) ProxyDiagnostics added in v0.4.1 

func (UnimplementedApiServer) ProxyDiagnostics(context.Context, *ProxyDiagnostic) (*Empty, error)

func (UnimplementedApiServer) WorkloadStream 

func (UnimplementedApiServer) WorkloadStream(Api_WorkloadStreamServer) error

type UnsafeApiServer 

type UnsafeApiServer interface {
	// contains filtered or unexported methods
}

UnsafeApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApiServer will result in compilation errors.

type UpdateWorkload 

type UpdateWorkload struct {
	OldWorkload *Workload              `protobuf:"bytes,1,opt,name=old_workload,json=oldWorkload,proto3" json:"old_workload,omitempty"`
	NewWorkload *Workload              `protobuf:"bytes,2,opt,name=new_workload,json=newWorkload,proto3" json:"new_workload,omitempty"`
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkload) Descriptor deprecated 

func (*UpdateWorkload) Descriptor() ([]byte, []int)

Deprecated: Use UpdateWorkload.ProtoReflect.Descriptor instead.

func (*UpdateWorkload) GetNewWorkload 

func (x *UpdateWorkload) GetNewWorkload() *Workload

func (*UpdateWorkload) GetOldWorkload 

func (x *UpdateWorkload) GetOldWorkload() *Workload

func (*UpdateWorkload) GetTimestamp 

func (x *UpdateWorkload) GetTimestamp() *timestamppb.Timestamp

func (*UpdateWorkload) ProtoMessage 

func (*UpdateWorkload) ProtoMessage()

func (*UpdateWorkload) ProtoReflect 

func (x *UpdateWorkload) ProtoReflect() protoreflect.Message

func (*UpdateWorkload) Reset 

func (x *UpdateWorkload) Reset()

func (*UpdateWorkload) String 

func (x *UpdateWorkload) String() string

type Workload 

type Workload struct {

	// Types that are assignable to Workload:
	//	*Workload_Daemonset
	//	*Workload_Deployment
	//	*Workload_Statefulset
	Workload isWorkload_Workload `protobuf_oneof:"workload"`
	// contains filtered or unexported fields
}

func (*Workload) Descriptor deprecated 

func (*Workload) Descriptor() ([]byte, []int)

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetDaemonset 

func (x *Workload) GetDaemonset() *DaemonSet

func (*Workload) GetDeployment 

func (x *Workload) GetDeployment() *Deployment

func (*Workload) GetStatefulset 

func (x *Workload) GetStatefulset() *StatefulSet

func (*Workload) GetWorkload 

func (m *Workload) GetWorkload() isWorkload_Workload

func (*Workload) ProtoMessage 

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect 

func (x *Workload) ProtoReflect() protoreflect.Message

func (*Workload) Reset 

func (x *Workload) Reset()

func (*Workload) String 

func (x *Workload) String() string

type WorkloadMessage 

type WorkloadMessage struct {

	// Types that are assignable to Message:
	//	*WorkloadMessage_Auth
	//	*WorkloadMessage_Added
	//	*WorkloadMessage_Updated
	//	*WorkloadMessage_Deleted
	//	*WorkloadMessage_List
	Message isWorkloadMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*WorkloadMessage) Descriptor deprecated 

func (*WorkloadMessage) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadMessage.ProtoReflect.Descriptor instead.

func (*WorkloadMessage) GetAdded 

func (x *WorkloadMessage) GetAdded() *AddWorkload

func (*WorkloadMessage) GetAuth 

func (x *WorkloadMessage) GetAuth() *Auth

func (*WorkloadMessage) GetDeleted 

func (x *WorkloadMessage) GetDeleted() *DeleteWorkload

func (*WorkloadMessage) GetList 

func (x *WorkloadMessage) GetList() *ListWorkloads

func (*WorkloadMessage) GetMessage 

func (m *WorkloadMessage) GetMessage() isWorkloadMessage_Message

func (*WorkloadMessage) GetUpdated 

func (x *WorkloadMessage) GetUpdated() *UpdateWorkload

func (*WorkloadMessage) ProtoMessage 

func (*WorkloadMessage) ProtoMessage()

func (*WorkloadMessage) ProtoReflect 

func (x *WorkloadMessage) ProtoReflect() protoreflect.Message

func (*WorkloadMessage) Reset 

func (x *WorkloadMessage) Reset()

func (*WorkloadMessage) String 

func (x *WorkloadMessage) String() string

type WorkloadMessage_Added 

type WorkloadMessage_Added struct {
	Added *AddWorkload `protobuf:"bytes,2,opt,name=added,proto3,oneof"`
}

type WorkloadMessage_Auth 

type WorkloadMessage_Auth struct {
	Auth *Auth `protobuf:"bytes,1,opt,name=auth,proto3,oneof"`
}

type WorkloadMessage_Deleted 

type WorkloadMessage_Deleted struct {
	Deleted *DeleteWorkload `protobuf:"bytes,4,opt,name=deleted,proto3,oneof"`
}

type WorkloadMessage_List 

type WorkloadMessage_List struct {
	List *ListWorkloads `protobuf:"bytes,5,opt,name=list,proto3,oneof"`
}

type WorkloadMessage_Updated 

type WorkloadMessage_Updated struct {
	Updated *UpdateWorkload `protobuf:"bytes,3,opt,name=updated,proto3,oneof"`
}

type Workload_Daemonset 

type Workload_Daemonset struct {
	Daemonset *DaemonSet `protobuf:"bytes,1,opt,name=daemonset,proto3,oneof"`
}

type Workload_Deployment 

type Workload_Deployment struct {
	Deployment *Deployment `protobuf:"bytes,2,opt,name=deployment,proto3,oneof"`
}

type Workload_Statefulset 

type Workload_Statefulset struct {
	Statefulset *StatefulSet `protobuf:"bytes,3,opt,name=statefulset,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.