connector

package
v2.1.1-rc.1 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 12 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InterceptError_name = map[int32]string{
		0:  "UNSPECIFIED",
		1:  "NO_PREVIEW_HOST",
		2:  "NO_CONNECTION",
		3:  "NO_TRAFFIC_MANAGER",
		4:  "TRAFFIC_MANAGER_CONNECTING",
		5:  "TRAFFIC_MANAGER_ERROR",
		6:  "ALREADY_EXISTS",
		7:  "LOCAL_TARGET_IN_USE",
		8:  "NO_ACCEPTABLE_DEPLOYMENT",
		9:  "AMBIGUOUS_MATCH",
		10: "FAILED_TO_ESTABLISH",
		11: "FAILED_TO_REMOVE",
		12: "NOT_FOUND",
		13: "MOUNT_POINT_BUSY",
	}
	InterceptError_value = map[string]int32{
		"UNSPECIFIED":                0,
		"NO_PREVIEW_HOST":            1,
		"NO_CONNECTION":              2,
		"NO_TRAFFIC_MANAGER":         3,
		"TRAFFIC_MANAGER_CONNECTING": 4,
		"TRAFFIC_MANAGER_ERROR":      5,
		"ALREADY_EXISTS":             6,
		"LOCAL_TARGET_IN_USE":        7,
		"NO_ACCEPTABLE_DEPLOYMENT":   8,
		"AMBIGUOUS_MATCH":            9,
		"FAILED_TO_ESTABLISH":        10,
		"FAILED_TO_REMOVE":           11,
		"NOT_FOUND":                  12,
		"MOUNT_POINT_BUSY":           13,
	}
)

Enum value maps for InterceptError.

View Source 
var (
	ConnectInfo_ErrType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NOT_STARTED",
		2: "ALREADY_CONNECTED",
		3: "DISCONNECTING",
		4: "CLUSTER_FAILED",
		5: "BRIDGE_FAILED",
		6: "TRAFFIC_MANAGER_FAILED",
		7: "MUST_RESTART",
	}
	ConnectInfo_ErrType_value = map[string]int32{
		"UNSPECIFIED":            0,
		"NOT_STARTED":            1,
		"ALREADY_CONNECTED":      2,
		"DISCONNECTING":          3,
		"CLUSTER_FAILED":         4,
		"BRIDGE_FAILED":          5,
		"TRAFFIC_MANAGER_FAILED": 6,
		"MUST_RESTART":           7,
	}
)

Enum value maps for ConnectInfo_ErrType.

View Source 
var (
	UninstallRequest_UninstallType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NAMED_AGENTS",
		2: "ALL_AGENTS",
		3: "EVERYTHING",
	}
	UninstallRequest_UninstallType_value = map[string]int32{
		"UNSPECIFIED":  0,
		"NAMED_AGENTS": 1,
		"ALL_AGENTS":   2,
		"EVERYTHING":   3,
	}
)

Enum value maps for UninstallRequest_UninstallType.

View Source 
var (
	ListRequest_Filter_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INTERCEPTS",
		2: "INSTALLED_AGENTS",
		3: "INTERCEPTABLE",
		4: "EVERYTHING",
	}
	ListRequest_Filter_value = map[string]int32{
		"UNSPECIFIED":      0,
		"INTERCEPTS":       1,
		"INSTALLED_AGENTS": 2,
		"INTERCEPTABLE":    3,
		"EVERYTHING":       4,
	}
)

Enum value maps for ListRequest_Filter.

View Source 
var File_rpc_connector_connector_proto protoreflect.FileDescriptor

Functions

func RegisterConnectorServer 

func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)

Types

type ConnectInfo 

