connector

package
v2.4.3-rc.0 Latest Latest
Warning

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

Go to latest
Published: Sep 14, 2021 License: Apache-2.0 Imports: 11 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	InterceptError_name = map[int32]string{
		0:  "UNSPECIFIED",
		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_WORKLOAD",
		9:  "AMBIGUOUS_MATCH",
		10: "FAILED_TO_ESTABLISH",
		12: "NOT_FOUND",
		13: "MOUNT_POINT_BUSY",
	}
	InterceptError_value = map[string]int32{
		"UNSPECIFIED":                0,
		"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_WORKLOAD":     8,
		"AMBIGUOUS_MATCH":            9,
		"FAILED_TO_ESTABLISH":        10,
		"NOT_FOUND":                  12,
		"MOUNT_POINT_BUSY":           13,
	}
)

Enum value maps for InterceptError.

View Source
var (
	ConnectInfo_ErrType_name = map[int32]string{
		0: "UNSPECIFIED",
		2: "ALREADY_CONNECTED",
		7: "MUST_RESTART",
		3: "DISCONNECTED",
		4: "CLUSTER_FAILED",
		6: "TRAFFIC_MANAGER_FAILED",
		8: "DAEMON_FAILED",
	}
	ConnectInfo_ErrType_value = map[string]int32{
		"UNSPECIFIED":            0,
		"ALREADY_CONNECTED":      2,
		"MUST_RESTART":           7,
		"DISCONNECTED":           3,
		"CLUSTER_FAILED":         4,
		"TRAFFIC_MANAGER_FAILED": 6,
		"DAEMON_FAILED":          8,
	}
)

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 (
	LoginResult_Code_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "OLD_LOGIN_REUSED",
		2: "NEW_LOGIN_SUCCEEDED",
	}
	LoginResult_Code_value = map[string]int32{
		"UNSPECIFIED":         0,
		"OLD_LOGIN_REUSED":    1,
		"NEW_LOGIN_SUCCEEDED": 2,
	}
)

Enum value maps for LoginResult_Code.

View Source
var Connector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.connector.Connector",
	HandlerType: (*ConnectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Connector_Version_Handler,
		},
		{
			MethodName: "Connect",
			Handler:    _Connector_Connect_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _Connector_Status_Handler,
		},
		{
			MethodName: "CreateIntercept",
			Handler:    _Connector_CreateIntercept_Handler,
		},
		{
			MethodName: "RemoveIntercept",
			Handler:    _Connector_RemoveIntercept_Handler,
		},
		{
			MethodName: "Uninstall",
			Handler:    _Connector_Uninstall_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Connector_List_Handler,
		},
		{
			MethodName: "Login",
			Handler:    _Connector_Login_Handler,
		},
		{
			MethodName: "Logout",
			Handler:    _Connector_Logout_Handler,
		},
		{
			MethodName: "GetCloudUserInfo",
			Handler:    _Connector_GetCloudUserInfo_Handler,
		},
		{
			MethodName: "GetCloudAPIKey",
			Handler:    _Connector_GetCloudAPIKey_Handler,
		},
		{
			MethodName: "GetCloudLicense",
			Handler:    _Connector_GetCloudLicense_Handler,
		},
		{
			MethodName: "SetLogLevel",
			Handler:    _Connector_SetLogLevel_Handler,
		},
		{
			MethodName: "Quit",
			Handler:    _Connector_Quit_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UserNotifications",
			Handler:       _Connector_UserNotifications_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "rpc/connector/connector.proto",
}