type ConnectInfo struct {
	Error          ConnectInfo_ErrType            `protobuf:"varint,1,opt,name=error,proto3,enum=telepresence.connector.ConnectInfo_ErrType" json:"error,omitempty"`
	ErrorText      string                         `protobuf:"bytes,2,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	ClusterServer  string                         `protobuf:"bytes,3,opt,name=cluster_server,json=clusterServer,proto3" json:"cluster_server,omitempty"`
	ClusterContext string                         `protobuf:"bytes,4,opt,name=cluster_context,json=clusterContext,proto3" json:"cluster_context,omitempty"`
	BridgeOk       bool                           `protobuf:"varint,5,opt,name=bridge_ok,json=bridgeOk,proto3" json:"bridge_ok,omitempty"`
	ClusterOk      bool                           `protobuf:"varint,6,opt,name=cluster_ok,json=clusterOk,proto3" json:"cluster_ok,omitempty"`
	Agents         *manager.AgentInfoSnapshot     `protobuf:"bytes,7,opt,name=agents,proto3" json:"agents,omitempty"`
	Intercepts     *manager.InterceptInfoSnapshot `protobuf:"bytes,8,opt,name=intercepts,proto3" json:"intercepts,omitempty"`
	IngressInfos   []*manager.IngressInfo         `protobuf:"bytes,9,rep,name=ingress_infos,json=ingressInfos,proto3" json:"ingress_infos,omitempty"`
	SessionInfo    *manager.SessionInfo           `protobuf:"bytes,10,opt,name=session_info,json=sessionInfo,proto3" json:"session_info,omitempty"`
	ClusterId      string                         `protobuf:"bytes,11,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectInfo) Descriptor deprecated 

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

Deprecated: Use ConnectInfo.ProtoReflect.Descriptor instead.

func (*ConnectInfo) GetAgents 

func (x *ConnectInfo) GetAgents() *manager.AgentInfoSnapshot

func (*ConnectInfo) GetBridgeOk 

func (x *ConnectInfo) GetBridgeOk() bool

func (*ConnectInfo) GetClusterContext 

func (x *ConnectInfo) GetClusterContext() string

func (*ConnectInfo) GetClusterId 

func (x *ConnectInfo) GetClusterId() string

func (*ConnectInfo) GetClusterOk 

func (x *ConnectInfo) GetClusterOk() bool

func (*ConnectInfo) GetClusterServer 

func (x *ConnectInfo) GetClusterServer() string

func (*ConnectInfo) GetError 

func (x *ConnectInfo) GetError() ConnectInfo_ErrType

func (*ConnectInfo) GetErrorText 

func (x *ConnectInfo) GetErrorText() string

func (*ConnectInfo) GetIngressInfos 

func (x *ConnectInfo) GetIngressInfos() []*manager.IngressInfo

func (*ConnectInfo) GetIntercepts 

func (x *ConnectInfo) GetIntercepts() *manager.InterceptInfoSnapshot

func (*ConnectInfo) GetSessionInfo 

func (x *ConnectInfo) GetSessionInfo() *manager.SessionInfo

func (*ConnectInfo) ProtoMessage 

func (*ConnectInfo) ProtoMessage()

func (*ConnectInfo) ProtoReflect 

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

func (*ConnectInfo) Reset 

func (x *ConnectInfo) Reset()

func (*ConnectInfo) String 

func (x *ConnectInfo) String() string

type ConnectInfo_ErrType 

type ConnectInfo_ErrType int32
const (
	ConnectInfo_UNSPECIFIED            ConnectInfo_ErrType = 0 // success
	ConnectInfo_NOT_STARTED            ConnectInfo_ErrType = 1
	ConnectInfo_ALREADY_CONNECTED      ConnectInfo_ErrType = 2 // success
	ConnectInfo_DISCONNECTING          ConnectInfo_ErrType = 3
	ConnectInfo_CLUSTER_FAILED         ConnectInfo_ErrType = 4
	ConnectInfo_BRIDGE_FAILED          ConnectInfo_ErrType = 5
	ConnectInfo_TRAFFIC_MANAGER_FAILED ConnectInfo_ErrType = 6
	ConnectInfo_MUST_RESTART           ConnectInfo_ErrType = 7
)

func (ConnectInfo_ErrType) Descriptor 

func (ConnectInfo_ErrType) Descriptor() protoreflect.EnumDescriptor

func (ConnectInfo_ErrType) Enum 

func (x ConnectInfo_ErrType) Enum() *ConnectInfo_ErrType

func (ConnectInfo_ErrType) EnumDescriptor deprecated 

func (ConnectInfo_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectInfo_ErrType.Descriptor instead.

func (ConnectInfo_ErrType) Number 

func (x ConnectInfo_ErrType) Number() protoreflect.EnumNumber

func (ConnectInfo_ErrType) String 

func (x ConnectInfo_ErrType) String() string

func (ConnectInfo_ErrType) Type 

func (ConnectInfo_ErrType) Type() protoreflect.EnumType

type ConnectRequest 

type ConnectRequest struct {
	KubeFlags        map[string]string `` /* 176-byte string literal not displayed */
	MappedNamespaces []string          `protobuf:"bytes,2,rep,name=mapped_namespaces,json=mappedNamespaces,proto3" json:"mapped_namespaces,omitempty"`
	// contains filtered or unexported fields
}

ConnectRequest contains the information needed to connect ot a cluster.

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetKubeFlags 

func (x *ConnectRequest) GetKubeFlags() map[string]string

func (*ConnectRequest) GetMappedNamespaces 

func (x *ConnectRequest) GetMappedNamespaces() []string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectorClient 

type ConnectorClient interface {
	// Returns version information from the Connector
	Version(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.VersionInfo, error)
	// Connects to the cluster and connects the laptop's network (via
	// the daemon process) to the cluster's network.  A result code of
	// UNSPECIFIED indicates that the connection was successfully
	// initiated; if already connected, then either ALREADY_CONNECTED or
	// MUST_RESTART is returned, based on whether the current connection
	// is in agreement with the ConnectionRequest.
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectInfo, error)
	// Adds a deployment intercept.  Requires having already called
	// Connect.
	CreateIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptResult, error)
	// Deactivates and removes an existent deployment intercept.
	// Requires having already called Connect.
	RemoveIntercept(ctx context.Context, in *manager.RemoveInterceptRequest2, opts ...grpc.CallOption) (*InterceptResult, error)
	// Uninstalls traffic-agents and traffic-manager from the cluster.
	// Requires having already called Connect.
	Uninstall(ctx context.Context, in *UninstallRequest, opts ...grpc.CallOption) (*UninstallResult, error)
	// Returns a list of deployments and their current intercept status.
	// Requires having already called Connect.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*DeploymentInfoSnapshot, error)
	// Quits (terminates) the connector process.
	Quit(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

ConnectorClient is the client API for Connector 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 NewConnectorClient 

func NewConnectorClient(cc grpc.ClientConnInterface) ConnectorClient

type ConnectorServer 

type ConnectorServer interface {
	// Returns version information from the Connector
	Version(context.Context, *empty.Empty) (*common.VersionInfo, error)
	// Connects to the cluster and connects the laptop's network (via
	// the daemon process) to the cluster's network.  A result code of
	// UNSPECIFIED indicates that the connection was successfully
	// initiated; if already connected, then either ALREADY_CONNECTED or
	// MUST_RESTART is returned, based on whether the current connection
	// is in agreement with the ConnectionRequest.
	Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)
	// Adds a deployment intercept.  Requires having already called
	// Connect.
	CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
	// Deactivates and removes an existent deployment intercept.
	// Requires having already called Connect.
	RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)
	// Uninstalls traffic-agents and traffic-manager from the cluster.
	// Requires having already called Connect.
	Uninstall(context.Context, *UninstallRequest) (*UninstallResult, error)
	// Returns a list of deployments and their current intercept status.
	// Requires having already called Connect.
	List(context.Context, *ListRequest) (*DeploymentInfoSnapshot, error)
	// Quits (terminates) the connector process.
	Quit(context.Context, *empty.Empty) (*empty.Empty, error)
	// contains filtered or unexported methods
}

ConnectorServer is the server API for Connector service. All implementations must embed UnimplementedConnectorServer for forward compatibility

type CreateInterceptRequest 

type CreateInterceptRequest struct {

	// No need to set spec.client; the connector will fill that in for
	// you.
	Spec       *manager.InterceptSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	MountPoint string                 `protobuf:"bytes,2,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	AgentImage string                 `protobuf:"bytes,3,opt,name=agent_image,json=agentImage,proto3" json:"agent_image,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateInterceptRequest) Descriptor deprecated 

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

Deprecated: Use CreateInterceptRequest.ProtoReflect.Descriptor instead.

func (*CreateInterceptRequest) GetAgentImage 

func (x *CreateInterceptRequest) GetAgentImage() string

func (*CreateInterceptRequest) GetMountPoint 

func (x *CreateInterceptRequest) GetMountPoint() string

func (*CreateInterceptRequest) GetSpec 

func (x *CreateInterceptRequest) GetSpec() *manager.InterceptSpec

func (*CreateInterceptRequest) ProtoMessage 

func (*CreateInterceptRequest) ProtoMessage()

func (*CreateInterceptRequest) ProtoReflect 

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

func (*CreateInterceptRequest) Reset 

func (x *CreateInterceptRequest) Reset()

func (*CreateInterceptRequest) String 

func (x *CreateInterceptRequest) String() string

type DeploymentInfo 

type DeploymentInfo struct {

	// Name of deployment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Reason why deployment cannot be intercepted, or empty if it can.
	NotInterceptableReason string `` /* 129-byte string literal not displayed */
	// AgentInfo reported from the traffic manager in case the deployment has a traffic-agent installed
	AgentInfo *manager.AgentInfo `protobuf:"bytes,3,opt,name=agent_info,json=agentInfo,proto3" json:"agent_info,omitempty"`
	// InterceptInfo reported from the traffic manager in case the deployment is currently intercepted
	InterceptInfo *manager.InterceptInfo `protobuf:"bytes,4,opt,name=intercept_info,json=interceptInfo,proto3" json:"intercept_info,omitempty"`
	// contains filtered or unexported fields
}

DeploymentInfo contains information about a deployment

func (*DeploymentInfo) Descriptor deprecated 

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

Deprecated: Use DeploymentInfo.ProtoReflect.Descriptor instead.

func (*DeploymentInfo) GetAgentInfo 

func (x *DeploymentInfo) GetAgentInfo() *manager.AgentInfo

func (*DeploymentInfo) GetInterceptInfo 

func (x *DeploymentInfo) GetInterceptInfo() *manager.InterceptInfo

func (*DeploymentInfo) GetName 

func (x *DeploymentInfo) GetName() string

func (*DeploymentInfo) GetNotInterceptableReason 

func (x *DeploymentInfo) GetNotInterceptableReason() string

func (*DeploymentInfo) ProtoMessage 

func (*DeploymentInfo) ProtoMessage()

func (*DeploymentInfo) ProtoReflect 

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

func (*DeploymentInfo) Reset 

func (x *DeploymentInfo) Reset()

func (*DeploymentInfo) String 

func (x *DeploymentInfo) String() string

type DeploymentInfoSnapshot 

type DeploymentInfoSnapshot struct {
	Deployments []*DeploymentInfo `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentInfoSnapshot) Descriptor deprecated 

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

Deprecated: Use DeploymentInfoSnapshot.ProtoReflect.Descriptor instead.

func (*DeploymentInfoSnapshot) GetDeployments 

func (x *DeploymentInfoSnapshot) GetDeployments() []*DeploymentInfo

func (*DeploymentInfoSnapshot) ProtoMessage 

func (*DeploymentInfoSnapshot) ProtoMessage()

func (*DeploymentInfoSnapshot) ProtoReflect 

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

func (*DeploymentInfoSnapshot) Reset 

func (x *DeploymentInfoSnapshot) Reset()

func (*DeploymentInfoSnapshot) String 

func (x *DeploymentInfoSnapshot) String() string

type InterceptError 

type InterceptError int32

InterceptError is a common error type used by the intercept call family (add, remove, list, available). 

const (
	InterceptError_UNSPECIFIED                InterceptError = 0
	InterceptError_NO_PREVIEW_HOST            InterceptError = 1
	InterceptError_NO_CONNECTION              InterceptError = 2
	InterceptError_NO_TRAFFIC_MANAGER         InterceptError = 3
	InterceptError_TRAFFIC_MANAGER_CONNECTING InterceptError = 4
	InterceptError_TRAFFIC_MANAGER_ERROR      InterceptError = 5
	InterceptError_ALREADY_EXISTS             InterceptError = 6
	InterceptError_LOCAL_TARGET_IN_USE        InterceptError = 7
	InterceptError_NO_ACCEPTABLE_DEPLOYMENT   InterceptError = 8
	InterceptError_AMBIGUOUS_MATCH            InterceptError = 9
	InterceptError_FAILED_TO_ESTABLISH        InterceptError = 10
	InterceptError_FAILED_TO_REMOVE           InterceptError = 11
	InterceptError_NOT_FOUND                  InterceptError = 12
	InterceptError_MOUNT_POINT_BUSY           InterceptError = 13
)

func (InterceptError) Descriptor 

func (InterceptError) Descriptor() protoreflect.EnumDescriptor

func (InterceptError) Enum 

func (x InterceptError) Enum() *InterceptError

func (InterceptError) EnumDescriptor deprecated 

func (InterceptError) EnumDescriptor() ([]byte, []int)

Deprecated: Use InterceptError.Descriptor instead.

func (InterceptError) Number 

func (x InterceptError) Number() protoreflect.EnumNumber

func (InterceptError) String 

func (x InterceptError) String() string

func (InterceptError) Type 

func (InterceptError) Type() protoreflect.EnumType

type InterceptResult 

type InterceptResult struct {
	InterceptInfo *manager.InterceptInfo `protobuf:"bytes,1,opt,name=intercept_info,json=interceptInfo,proto3" json:"intercept_info,omitempty"`
	Error         InterceptError         `protobuf:"varint,2,opt,name=error,proto3,enum=telepresence.connector.InterceptError" json:"error,omitempty"`
	ErrorText     string                 `protobuf:"bytes,3,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	// The environment of the app
	Environment map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InterceptResult) Descriptor deprecated 

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

Deprecated: Use InterceptResult.ProtoReflect.Descriptor instead.

func (*InterceptResult) GetEnvironment 

func (x *InterceptResult) GetEnvironment() map[string]string

func (*InterceptResult) GetError 

func (x *InterceptResult) GetError() InterceptError

func (*InterceptResult) GetErrorText 

func (x *InterceptResult) GetErrorText() string

func (*InterceptResult) GetInterceptInfo 

func (x *InterceptResult) GetInterceptInfo() *manager.InterceptInfo

func (*InterceptResult) ProtoMessage 

func (*InterceptResult) ProtoMessage()

func (*InterceptResult) ProtoReflect 

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

func (*InterceptResult) Reset 

func (x *InterceptResult) Reset()

func (*InterceptResult) String 

func (x *InterceptResult) String() string

type ListRequest 

type ListRequest struct {
	Filter ListRequest_Filter `protobuf:"varint,1,opt,name=filter,proto3,enum=telepresence.connector.ListRequest_Filter" json:"filter,omitempty"`
	// Namespace to list.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetFilter 

func (x *ListRequest) GetFilter() ListRequest_Filter

func (*ListRequest) GetNamespace 

func (x *ListRequest) GetNamespace() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListRequest_Filter 

type ListRequest_Filter int32
const (
	ListRequest_UNSPECIFIED      ListRequest_Filter = 0
	ListRequest_INTERCEPTS       ListRequest_Filter = 1
	ListRequest_INSTALLED_AGENTS ListRequest_Filter = 2
	ListRequest_INTERCEPTABLE    ListRequest_Filter = 3
	ListRequest_EVERYTHING       ListRequest_Filter = 4
)

func (ListRequest_Filter) Descriptor 

func (ListRequest_Filter) Descriptor() protoreflect.EnumDescriptor

func (ListRequest_Filter) Enum 

func (x ListRequest_Filter) Enum() *ListRequest_Filter

func (ListRequest_Filter) EnumDescriptor deprecated 

func (ListRequest_Filter) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListRequest_Filter.Descriptor instead.

func (ListRequest_Filter) Number 

func (x ListRequest_Filter) Number() protoreflect.EnumNumber

func (ListRequest_Filter) String 

func (x ListRequest_Filter) String() string

func (ListRequest_Filter) Type 

func (ListRequest_Filter) Type() protoreflect.EnumType

type UnimplementedConnectorServer 

type UnimplementedConnectorServer struct {
}

UnimplementedConnectorServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServer) Connect 

func (UnimplementedConnectorServer) Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)

func (UnimplementedConnectorServer) CreateIntercept 

func (UnimplementedConnectorServer) CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)

func (UnimplementedConnectorServer) List 

func (UnimplementedConnectorServer) List(context.Context, *ListRequest) (*DeploymentInfoSnapshot, error)

func (UnimplementedConnectorServer) Quit 

func (UnimplementedConnectorServer) Quit(context.Context, *empty.Empty) (*empty.Empty, error)

func (UnimplementedConnectorServer) RemoveIntercept 

func (UnimplementedConnectorServer) RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)

func (UnimplementedConnectorServer) Uninstall 

func (UnimplementedConnectorServer) Uninstall(context.Context, *UninstallRequest) (*UninstallResult, error)

func (UnimplementedConnectorServer) Version 

func (UnimplementedConnectorServer) Version(context.Context, *empty.Empty) (*common.VersionInfo, error)

type UninstallRequest 

type UninstallRequest struct {
	UninstallType UninstallRequest_UninstallType `` /* 160-byte string literal not displayed */
	Agents        []string                       `protobuf:"bytes,2,rep,name=agents,proto3" json:"agents,omitempty"`
	// Namespace of agents to remove.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallRequest) Descriptor deprecated 

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

Deprecated: Use UninstallRequest.ProtoReflect.Descriptor instead.

func (*UninstallRequest) GetAgents 

func (x *UninstallRequest) GetAgents() []string

func (*UninstallRequest) GetNamespace 

func (x *UninstallRequest) GetNamespace() string

func (*UninstallRequest) GetUninstallType 

func (x *UninstallRequest) GetUninstallType() UninstallRequest_UninstallType

func (*UninstallRequest) ProtoMessage 

func (*UninstallRequest) ProtoMessage()

func (*UninstallRequest) ProtoReflect 

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

func (*UninstallRequest) Reset 

func (x *UninstallRequest) Reset()

func (*UninstallRequest) String 

func (x *UninstallRequest) String() string

type UninstallRequest_UninstallType 

type UninstallRequest_UninstallType int32
const (
	UninstallRequest_UNSPECIFIED UninstallRequest_UninstallType = 0
	// Uninstalls an agent from the named deployments
	UninstallRequest_NAMED_AGENTS UninstallRequest_UninstallType = 1
	// Uninstalls all agents
	UninstallRequest_ALL_AGENTS UninstallRequest_UninstallType = 2
	// Uninstalls all agents and the traffic-manager
	UninstallRequest_EVERYTHING UninstallRequest_UninstallType = 3
)

func (UninstallRequest_UninstallType) Descriptor 

func (UninstallRequest_UninstallType) Descriptor() protoreflect.EnumDescriptor

func (UninstallRequest_UninstallType) Enum 

func (x UninstallRequest_UninstallType) Enum() *UninstallRequest_UninstallType

func (UninstallRequest_UninstallType) EnumDescriptor deprecated 

func (UninstallRequest_UninstallType) EnumDescriptor() ([]byte, []int)

Deprecated: Use UninstallRequest_UninstallType.Descriptor instead.

func (UninstallRequest_UninstallType) Number 

func (x UninstallRequest_UninstallType) Number() protoreflect.EnumNumber

func (UninstallRequest_UninstallType) String 

func (x UninstallRequest_UninstallType) String() string

func (UninstallRequest_UninstallType) Type 

func (UninstallRequest_UninstallType) Type() protoreflect.EnumType

type UninstallResult 

type UninstallResult struct {
	ErrorText string `protobuf:"bytes,1,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	// contains filtered or unexported fields
}

func (*UninstallResult) Descriptor deprecated 

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

Deprecated: Use UninstallResult.ProtoReflect.Descriptor instead.

func (*UninstallResult) GetErrorText 

func (x *UninstallResult) GetErrorText() string

func (*UninstallResult) ProtoMessage 

func (*UninstallResult) ProtoMessage()

func (*UninstallResult) ProtoReflect 

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

func (*UninstallResult) Reset 

func (x *UninstallResult) Reset()

func (*UninstallResult) String 

func (x *UninstallResult) String() string

type UnsafeConnectorServer 

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

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

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.