Connector_ServiceDesc is the grpc.ServiceDesc for Connector 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_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"`
	// only set for some error codes, see above
	ErrorText      string                         `protobuf:"bytes,2,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	ErrorCategory  int32                          `protobuf:"varint,12,opt,name=error_category,json=errorCategory,proto3" json:"error_category,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"`
	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) GetClusterServer

func (x *ConnectInfo) GetClusterServer() string

func (*ConnectInfo) GetError

func (x *ConnectInfo) GetError() ConnectInfo_ErrType

func (*ConnectInfo) GetErrorCategory added in v2.4.3

func (x *ConnectInfo) GetErrorCategory() int32

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_ALREADY_CONNECTED ConnectInfo_ErrType = 2 // success
	ConnectInfo_MUST_RESTART      ConnectInfo_ErrType = 7 // would-be-success, but kubeconfig has changed
	// failure: Connect has not yet been called (only returned from Status)
	ConnectInfo_DISCONNECTED ConnectInfo_ErrType = 3
	// failure: error parsing kubeconfig or talking to the cluster; error_text and error_category are set
	ConnectInfo_CLUSTER_FAILED ConnectInfo_ErrType = 4
	// failure: error talking to the in-cluster traffic-manager; error_text and error_category are set
	ConnectInfo_TRAFFIC_MANAGER_FAILED ConnectInfo_ErrType = 6
	// failure: error talking to the on-laptop root daemon; error_text and error_category are set
	ConnectInfo_DAEMON_FAILED ConnectInfo_ErrType = 8
)

func (ConnectInfo_ErrType) Descriptor

func (ConnectInfo_ErrType) Enum

func (ConnectInfo_ErrType) EnumDescriptor deprecated

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

Deprecated: Use ConnectInfo_ErrType.Descriptor instead.

func (ConnectInfo_ErrType) Number

func (ConnectInfo_ErrType) String

func (x ConnectInfo_ErrType) String() string

func (ConnectInfo_ErrType) Type

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 *emptypb.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)
	// Status is much like Connect, except that it doesn't actually do
	// anything.  It's a dry-run.
	Status(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectInfo, error)
	// Adds an intercept to a workload.  Requires having already called
	// Connect.
	CreateIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptResult, error)
	// Deactivates and removes an existent workload 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 workloads and their current intercept status.
	// Requires having already called Connect.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*WorkloadInfoSnapshot, error)
	// Returns a stream of messages to display to the user.  Does NOT
	// require having called anything else first.
	UserNotifications(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Connector_UserNotificationsClient, error)
	Login(ctx context.Context, in *LoginRequest, opts ...grpc.CallOption) (*LoginResult, error)
	// Returns an error with code=NotFound if not currently logged in.
	Logout(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetCloudUserInfo(ctx context.Context, in *UserInfoRequest, opts ...grpc.CallOption) (*UserInfo, error)
	GetCloudAPIKey(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*KeyData, error)
	GetCloudLicense(ctx context.Context, in *LicenseRequest, opts ...grpc.CallOption) (*LicenseData, error)
	// SetLogLevel will temporarily set the log-level for the daemon for a duration that is determined by the request.
	SetLogLevel(ctx context.Context, in *manager.LogLevelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Quits (terminates) the connector process.
	Quit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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, *emptypb.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)
	// Status is much like Connect, except that it doesn't actually do
	// anything.  It's a dry-run.
	Status(context.Context, *ConnectRequest) (*ConnectInfo, error)
	// Adds an intercept to a workload.  Requires having already called
	// Connect.
	CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
	// Deactivates and removes an existent workload 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 workloads and their current intercept status.
	// Requires having already called Connect.
	List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error)
	// Returns a stream of messages to display to the user.  Does NOT
	// require having called anything else first.
	UserNotifications(*emptypb.Empty, Connector_UserNotificationsServer) error
	Login(context.Context, *LoginRequest) (*LoginResult, error)
	// Returns an error with code=NotFound if not currently logged in.
	Logout(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetCloudUserInfo(context.Context, *UserInfoRequest) (*UserInfo, error)
	GetCloudAPIKey(context.Context, *KeyRequest) (*KeyData, error)
	GetCloudLicense(context.Context, *LicenseRequest) (*LicenseData, error)
	// SetLogLevel will temporarily set the log-level for the daemon for a duration that is determined by the request.
	SetLogLevel(context.Context, *manager.LogLevelRequest) (*emptypb.Empty, error)
	// Quits (terminates) the connector process.
	Quit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

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

type Connector_UserNotificationsClient added in v2.1.4

type Connector_UserNotificationsClient interface {
	Recv() (*Notification, error)
	grpc.ClientStream
}

type Connector_UserNotificationsServer added in v2.1.4

type Connector_UserNotificationsServer interface {
	Send(*Notification) error
	grpc.ServerStream
}

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 (*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 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 // no error
	InterceptError_NO_CONNECTION              InterceptError = 2 // Have not made the .Connect RPC call (or it errored)
	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_WORKLOAD     InterceptError = 8
	InterceptError_AMBIGUOUS_MATCH            InterceptError = 9
	InterceptError_FAILED_TO_ESTABLISH        InterceptError = 10
	InterceptError_NOT_FOUND                  InterceptError = 12
	InterceptError_MOUNT_POINT_BUSY           InterceptError = 13
)

func (InterceptError) Descriptor

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 (InterceptError) String

func (x InterceptError) String() string

func (InterceptError) Type

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"`
	ErrorCategory int32                  `protobuf:"varint,7,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	// The environment of the app
	Environment map[string]string `` /* 163-byte string literal not displayed */
	// The service uid associated with the workload intercepted
	ServiceUid string `protobuf:"bytes,5,opt,name=service_uid,json=serviceUid,proto3" json:"service_uid,omitempty"`
	// The kind of workload in this intercept
	WorkloadKind string `protobuf:"bytes,6,opt,name=workload_kind,json=workloadKind,proto3" json:"workload_kind,omitempty"`
	// 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) GetErrorCategory added in v2.4.3

func (x *InterceptResult) GetErrorCategory() int32

func (*InterceptResult) GetErrorText

func (x *InterceptResult) GetErrorText() string

func (*InterceptResult) GetInterceptInfo

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

func (*InterceptResult) GetServiceUid added in v2.1.2

func (x *InterceptResult) GetServiceUid() string

func (*InterceptResult) GetWorkloadKind added in v2.1.3

func (x *InterceptResult) GetWorkloadKind() string

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 KeyData added in v2.1.4

type KeyData struct {
	ApiKey string `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyData) Descriptor deprecated added in v2.1.4

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

Deprecated: Use KeyData.ProtoReflect.Descriptor instead.

func (*KeyData) GetApiKey added in v2.1.4

func (x *KeyData) GetApiKey() string

func (*KeyData) ProtoMessage added in v2.1.4

func (*KeyData) ProtoMessage()

func (*KeyData) ProtoReflect added in v2.1.4

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

func (*KeyData) Reset added in v2.1.4

func (x *KeyData) Reset()

func (*KeyData) String added in v2.1.4

func (x *KeyData) String() string

type KeyRequest added in v2.1.4

type KeyRequest struct {
	AutoLogin   bool   `protobuf:"varint,1,opt,name=auto_login,json=autoLogin,proto3" json:"auto_login,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRequest) Descriptor deprecated added in v2.1.4

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetAutoLogin added in v2.1.4

func (x *KeyRequest) GetAutoLogin() bool

func (*KeyRequest) GetDescription added in v2.1.4

func (x *KeyRequest) GetDescription() string

func (*KeyRequest) ProtoMessage added in v2.1.4

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect added in v2.1.4

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

func (*KeyRequest) Reset added in v2.1.4

func (x *KeyRequest) Reset()

func (*KeyRequest) String added in v2.1.4

func (x *KeyRequest) String() string

type LicenseData added in v2.2.0

type LicenseData struct {
	License    string `protobuf:"bytes,1,opt,name=license,proto3" json:"license,omitempty"`
	HostDomain string `protobuf:"bytes,2,opt,name=host_domain,json=hostDomain,proto3" json:"host_domain,omitempty"`
	// contains filtered or unexported fields
}

func (*LicenseData) Descriptor deprecated added in v2.2.0

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

Deprecated: Use LicenseData.ProtoReflect.Descriptor instead.

func (*LicenseData) GetHostDomain added in v2.2.0

func (x *LicenseData) GetHostDomain() string

func (*LicenseData) GetLicense added in v2.2.0

func (x *LicenseData) GetLicense() string

func (*LicenseData) ProtoMessage added in v2.2.0

func (*LicenseData) ProtoMessage()

func (*LicenseData) ProtoReflect added in v2.2.0

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

func (*LicenseData) Reset added in v2.2.0

func (x *LicenseData) Reset()

func (*LicenseData) String added in v2.2.0

func (x *LicenseData) String() string

type LicenseRequest added in v2.2.0

type LicenseRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*LicenseRequest) Descriptor deprecated added in v2.2.0

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

Deprecated: Use LicenseRequest.ProtoReflect.Descriptor instead.

func (*LicenseRequest) GetId added in v2.2.0

func (x *LicenseRequest) GetId() string

func (*LicenseRequest) ProtoMessage added in v2.2.0

func (*LicenseRequest) ProtoMessage()

func (*LicenseRequest) ProtoReflect added in v2.2.0

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

func (*LicenseRequest) Reset added in v2.2.0

func (x *LicenseRequest) Reset()

func (*LicenseRequest) String added in v2.2.0

func (x *LicenseRequest) 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) Enum

func (ListRequest_Filter) EnumDescriptor deprecated

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

Deprecated: Use ListRequest_Filter.Descriptor instead.

func (ListRequest_Filter) Number

func (ListRequest_Filter) String

func (x ListRequest_Filter) String() string

func (ListRequest_Filter) Type

type LoginRequest added in v2.3.7

type LoginRequest struct {
	ApiKey string `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated added in v2.3.7

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetApiKey added in v2.3.7

func (x *LoginRequest) GetApiKey() string

func (*LoginRequest) ProtoMessage added in v2.3.7

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect added in v2.3.7

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

func (*LoginRequest) Reset added in v2.3.7

func (x *LoginRequest) Reset()

func (*LoginRequest) String added in v2.3.7

func (x *LoginRequest) String() string

type LoginResult added in v2.1.4

type LoginResult struct {
	Code LoginResult_Code `protobuf:"varint,1,opt,name=code,proto3,enum=telepresence.connector.LoginResult_Code" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResult) Descriptor deprecated added in v2.1.4

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

Deprecated: Use LoginResult.ProtoReflect.Descriptor instead.

func (*LoginResult) GetCode added in v2.1.4

func (x *LoginResult) GetCode() LoginResult_Code

func (*LoginResult) ProtoMessage added in v2.1.4

func (*LoginResult) ProtoMessage()

func (*LoginResult) ProtoReflect added in v2.1.4

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

func (*LoginResult) Reset added in v2.1.4

func (x *LoginResult) Reset()

func (*LoginResult) String added in v2.1.4

func (x *LoginResult) String() string

type LoginResult_Code added in v2.1.4

type LoginResult_Code int32
const (
	LoginResult_UNSPECIFIED         LoginResult_Code = 0
	LoginResult_OLD_LOGIN_REUSED    LoginResult_Code = 1 // success; already logged in
	LoginResult_NEW_LOGIN_SUCCEEDED LoginResult_Code = 2 // success
)

func (LoginResult_Code) Descriptor added in v2.1.4

func (LoginResult_Code) Enum added in v2.1.4

func (LoginResult_Code) EnumDescriptor deprecated added in v2.1.4

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

Deprecated: Use LoginResult_Code.Descriptor instead.

func (LoginResult_Code) Number added in v2.1.4

func (LoginResult_Code) String added in v2.1.4

func (x LoginResult_Code) String() string

func (LoginResult_Code) Type added in v2.1.4

type Notification added in v2.1.4

type Notification struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor deprecated added in v2.1.4

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetMessage added in v2.1.4

func (x *Notification) GetMessage() string

func (*Notification) ProtoMessage added in v2.1.4

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect added in v2.1.4

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

func (*Notification) Reset added in v2.1.4

func (x *Notification) Reset()

func (*Notification) String added in v2.1.4

func (x *Notification) String() string

type UnimplementedConnectorServer

type UnimplementedConnectorServer struct {
}

UnimplementedConnectorServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServer) Connect

func (UnimplementedConnectorServer) CreateIntercept

func (UnimplementedConnectorServer) GetCloudAPIKey added in v2.1.4

func (UnimplementedConnectorServer) GetCloudLicense added in v2.2.0

func (UnimplementedConnectorServer) GetCloudUserInfo added in v2.3.7

func (UnimplementedConnectorServer) List

func (UnimplementedConnectorServer) Login added in v2.1.4

func (UnimplementedConnectorServer) Logout added in v2.1.4

func (UnimplementedConnectorServer) Quit

func (UnimplementedConnectorServer) RemoveIntercept

func (UnimplementedConnectorServer) SetLogLevel added in v2.4.2

func (UnimplementedConnectorServer) Status added in v2.1.4

func (UnimplementedConnectorServer) Uninstall

func (UnimplementedConnectorServer) UserNotifications added in v2.1.4

func (UnimplementedConnectorServer) Version

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 workloads
	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) Enum

func (UninstallRequest_UninstallType) EnumDescriptor deprecated

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

Deprecated: Use UninstallRequest_UninstallType.Descriptor instead.

func (UninstallRequest_UninstallType) Number

func (UninstallRequest_UninstallType) String

func (UninstallRequest_UninstallType) Type

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.

type UserInfo added in v2.3.7

type UserInfo struct {
	Id               string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name             string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	AvatarUrl        string `protobuf:"bytes,3,opt,name=avatarUrl,proto3" json:"avatarUrl,omitempty"`
	AccountId        string `protobuf:"bytes,4,opt,name=accountId,proto3" json:"accountId,omitempty"`
	AccountName      string `protobuf:"bytes,5,opt,name=accountName,proto3" json:"accountName,omitempty"`
	AccountAvatarUrl string `protobuf:"bytes,6,opt,name=accountAvatarUrl,proto3" json:"accountAvatarUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfo) Descriptor deprecated added in v2.3.7

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAccountAvatarUrl added in v2.3.7

func (x *UserInfo) GetAccountAvatarUrl() string

func (*UserInfo) GetAccountId added in v2.3.7

func (x *UserInfo) GetAccountId() string

func (*UserInfo) GetAccountName added in v2.3.7

func (x *UserInfo) GetAccountName() string

func (*UserInfo) GetAvatarUrl added in v2.3.7

func (x *UserInfo) GetAvatarUrl() string

func (*UserInfo) GetId added in v2.3.7

func (x *UserInfo) GetId() string

func (*UserInfo) GetName added in v2.3.7

func (x *UserInfo) GetName() string

func (*UserInfo) ProtoMessage added in v2.3.7

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect added in v2.3.7

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

func (*UserInfo) Reset added in v2.3.7

func (x *UserInfo) Reset()

func (*UserInfo) String added in v2.3.7

func (x *UserInfo) String() string

type UserInfoRequest added in v2.3.7

type UserInfoRequest struct {
	AutoLogin bool `protobuf:"varint,1,opt,name=auto_login,json=autoLogin,proto3" json:"auto_login,omitempty"`
	Refresh   bool `protobuf:"varint,2,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func (*UserInfoRequest) Descriptor deprecated added in v2.3.7

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

Deprecated: Use UserInfoRequest.ProtoReflect.Descriptor instead.

func (*UserInfoRequest) GetAutoLogin added in v2.3.7

func (x *UserInfoRequest) GetAutoLogin() bool

func (*UserInfoRequest) GetRefresh added in v2.3.7

func (x *UserInfoRequest) GetRefresh() bool

func (*UserInfoRequest) ProtoMessage added in v2.3.7

func (*UserInfoRequest) ProtoMessage()

func (*UserInfoRequest) ProtoReflect added in v2.3.7

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

func (*UserInfoRequest) Reset added in v2.3.7

func (x *UserInfoRequest) Reset()

func (*UserInfoRequest) String added in v2.3.7

func (x *UserInfoRequest) String() string

type WorkloadInfo added in v2.1.3

type WorkloadInfo struct {

	// Name of workload
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Reason why workload 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 workload 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 workload is currently intercepted
	InterceptInfo *manager.InterceptInfo `protobuf:"bytes,4,opt,name=intercept_info,json=interceptInfo,proto3" json:"intercept_info,omitempty"`
	// Workload Resource type (e.g. Deployment, ReplicaSet, StatefulSet)
	WorkloadResourceType string `protobuf:"bytes,5,opt,name=workload_resource_type,json=workloadResourceType,proto3" json:"workload_resource_type,omitempty"`
	// contains filtered or unexported fields
}

WorkloadInfo contains information about a workload https://kubernetes.io/docs/concepts/workloads/

func (*WorkloadInfo) Descriptor deprecated added in v2.1.3

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

Deprecated: Use WorkloadInfo.ProtoReflect.Descriptor instead.

func (*WorkloadInfo) GetAgentInfo added in v2.1.3

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

func (*WorkloadInfo) GetInterceptInfo added in v2.1.3

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

func (*WorkloadInfo) GetName added in v2.1.3

func (x *WorkloadInfo) GetName() string

func (*WorkloadInfo) GetNotInterceptableReason added in v2.1.3

func (x *WorkloadInfo) GetNotInterceptableReason() string

func (*WorkloadInfo) GetWorkloadResourceType added in v2.1.3

func (x *WorkloadInfo) GetWorkloadResourceType() string

func (*WorkloadInfo) ProtoMessage added in v2.1.3

func (*WorkloadInfo) ProtoMessage()

func (*WorkloadInfo) ProtoReflect added in v2.1.3

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

func (*WorkloadInfo) Reset added in v2.1.3

func (x *WorkloadInfo) Reset()

func (*WorkloadInfo) String added in v2.1.3

func (x *WorkloadInfo) String() string

type WorkloadInfoSnapshot added in v2.1.3

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

func (*WorkloadInfoSnapshot) Descriptor deprecated added in v2.1.3

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

Deprecated: Use WorkloadInfoSnapshot.ProtoReflect.Descriptor instead.

func (*WorkloadInfoSnapshot) GetWorkloads added in v2.1.3

func (x *WorkloadInfoSnapshot) GetWorkloads() []*WorkloadInfo

func (*WorkloadInfoSnapshot) ProtoMessage added in v2.1.3

func (*WorkloadInfoSnapshot) ProtoMessage()

func (*WorkloadInfoSnapshot) ProtoReflect added in v2.1.3

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

func (*WorkloadInfoSnapshot) Reset added in v2.1.3

func (x *WorkloadInfoSnapshot) Reset()

func (*WorkloadInfoSnapshot) String added in v2.1.3

func (x *WorkloadInfoSnapshot) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL