Documentation ¶
Index ¶
- Variables
- func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)
- type CommandGroups
- func (*CommandGroups) Descriptor() ([]byte, []int)deprecated
- func (x *CommandGroups) GetCommandGroups() map[string]*CommandGroups_Commands
- func (*CommandGroups) ProtoMessage()
- func (x *CommandGroups) ProtoReflect() protoreflect.Message
- func (x *CommandGroups) Reset()
- func (x *CommandGroups) String() string
- type CommandGroups_Command
- func (*CommandGroups_Command) Descriptor() ([]byte, []int)deprecated
- func (x *CommandGroups_Command) GetFlags() []*CommandGroups_Flag
- func (x *CommandGroups_Command) GetLongHelp() string
- func (x *CommandGroups_Command) GetName() string
- func (x *CommandGroups_Command) GetShortHelp() string
- func (*CommandGroups_Command) ProtoMessage()
- func (x *CommandGroups_Command) ProtoReflect() protoreflect.Message
- func (x *CommandGroups_Command) Reset()
- func (x *CommandGroups_Command) String() string
- type CommandGroups_Commands
- func (*CommandGroups_Commands) Descriptor() ([]byte, []int)deprecated
- func (x *CommandGroups_Commands) GetCommands() []*CommandGroups_Command
- func (*CommandGroups_Commands) ProtoMessage()
- func (x *CommandGroups_Commands) ProtoReflect() protoreflect.Message
- func (x *CommandGroups_Commands) Reset()
- func (x *CommandGroups_Commands) String() string
- type CommandGroups_Flag
- func (*CommandGroups_Flag) Descriptor() ([]byte, []int)deprecated
- func (x *CommandGroups_Flag) GetDefaultValue() string
- func (x *CommandGroups_Flag) GetFlag() string
- func (x *CommandGroups_Flag) GetHelp() string
- func (x *CommandGroups_Flag) GetShorthand() string
- func (x *CommandGroups_Flag) GetType() string
- func (*CommandGroups_Flag) ProtoMessage()
- func (x *CommandGroups_Flag) ProtoReflect() protoreflect.Message
- func (x *CommandGroups_Flag) Reset()
- func (x *CommandGroups_Flag) String() string
- type ConnectInfo
- func (*ConnectInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectInfo) GetClusterContext() string
- func (x *ConnectInfo) GetClusterId() string
- func (x *ConnectInfo) GetClusterServer() string
- func (x *ConnectInfo) GetError() ConnectInfo_ErrType
- func (x *ConnectInfo) GetErrorCategory() int32
- func (x *ConnectInfo) GetErrorText() string
- func (x *ConnectInfo) GetIntercepts() *manager.InterceptInfoSnapshot
- func (x *ConnectInfo) GetSessionInfo() *manager.SessionInfo
- func (*ConnectInfo) ProtoMessage()
- func (x *ConnectInfo) ProtoReflect() protoreflect.Message
- func (x *ConnectInfo) Reset()
- func (x *ConnectInfo) String() string
- type ConnectInfo_ErrType
- func (ConnectInfo_ErrType) Descriptor() protoreflect.EnumDescriptor
- func (x ConnectInfo_ErrType) Enum() *ConnectInfo_ErrType
- func (ConnectInfo_ErrType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConnectInfo_ErrType) Number() protoreflect.EnumNumber
- func (x ConnectInfo_ErrType) String() string
- func (ConnectInfo_ErrType) Type() protoreflect.EnumType
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRequest) GetIsPodDaemon() bool
- func (x *ConnectRequest) GetKubeFlags() map[string]string
- func (x *ConnectRequest) GetMappedNamespaces() []string
- func (*ConnectRequest) ProtoMessage()
- func (x *ConnectRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectRequest) Reset()
- func (x *ConnectRequest) String() string
- type ConnectorClient
- type ConnectorServer
- type Connector_RunCommandClient
- type Connector_RunCommandServer
- type Connector_UserNotificationsClient
- type Connector_UserNotificationsServer
- type Connector_WatchWorkloadsClient
- type Connector_WatchWorkloadsServer
- type CreateInterceptRequest
- func (*CreateInterceptRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateInterceptRequest) GetAgentImage() string
- func (x *CreateInterceptRequest) GetIsPodDaemon() bool
- func (x *CreateInterceptRequest) GetMountPoint() string
- func (x *CreateInterceptRequest) GetSpec() *manager.InterceptSpec
- func (*CreateInterceptRequest) ProtoMessage()
- func (x *CreateInterceptRequest) ProtoReflect() protoreflect.Message
- func (x *CreateInterceptRequest) Reset()
- func (x *CreateInterceptRequest) String() string
- type GetNamespacesRequest
- func (*GetNamespacesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespacesRequest) GetForClientAccess() bool
- func (x *GetNamespacesRequest) GetPrefix() string
- func (*GetNamespacesRequest) ProtoMessage()
- func (x *GetNamespacesRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespacesRequest) Reset()
- func (x *GetNamespacesRequest) String() string
- type GetNamespacesResponse
- func (*GetNamespacesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespacesResponse) GetNamespaces() []string
- func (*GetNamespacesResponse) ProtoMessage()
- func (x *GetNamespacesResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespacesResponse) Reset()
- func (x *GetNamespacesResponse) String() string
- type HelmRequest
- func (*HelmRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HelmRequest) GetConnectRequest() *ConnectRequest
- func (x *HelmRequest) GetType() HelmRequest_Type
- func (x *HelmRequest) GetValuePaths() []string
- func (*HelmRequest) ProtoMessage()
- func (x *HelmRequest) ProtoReflect() protoreflect.Message
- func (x *HelmRequest) Reset()
- func (x *HelmRequest) String() string
- type HelmRequest_Type
- func (HelmRequest_Type) Descriptor() protoreflect.EnumDescriptor
- func (x HelmRequest_Type) Enum() *HelmRequest_Type
- func (HelmRequest_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x HelmRequest_Type) Number() protoreflect.EnumNumber
- func (x HelmRequest_Type) String() string
- func (HelmRequest_Type) Type() protoreflect.EnumType
- type IngressInfos
- type InterceptResult
- func (*InterceptResult) Descriptor() ([]byte, []int)deprecated
- func (x *InterceptResult) GetError() common.InterceptError
- func (x *InterceptResult) GetErrorCategory() int32
- func (x *InterceptResult) GetErrorText() string
- func (x *InterceptResult) GetInterceptInfo() *manager.InterceptInfo
- func (x *InterceptResult) GetServiceProps() *userdaemon.IngressInfoRequest
- func (x *InterceptResult) GetServiceUid() string
- func (x *InterceptResult) GetWorkloadKind() string
- func (*InterceptResult) ProtoMessage()
- func (x *InterceptResult) ProtoReflect() protoreflect.Message
- func (x *InterceptResult) Reset()
- func (x *InterceptResult) String() string
- type Interceptor
- func (*Interceptor) Descriptor() ([]byte, []int)deprecated
- func (x *Interceptor) GetInterceptId() string
- func (x *Interceptor) GetPid() int32
- func (*Interceptor) ProtoMessage()
- func (x *Interceptor) ProtoReflect() protoreflect.Message
- func (x *Interceptor) Reset()
- func (x *Interceptor) String() string
- type KeyData
- type KeyRequest
- func (*KeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeyRequest) GetAutoLogin() bool
- func (x *KeyRequest) GetDescription() string
- func (*KeyRequest) ProtoMessage()
- func (x *KeyRequest) ProtoReflect() protoreflect.Message
- func (x *KeyRequest) Reset()
- func (x *KeyRequest) String() string
- type LicenseData
- func (*LicenseData) Descriptor() ([]byte, []int)deprecated
- func (x *LicenseData) GetHostDomain() string
- func (x *LicenseData) GetLicense() string
- func (*LicenseData) ProtoMessage()
- func (x *LicenseData) ProtoReflect() protoreflect.Message
- func (x *LicenseData) Reset()
- func (x *LicenseData) String() string
- type LicenseRequest
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetFilter() ListRequest_Filter
- func (x *ListRequest) GetNamespace() string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListRequest_Filter
- func (ListRequest_Filter) Descriptor() protoreflect.EnumDescriptor
- func (x ListRequest_Filter) Enum() *ListRequest_Filter
- func (ListRequest_Filter) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListRequest_Filter) Number() protoreflect.EnumNumber
- func (x ListRequest_Filter) String() string
- func (ListRequest_Filter) Type() protoreflect.EnumType
- type LoginRequest
- type LoginResult
- type LoginResult_Code
- func (LoginResult_Code) Descriptor() protoreflect.EnumDescriptor
- func (x LoginResult_Code) Enum() *LoginResult_Code
- func (LoginResult_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x LoginResult_Code) Number() protoreflect.EnumNumber
- func (x LoginResult_Code) String() string
- func (LoginResult_Code) Type() protoreflect.EnumType
- type LogsRequest
- func (*LogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogsRequest) GetAgents() string
- func (x *LogsRequest) GetExportDir() string
- func (x *LogsRequest) GetGetPodYaml() bool
- func (x *LogsRequest) GetTrafficManager() bool
- func (*LogsRequest) ProtoMessage()
- func (x *LogsRequest) ProtoReflect() protoreflect.Message
- func (x *LogsRequest) Reset()
- func (x *LogsRequest) String() string
- type LogsResponse
- func (*LogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LogsResponse) GetError() string
- func (x *LogsResponse) GetPodInfo() map[string]string
- func (*LogsResponse) ProtoMessage()
- func (x *LogsResponse) ProtoReflect() protoreflect.Message
- func (x *LogsResponse) Reset()
- func (x *LogsResponse) String() string
- type Notification
- type Result
- type Result_ErrorCategory
- func (Result_ErrorCategory) Descriptor() protoreflect.EnumDescriptor
- func (x Result_ErrorCategory) Enum() *Result_ErrorCategory
- func (Result_ErrorCategory) EnumDescriptor() ([]byte, []int)deprecated
- func (x Result_ErrorCategory) Number() protoreflect.EnumNumber
- func (x Result_ErrorCategory) String() string
- func (Result_ErrorCategory) Type() protoreflect.EnumType
- type RunCommandRequest
- func (*RunCommandRequest) Descriptor() ([]byte, []int)deprecated
- func (m *RunCommandRequest) GetCOrD() isRunCommandRequest_COrD
- func (x *RunCommandRequest) GetCommand() *RunCommandRequest_Command
- func (x *RunCommandRequest) GetData() []byte
- func (x *RunCommandRequest) GetSoftCancel() bool
- func (*RunCommandRequest) ProtoMessage()
- func (x *RunCommandRequest) ProtoReflect() protoreflect.Message
- func (x *RunCommandRequest) Reset()
- func (x *RunCommandRequest) String() string
- type RunCommandRequest_Command
- func (*RunCommandRequest_Command) Descriptor() ([]byte, []int)deprecated
- func (x *RunCommandRequest_Command) GetCwd() string
- func (x *RunCommandRequest_Command) GetOsArgs() []string
- func (*RunCommandRequest_Command) ProtoMessage()
- func (x *RunCommandRequest_Command) ProtoReflect() protoreflect.Message
- func (x *RunCommandRequest_Command) Reset()
- func (x *RunCommandRequest_Command) String() string
- type RunCommandRequest_Command_
- type RunCommandRequest_Data
- type RunCommandRequest_SoftCancel
- type StreamResult
- func (*StreamResult) Descriptor() ([]byte, []int)deprecated
- func (x *StreamResult) GetData() *Result
- func (x *StreamResult) GetFinal() bool
- func (*StreamResult) ProtoMessage()
- func (x *StreamResult) ProtoReflect() protoreflect.Message
- func (x *StreamResult) Reset()
- func (x *StreamResult) String() string
- type UnimplementedConnectorServer
- func (UnimplementedConnectorServer) AddInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) CanIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
- func (UnimplementedConnectorServer) Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)
- func (UnimplementedConnectorServer) CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
- func (UnimplementedConnectorServer) Disconnect(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) GatherLogs(context.Context, *LogsRequest) (*LogsResponse, error)
- func (UnimplementedConnectorServer) GetCloudAPIKey(context.Context, *KeyRequest) (*KeyData, error)
- func (UnimplementedConnectorServer) GetCloudLicense(context.Context, *LicenseRequest) (*LicenseData, error)
- func (UnimplementedConnectorServer) GetCloudUserInfo(context.Context, *UserInfoRequest) (*UserInfo, error)
- func (UnimplementedConnectorServer) GetIngressInfos(context.Context, *emptypb.Empty) (*IngressInfos, error)
- func (UnimplementedConnectorServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
- func (UnimplementedConnectorServer) Helm(context.Context, *HelmRequest) (*Result, error)
- func (UnimplementedConnectorServer) List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error)
- func (UnimplementedConnectorServer) ListCommands(context.Context, *emptypb.Empty) (*CommandGroups, error)
- func (UnimplementedConnectorServer) Login(context.Context, *LoginRequest) (*LoginResult, error)
- func (UnimplementedConnectorServer) Logout(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) Quit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)
- func (UnimplementedConnectorServer) RemoveInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) ResolveIngressInfo(context.Context, *userdaemon.IngressInfoRequest) (*userdaemon.IngressInfoResponse, error)
- func (UnimplementedConnectorServer) RunCommand(Connector_RunCommandServer) error
- func (UnimplementedConnectorServer) SetLogLevel(context.Context, *manager.LogLevelRequest) (*emptypb.Empty, error)
- func (UnimplementedConnectorServer) Status(context.Context, *emptypb.Empty) (*ConnectInfo, error)
- func (UnimplementedConnectorServer) Uninstall(context.Context, *UninstallRequest) (*Result, error)
- func (UnimplementedConnectorServer) UserNotifications(*emptypb.Empty, Connector_UserNotificationsServer) error
- func (UnimplementedConnectorServer) ValidArgsForCommand(context.Context, *ValidArgsForCommandRequest) (*ValidArgsForCommandResponse, error)
- func (UnimplementedConnectorServer) Version(context.Context, *emptypb.Empty) (*common.VersionInfo, error)
- func (UnimplementedConnectorServer) WatchWorkloads(*WatchWorkloadsRequest, Connector_WatchWorkloadsServer) error
- type UninstallRequest
- func (*UninstallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UninstallRequest) GetAgents() []string
- func (x *UninstallRequest) GetNamespace() string
- func (x *UninstallRequest) GetUninstallType() UninstallRequest_UninstallType
- func (*UninstallRequest) ProtoMessage()
- func (x *UninstallRequest) ProtoReflect() protoreflect.Message
- func (x *UninstallRequest) Reset()
- func (x *UninstallRequest) String() string
- type UninstallRequest_UninstallType
- func (UninstallRequest_UninstallType) Descriptor() protoreflect.EnumDescriptor
- func (x UninstallRequest_UninstallType) Enum() *UninstallRequest_UninstallType
- func (UninstallRequest_UninstallType) EnumDescriptor() ([]byte, []int)deprecated
- func (x UninstallRequest_UninstallType) Number() protoreflect.EnumNumber
- func (x UninstallRequest_UninstallType) String() string
- func (UninstallRequest_UninstallType) Type() protoreflect.EnumType
- type UnsafeConnectorServer
- type UserInfo
- func (*UserInfo) Descriptor() ([]byte, []int)deprecated
- func (x *UserInfo) GetAccountAvatarUrl() string
- func (x *UserInfo) GetAccountId() string
- func (x *UserInfo) GetAccountName() string
- func (x *UserInfo) GetAvatarUrl() string
- func (x *UserInfo) GetEmail() string
- func (x *UserInfo) GetId() string
- func (x *UserInfo) GetName() string
- func (*UserInfo) ProtoMessage()
- func (x *UserInfo) ProtoReflect() protoreflect.Message
- func (x *UserInfo) Reset()
- func (x *UserInfo) String() string
- type UserInfoRequest
- func (*UserInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UserInfoRequest) GetAutoLogin() bool
- func (x *UserInfoRequest) GetRefresh() bool
- func (*UserInfoRequest) ProtoMessage()
- func (x *UserInfoRequest) ProtoReflect() protoreflect.Message
- func (x *UserInfoRequest) Reset()
- func (x *UserInfoRequest) String() string
- type ValidArgsForCommandRequest
- func (*ValidArgsForCommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidArgsForCommandRequest) GetCmdName() string
- func (x *ValidArgsForCommandRequest) GetOsArgs() []string
- func (x *ValidArgsForCommandRequest) GetToComplete() string
- func (*ValidArgsForCommandRequest) ProtoMessage()
- func (x *ValidArgsForCommandRequest) ProtoReflect() protoreflect.Message
- func (x *ValidArgsForCommandRequest) Reset()
- func (x *ValidArgsForCommandRequest) String() string
- type ValidArgsForCommandResponse
- func (*ValidArgsForCommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidArgsForCommandResponse) GetCompletions() []string
- func (x *ValidArgsForCommandResponse) GetShellCompDirective() int32
- func (*ValidArgsForCommandResponse) ProtoMessage()
- func (x *ValidArgsForCommandResponse) ProtoReflect() protoreflect.Message
- func (x *ValidArgsForCommandResponse) Reset()
- func (x *ValidArgsForCommandResponse) String() string
- type WatchWorkloadsRequest
- func (*WatchWorkloadsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchWorkloadsRequest) GetNamespaces() []string
- func (*WatchWorkloadsRequest) ProtoMessage()
- func (x *WatchWorkloadsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchWorkloadsRequest) Reset()
- func (x *WatchWorkloadsRequest) String() string
- type WorkloadInfo
- func (*WorkloadInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadInfo) GetAgentInfo() *manager.AgentInfo
- func (x *WorkloadInfo) GetInterceptInfos() []*manager.InterceptInfo
- func (x *WorkloadInfo) GetName() string
- func (x *WorkloadInfo) GetNamespace() string
- func (x *WorkloadInfo) GetNotInterceptableReason() string
- func (x *WorkloadInfo) GetService() *WorkloadInfo_ServiceReference
- func (x *WorkloadInfo) GetUid() string
- func (x *WorkloadInfo) GetWorkloadResourceType() string
- func (*WorkloadInfo) ProtoMessage()
- func (x *WorkloadInfo) ProtoReflect() protoreflect.Message
- func (x *WorkloadInfo) Reset()
- func (x *WorkloadInfo) String() string
- type WorkloadInfoSnapshot
- func (*WorkloadInfoSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadInfoSnapshot) GetWorkloads() []*WorkloadInfo
- func (*WorkloadInfoSnapshot) ProtoMessage()
- func (x *WorkloadInfoSnapshot) ProtoReflect() protoreflect.Message
- func (x *WorkloadInfoSnapshot) Reset()
- func (x *WorkloadInfoSnapshot) String() string
- type WorkloadInfo_ServiceReference
- func (*WorkloadInfo_ServiceReference) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadInfo_ServiceReference) GetName() string
- func (x *WorkloadInfo_ServiceReference) GetNamespace() string
- func (x *WorkloadInfo_ServiceReference) GetPorts() []*WorkloadInfo_ServiceReference_Port
- func (x *WorkloadInfo_ServiceReference) GetUid() string
- func (*WorkloadInfo_ServiceReference) ProtoMessage()
- func (x *WorkloadInfo_ServiceReference) ProtoReflect() protoreflect.Message
- func (x *WorkloadInfo_ServiceReference) Reset()
- func (x *WorkloadInfo_ServiceReference) String() string
- type WorkloadInfo_ServiceReference_Port
- func (*WorkloadInfo_ServiceReference_Port) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadInfo_ServiceReference_Port) GetName() string
- func (x *WorkloadInfo_ServiceReference_Port) GetPort() int32
- func (*WorkloadInfo_ServiceReference_Port) ProtoMessage()
- func (x *WorkloadInfo_ServiceReference_Port) ProtoReflect() protoreflect.Message
- func (x *WorkloadInfo_ServiceReference_Port) Reset()
- func (x *WorkloadInfo_ServiceReference_Port) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Result_ErrorCategory_name = map[int32]string{ 0: "UNSPECIFIED", 1: "USER", 2: "CONFIG", 3: "NO_DAEMON_LOGS", 4: "UNKNOWN", } Result_ErrorCategory_value = map[string]int32{ "UNSPECIFIED": 0, "USER": 1, "CONFIG": 2, "NO_DAEMON_LOGS": 3, "UNKNOWN": 4, } )
Enum value maps for Result_ErrorCategory.
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.
var ( HelmRequest_Type_name = map[int32]string{ 0: "UNSPECIFIED", 1: "INSTALL", 2: "UPGRADE", 3: "UNINSTALL", } HelmRequest_Type_value = map[string]int32{ "UNSPECIFIED": 0, "INSTALL": 1, "UPGRADE": 2, "UNINSTALL": 3, } )
Enum value maps for HelmRequest_Type.
var ( UninstallRequest_UninstallType_name = map[int32]string{ 0: "UNSPECIFIED", 1: "NAMED_AGENTS", 2: "ALL_AGENTS", } UninstallRequest_UninstallType_value = map[string]int32{ "UNSPECIFIED": 0, "NAMED_AGENTS": 1, "ALL_AGENTS": 2, } )
Enum value maps for UninstallRequest_UninstallType.
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.
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.
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: "Disconnect", Handler: _Connector_Disconnect_Handler, }, { MethodName: "Status", Handler: _Connector_Status_Handler, }, { MethodName: "CanIntercept", Handler: _Connector_CanIntercept_Handler, }, { MethodName: "CreateIntercept", Handler: _Connector_CreateIntercept_Handler, }, { MethodName: "RemoveIntercept", Handler: _Connector_RemoveIntercept_Handler, }, { MethodName: "Helm", Handler: _Connector_Helm_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: "GetIngressInfos", Handler: _Connector_GetIngressInfos_Handler, }, { MethodName: "SetLogLevel", Handler: _Connector_SetLogLevel_Handler, }, { MethodName: "Quit", Handler: _Connector_Quit_Handler, }, { MethodName: "ListCommands", Handler: _Connector_ListCommands_Handler, }, { MethodName: "ValidArgsForCommand", Handler: _Connector_ValidArgsForCommand_Handler, }, { MethodName: "ResolveIngressInfo", Handler: _Connector_ResolveIngressInfo_Handler, }, { MethodName: "GatherLogs", Handler: _Connector_GatherLogs_Handler, }, { MethodName: "AddInterceptor", Handler: _Connector_AddInterceptor_Handler, }, { MethodName: "RemoveInterceptor", Handler: _Connector_RemoveInterceptor_Handler, }, { MethodName: "GetNamespaces", Handler: _Connector_GetNamespaces_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchWorkloads", Handler: _Connector_WatchWorkloads_Handler, ServerStreams: true, }, { StreamName: "UserNotifications", Handler: _Connector_UserNotifications_Handler, ServerStreams: true, }, { StreamName: "RunCommand", Handler: _Connector_RunCommand_Handler, ServerStreams: true, ClientStreams: 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)
var File_rpc_connector_connector_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConnectorServer ¶
func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)
Types ¶
type CommandGroups ¶ added in v2.5.0
type CommandGroups struct { CommandGroups map[string]*CommandGroups_Commands `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CommandGroups) Descriptor
deprecated
added in
v2.5.0
func (*CommandGroups) Descriptor() ([]byte, []int)
Deprecated: Use CommandGroups.ProtoReflect.Descriptor instead.
func (*CommandGroups) GetCommandGroups ¶ added in v2.5.0
func (x *CommandGroups) GetCommandGroups() map[string]*CommandGroups_Commands
func (*CommandGroups) ProtoMessage ¶ added in v2.5.0
func (*CommandGroups) ProtoMessage()
func (*CommandGroups) ProtoReflect ¶ added in v2.5.0
func (x *CommandGroups) ProtoReflect() protoreflect.Message
func (*CommandGroups) Reset ¶ added in v2.5.0
func (x *CommandGroups) Reset()
func (*CommandGroups) String ¶ added in v2.5.0
func (x *CommandGroups) String() string
type CommandGroups_Command ¶ added in v2.5.0
type CommandGroups_Command struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ShortHelp string `protobuf:"bytes,2,opt,name=short_help,json=shortHelp,proto3" json:"short_help,omitempty"` LongHelp string `protobuf:"bytes,3,opt,name=long_help,json=longHelp,proto3" json:"long_help,omitempty"` Flags []*CommandGroups_Flag `protobuf:"bytes,4,rep,name=flags,proto3" json:"flags,omitempty"` // contains filtered or unexported fields }
func (*CommandGroups_Command) Descriptor
deprecated
added in
v2.5.0
func (*CommandGroups_Command) Descriptor() ([]byte, []int)
Deprecated: Use CommandGroups_Command.ProtoReflect.Descriptor instead.
func (*CommandGroups_Command) GetFlags ¶ added in v2.5.0
func (x *CommandGroups_Command) GetFlags() []*CommandGroups_Flag
func (*CommandGroups_Command) GetLongHelp ¶ added in v2.5.0
func (x *CommandGroups_Command) GetLongHelp() string
func (*CommandGroups_Command) GetName ¶ added in v2.5.0
func (x *CommandGroups_Command) GetName() string
func (*CommandGroups_Command) GetShortHelp ¶ added in v2.5.0
func (x *CommandGroups_Command) GetShortHelp() string
func (*CommandGroups_Command) ProtoMessage ¶ added in v2.5.0
func (*CommandGroups_Command) ProtoMessage()
func (*CommandGroups_Command) ProtoReflect ¶ added in v2.5.0
func (x *CommandGroups_Command) ProtoReflect() protoreflect.Message
func (*CommandGroups_Command) Reset ¶ added in v2.5.0
func (x *CommandGroups_Command) Reset()
func (*CommandGroups_Command) String ¶ added in v2.5.0
func (x *CommandGroups_Command) String() string
type CommandGroups_Commands ¶ added in v2.5.0
type CommandGroups_Commands struct { Commands []*CommandGroups_Command `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"` // contains filtered or unexported fields }
func (*CommandGroups_Commands) Descriptor
deprecated
added in
v2.5.0
func (*CommandGroups_Commands) Descriptor() ([]byte, []int)
Deprecated: Use CommandGroups_Commands.ProtoReflect.Descriptor instead.
func (*CommandGroups_Commands) GetCommands ¶ added in v2.5.0
func (x *CommandGroups_Commands) GetCommands() []*CommandGroups_Command
func (*CommandGroups_Commands) ProtoMessage ¶ added in v2.5.0
func (*CommandGroups_Commands) ProtoMessage()
func (*CommandGroups_Commands) ProtoReflect ¶ added in v2.5.0
func (x *CommandGroups_Commands) ProtoReflect() protoreflect.Message
func (*CommandGroups_Commands) Reset ¶ added in v2.5.0
func (x *CommandGroups_Commands) Reset()
func (*CommandGroups_Commands) String ¶ added in v2.5.0
func (x *CommandGroups_Commands) String() string
type CommandGroups_Flag ¶ added in v2.5.0
type CommandGroups_Flag struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Flag string `protobuf:"bytes,2,opt,name=flag,proto3" json:"flag,omitempty"` Help string `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"` Shorthand string `protobuf:"bytes,4,opt,name=shorthand,proto3" json:"shorthand,omitempty"` DefaultValue string `protobuf:"bytes,5,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"` // contains filtered or unexported fields }
func (*CommandGroups_Flag) Descriptor
deprecated
added in
v2.5.0
func (*CommandGroups_Flag) Descriptor() ([]byte, []int)
Deprecated: Use CommandGroups_Flag.ProtoReflect.Descriptor instead.
func (*CommandGroups_Flag) GetDefaultValue ¶ added in v2.5.0
func (x *CommandGroups_Flag) GetDefaultValue() string
func (*CommandGroups_Flag) GetFlag ¶ added in v2.5.0
func (x *CommandGroups_Flag) GetFlag() string
func (*CommandGroups_Flag) GetHelp ¶ added in v2.5.0
func (x *CommandGroups_Flag) GetHelp() string
func (*CommandGroups_Flag) GetShorthand ¶ added in v2.5.0
func (x *CommandGroups_Flag) GetShorthand() string
func (*CommandGroups_Flag) GetType ¶ added in v2.5.0
func (x *CommandGroups_Flag) GetType() string
func (*CommandGroups_Flag) ProtoMessage ¶ added in v2.5.0
func (*CommandGroups_Flag) ProtoMessage()
func (*CommandGroups_Flag) ProtoReflect ¶ added in v2.5.0
func (x *CommandGroups_Flag) ProtoReflect() protoreflect.Message
func (*CommandGroups_Flag) Reset ¶ added in v2.5.0
func (x *CommandGroups_Flag) Reset()
func (*CommandGroups_Flag) String ¶ added in v2.5.0
func (x *CommandGroups_Flag) String() string
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"` Intercepts *manager.InterceptInfoSnapshot `protobuf:"bytes,8,opt,name=intercepts,proto3" json:"intercepts,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) 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) 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) 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"` IsPodDaemon bool `protobuf:"varint,4,opt,name=is_pod_daemon,json=isPodDaemon,proto3" json:"is_pod_daemon,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) GetIsPodDaemon ¶ added in v2.7.0
func (x *ConnectRequest) GetIsPodDaemon() bool
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) // Disconnects the cluster Disconnect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // Status returns the status of the current connection or DISCONNECTED // if no connection has been established. Status(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConnectInfo, error) // Queries the connector whether it is possible to create the given intercept. CanIntercept(ctx context.Context, in *CreateInterceptRequest, opts ...grpc.CallOption) (*InterceptResult, 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) // Installs, Upgrades, or Uninstalls the traffic-manager in the cluster. Helm(ctx context.Context, in *HelmRequest, opts ...grpc.CallOption) (*Result, error) // Uninstalls traffic-agents from the cluster. // Requires having already called Connect. Uninstall(ctx context.Context, in *UninstallRequest, opts ...grpc.CallOption) (*Result, 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) // Watch all workloads in the mapped namespaces WatchWorkloads(ctx context.Context, in *WatchWorkloadsRequest, opts ...grpc.CallOption) (Connector_WatchWorkloadsClient, 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) GetIngressInfos(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*IngressInfos, 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) // ListCommands returns a list of CLI commands that are implemented remotely by this daemon. ListCommands(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CommandGroups, error) // RunCommand executes a CLI command. RunCommand(ctx context.Context, opts ...grpc.CallOption) (Connector_RunCommandClient, error) // ValidArgsForCommand handles autocompletion ValidArgsForCommand(ctx context.Context, in *ValidArgsForCommandRequest, opts ...grpc.CallOption) (*ValidArgsForCommandResponse, error) // ResolveIngressInfo is a temporary rpc intended to allow the cli to ask // the cloud for default ingress values ResolveIngressInfo(ctx context.Context, in *userdaemon.IngressInfoRequest, opts ...grpc.CallOption) (*userdaemon.IngressInfoResponse, error) // GatherLogs will acquire logs for the various Telepresence components in kubernetes // (pending the request) and return them to the caller GatherLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (*LogsResponse, error) // AddInterceptor tells the connector that a given process is serving a specific // intercept. The connector must kill this process when the intercept ends AddInterceptor(ctx context.Context, in *Interceptor, opts ...grpc.CallOption) (*emptypb.Empty, error) // RemoveInterceptor removes a previously added interceptor RemoveInterceptor(ctx context.Context, in *Interceptor, opts ...grpc.CallOption) (*emptypb.Empty, error) // GetNamespaces gets the mapped namespaces with an optional prefix GetNamespaces(ctx context.Context, in *GetNamespacesRequest, opts ...grpc.CallOption) (*GetNamespacesResponse, 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) // Disconnects the cluster Disconnect(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // Status returns the status of the current connection or DISCONNECTED // if no connection has been established. Status(context.Context, *emptypb.Empty) (*ConnectInfo, error) // Queries the connector whether it is possible to create the given intercept. CanIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, 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) // Installs, Upgrades, or Uninstalls the traffic-manager in the cluster. Helm(context.Context, *HelmRequest) (*Result, error) // Uninstalls traffic-agents from the cluster. // Requires having already called Connect. Uninstall(context.Context, *UninstallRequest) (*Result, error) // Returns a list of workloads and their current intercept status. // Requires having already called Connect. List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error) // Watch all workloads in the mapped namespaces WatchWorkloads(*WatchWorkloadsRequest, Connector_WatchWorkloadsServer) 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) GetIngressInfos(context.Context, *emptypb.Empty) (*IngressInfos, 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) // ListCommands returns a list of CLI commands that are implemented remotely by this daemon. ListCommands(context.Context, *emptypb.Empty) (*CommandGroups, error) // RunCommand executes a CLI command. RunCommand(Connector_RunCommandServer) error // ValidArgsForCommand handles autocompletion ValidArgsForCommand(context.Context, *ValidArgsForCommandRequest) (*ValidArgsForCommandResponse, error) // ResolveIngressInfo is a temporary rpc intended to allow the cli to ask // the cloud for default ingress values ResolveIngressInfo(context.Context, *userdaemon.IngressInfoRequest) (*userdaemon.IngressInfoResponse, error) // GatherLogs will acquire logs for the various Telepresence components in kubernetes // (pending the request) and return them to the caller GatherLogs(context.Context, *LogsRequest) (*LogsResponse, error) // AddInterceptor tells the connector that a given process is serving a specific // intercept. The connector must kill this process when the intercept ends AddInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error) // RemoveInterceptor removes a previously added interceptor RemoveInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error) // GetNamespaces gets the mapped namespaces with an optional prefix GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error) // contains filtered or unexported methods }
ConnectorServer is the server API for Connector service. All implementations must embed UnimplementedConnectorServer for forward compatibility
type Connector_RunCommandClient ¶ added in v2.7.2
type Connector_RunCommandClient interface { Send(*RunCommandRequest) error Recv() (*StreamResult, error) grpc.ClientStream }
type Connector_RunCommandServer ¶ added in v2.7.2
type Connector_RunCommandServer interface { Send(*StreamResult) error Recv() (*RunCommandRequest, error) grpc.ServerStream }
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 Connector_WatchWorkloadsClient ¶ added in v2.5.0
type Connector_WatchWorkloadsClient interface { Recv() (*WorkloadInfoSnapshot, error) grpc.ClientStream }
type Connector_WatchWorkloadsServer ¶ added in v2.5.0
type Connector_WatchWorkloadsServer interface { Send(*WorkloadInfoSnapshot) 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"` IsPodDaemon bool `protobuf:"varint,4,opt,name=is_pod_daemon,json=isPodDaemon,proto3" json:"is_pod_daemon,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) GetIsPodDaemon ¶ added in v2.7.0
func (x *CreateInterceptRequest) GetIsPodDaemon() bool
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 GetNamespacesRequest ¶ added in v2.7.2
type GetNamespacesRequest struct { ForClientAccess bool `protobuf:"varint,1,opt,name=for_client_access,json=forClientAccess,proto3" json:"for_client_access,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` // contains filtered or unexported fields }
func (*GetNamespacesRequest) Descriptor
deprecated
added in
v2.7.2
func (*GetNamespacesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespacesRequest.ProtoReflect.Descriptor instead.
func (*GetNamespacesRequest) GetForClientAccess ¶ added in v2.7.2
func (x *GetNamespacesRequest) GetForClientAccess() bool
func (*GetNamespacesRequest) GetPrefix ¶ added in v2.7.2
func (x *GetNamespacesRequest) GetPrefix() string
func (*GetNamespacesRequest) ProtoMessage ¶ added in v2.7.2
func (*GetNamespacesRequest) ProtoMessage()
func (*GetNamespacesRequest) ProtoReflect ¶ added in v2.7.2
func (x *GetNamespacesRequest) ProtoReflect() protoreflect.Message
func (*GetNamespacesRequest) Reset ¶ added in v2.7.2
func (x *GetNamespacesRequest) Reset()
func (*GetNamespacesRequest) String ¶ added in v2.7.2
func (x *GetNamespacesRequest) String() string
type GetNamespacesResponse ¶ added in v2.7.2
type GetNamespacesResponse struct { Namespaces []string `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"` // contains filtered or unexported fields }
func (*GetNamespacesResponse) Descriptor
deprecated
added in
v2.7.2
func (*GetNamespacesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNamespacesResponse.ProtoReflect.Descriptor instead.
func (*GetNamespacesResponse) GetNamespaces ¶ added in v2.7.2
func (x *GetNamespacesResponse) GetNamespaces() []string
func (*GetNamespacesResponse) ProtoMessage ¶ added in v2.7.2
func (*GetNamespacesResponse) ProtoMessage()
func (*GetNamespacesResponse) ProtoReflect ¶ added in v2.7.2
func (x *GetNamespacesResponse) ProtoReflect() protoreflect.Message
func (*GetNamespacesResponse) Reset ¶ added in v2.7.2
func (x *GetNamespacesResponse) Reset()
func (*GetNamespacesResponse) String ¶ added in v2.7.2
func (x *GetNamespacesResponse) String() string
type HelmRequest ¶ added in v2.7.1
type HelmRequest struct { ConnectRequest *ConnectRequest `protobuf:"bytes,1,opt,name=connect_request,json=connectRequest,proto3" json:"connect_request,omitempty"` Type HelmRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=telepresence.connector.HelmRequest_Type" json:"type,omitempty"` ValuePaths []string `protobuf:"bytes,3,rep,name=value_paths,json=valuePaths,proto3" json:"value_paths,omitempty"` // contains filtered or unexported fields }
func (*HelmRequest) Descriptor
deprecated
added in
v2.7.1
func (*HelmRequest) Descriptor() ([]byte, []int)
Deprecated: Use HelmRequest.ProtoReflect.Descriptor instead.
func (*HelmRequest) GetConnectRequest ¶ added in v2.7.1
func (x *HelmRequest) GetConnectRequest() *ConnectRequest
func (*HelmRequest) GetType ¶ added in v2.7.1
func (x *HelmRequest) GetType() HelmRequest_Type
func (*HelmRequest) GetValuePaths ¶ added in v2.7.1
func (x *HelmRequest) GetValuePaths() []string
func (*HelmRequest) ProtoMessage ¶ added in v2.7.1
func (*HelmRequest) ProtoMessage()
func (*HelmRequest) ProtoReflect ¶ added in v2.7.1
func (x *HelmRequest) ProtoReflect() protoreflect.Message
func (*HelmRequest) Reset ¶ added in v2.7.1
func (x *HelmRequest) Reset()
func (*HelmRequest) String ¶ added in v2.7.1
func (x *HelmRequest) String() string
type HelmRequest_Type ¶ added in v2.7.1
type HelmRequest_Type int32
const ( HelmRequest_UNSPECIFIED HelmRequest_Type = 0 HelmRequest_INSTALL HelmRequest_Type = 1 HelmRequest_UPGRADE HelmRequest_Type = 2 HelmRequest_UNINSTALL HelmRequest_Type = 3 )
func (HelmRequest_Type) Descriptor ¶ added in v2.7.1
func (HelmRequest_Type) Descriptor() protoreflect.EnumDescriptor
func (HelmRequest_Type) Enum ¶ added in v2.7.1
func (x HelmRequest_Type) Enum() *HelmRequest_Type
func (HelmRequest_Type) EnumDescriptor
deprecated
added in
v2.7.1
func (HelmRequest_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use HelmRequest_Type.Descriptor instead.
func (HelmRequest_Type) Number ¶ added in v2.7.1
func (x HelmRequest_Type) Number() protoreflect.EnumNumber
func (HelmRequest_Type) String ¶ added in v2.7.1
func (x HelmRequest_Type) String() string
func (HelmRequest_Type) Type ¶ added in v2.7.1
func (HelmRequest_Type) Type() protoreflect.EnumType
type IngressInfos ¶ added in v2.5.0
type IngressInfos struct { IngressInfos []*manager.IngressInfo `protobuf:"bytes,1,rep,name=ingress_infos,json=ingressInfos,proto3" json:"ingress_infos,omitempty"` // contains filtered or unexported fields }
func (*IngressInfos) Descriptor
deprecated
added in
v2.5.0
func (*IngressInfos) Descriptor() ([]byte, []int)
Deprecated: Use IngressInfos.ProtoReflect.Descriptor instead.
func (*IngressInfos) GetIngressInfos ¶ added in v2.5.0
func (x *IngressInfos) GetIngressInfos() []*manager.IngressInfo
func (*IngressInfos) ProtoMessage ¶ added in v2.5.0
func (*IngressInfos) ProtoMessage()
func (*IngressInfos) ProtoReflect ¶ added in v2.5.0
func (x *IngressInfos) ProtoReflect() protoreflect.Message
func (*IngressInfos) Reset ¶ added in v2.5.0
func (x *IngressInfos) Reset()
func (*IngressInfos) String ¶ added in v2.5.0
func (x *IngressInfos) String() string
type InterceptResult ¶
type InterceptResult struct { InterceptInfo *manager.InterceptInfo `protobuf:"bytes,1,opt,name=intercept_info,json=interceptInfo,proto3" json:"intercept_info,omitempty"` Error common.InterceptError `protobuf:"varint,2,opt,name=error,proto3,enum=telepresence.common.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 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"` // The port number that service_port_identifier resolved into is // used as the default port for the ingress for pro intercepts ServiceProps *userdaemon.IngressInfoRequest `protobuf:"bytes,8,opt,name=service_props,json=serviceProps,proto3" json:"service_props,omitempty"` // contains filtered or unexported fields }
func (*InterceptResult) Descriptor
deprecated
func (*InterceptResult) Descriptor() ([]byte, []int)
Deprecated: Use InterceptResult.ProtoReflect.Descriptor instead.
func (*InterceptResult) GetError ¶
func (x *InterceptResult) GetError() common.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) GetServiceProps ¶ added in v2.5.0
func (x *InterceptResult) GetServiceProps() *userdaemon.IngressInfoRequest
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 Interceptor ¶ added in v2.6.0
type Interceptor struct { // The ID of the intercept that is served by this interceptor process InterceptId string `protobuf:"bytes,1,opt,name=intercept_id,json=interceptId,proto3" json:"intercept_id,omitempty"` // The pid of the interceptor process Pid int32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` // contains filtered or unexported fields }
func (*Interceptor) Descriptor
deprecated
added in
v2.6.0
func (*Interceptor) Descriptor() ([]byte, []int)
Deprecated: Use Interceptor.ProtoReflect.Descriptor instead.
func (*Interceptor) GetInterceptId ¶ added in v2.6.0
func (x *Interceptor) GetInterceptId() string
func (*Interceptor) GetPid ¶ added in v2.6.0
func (x *Interceptor) GetPid() int32
func (*Interceptor) ProtoMessage ¶ added in v2.6.0
func (*Interceptor) ProtoMessage()
func (*Interceptor) ProtoReflect ¶ added in v2.6.0
func (x *Interceptor) ProtoReflect() protoreflect.Message
func (*Interceptor) Reset ¶ added in v2.6.0
func (x *Interceptor) Reset()
func (*Interceptor) String ¶ added in v2.6.0
func (x *Interceptor) 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) ProtoMessage ¶ added in v2.1.4
func (*KeyData) ProtoMessage()
func (*KeyData) ProtoReflect ¶ added in v2.1.4
func (x *KeyData) ProtoReflect() protoreflect.Message
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) 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 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) Descriptor() protoreflect.EnumDescriptor
func (LoginResult_Code) Enum ¶ added in v2.1.4
func (x LoginResult_Code) Enum() *LoginResult_Code
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 (x LoginResult_Code) Number() protoreflect.EnumNumber
func (LoginResult_Code) String ¶ added in v2.1.4
func (x LoginResult_Code) String() string
func (LoginResult_Code) Type ¶ added in v2.1.4
func (LoginResult_Code) Type() protoreflect.EnumType
type LogsRequest ¶ added in v2.5.5
type LogsRequest struct { // Whether or not logs from the traffic-manager are desired. TrafficManager bool `protobuf:"varint,1,opt,name=traffic_manager,json=trafficManager,proto3" json:"traffic_manager,omitempty"` // Whether or not to get the pod yaml deployed to the cluster. GetPodYaml bool `protobuf:"varint,2,opt,name=get_pod_yaml,json=getPodYaml,proto3" json:"get_pod_yaml,omitempty"` // The traffic-agent(s) logs are desired from. Can be `all`, `False`, // or substring to filter based on pod names. Agents string `protobuf:"bytes,3,opt,name=agents,proto3" json:"agents,omitempty"` // Directory that the logs will be exported to ExportDir string `protobuf:"bytes,4,opt,name=export_dir,json=exportDir,proto3" json:"export_dir,omitempty"` // contains filtered or unexported fields }
func (*LogsRequest) Descriptor
deprecated
added in
v2.5.5
func (*LogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.
func (*LogsRequest) GetAgents ¶ added in v2.5.5
func (x *LogsRequest) GetAgents() string
func (*LogsRequest) GetExportDir ¶ added in v2.5.6
func (x *LogsRequest) GetExportDir() string
func (*LogsRequest) GetGetPodYaml ¶ added in v2.5.5
func (x *LogsRequest) GetGetPodYaml() bool
func (*LogsRequest) GetTrafficManager ¶ added in v2.5.5
func (x *LogsRequest) GetTrafficManager() bool
func (*LogsRequest) ProtoMessage ¶ added in v2.5.5
func (*LogsRequest) ProtoMessage()
func (*LogsRequest) ProtoReflect ¶ added in v2.5.5
func (x *LogsRequest) ProtoReflect() protoreflect.Message
func (*LogsRequest) Reset ¶ added in v2.5.5
func (x *LogsRequest) Reset()
func (*LogsRequest) String ¶ added in v2.5.5
func (x *LogsRequest) String() string
type LogsResponse ¶ added in v2.5.5
type LogsResponse struct { // General error that isn't associated with a pod such as failing to list the pods. Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // pod_info contains one entry per created file name name. The value is either the string // "ok" indicating that the file exists, or an error string with info why it could not // be created. PodInfo map[string]string `` /* 170-byte string literal not displayed */ // contains filtered or unexported fields }
func (*LogsResponse) Descriptor
deprecated
added in
v2.5.5
func (*LogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.
func (*LogsResponse) GetError ¶ added in v2.5.6
func (x *LogsResponse) GetError() string
func (*LogsResponse) GetPodInfo ¶ added in v2.5.6
func (x *LogsResponse) GetPodInfo() map[string]string
func (*LogsResponse) ProtoMessage ¶ added in v2.5.5
func (*LogsResponse) ProtoMessage()
func (*LogsResponse) ProtoReflect ¶ added in v2.5.5
func (x *LogsResponse) ProtoReflect() protoreflect.Message
func (*LogsResponse) Reset ¶ added in v2.5.5
func (x *LogsResponse) Reset()
func (*LogsResponse) String ¶ added in v2.5.5
func (x *LogsResponse) String() string
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 Result ¶ added in v2.7.1
type Result struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` ErrorCategory Result_ErrorCategory `` /* 150-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Result) Descriptor
deprecated
added in
v2.7.1
func (*Result) GetErrorCategory ¶ added in v2.7.1
func (x *Result) GetErrorCategory() Result_ErrorCategory
func (*Result) ProtoMessage ¶ added in v2.7.1
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶ added in v2.7.1
func (x *Result) ProtoReflect() protoreflect.Message
type Result_ErrorCategory ¶ added in v2.7.2
type Result_ErrorCategory int32
const ( Result_UNSPECIFIED Result_ErrorCategory = 0 // No error Result_USER Result_ErrorCategory = 1 Result_CONFIG Result_ErrorCategory = 2 Result_NO_DAEMON_LOGS Result_ErrorCategory = 3 Result_UNKNOWN Result_ErrorCategory = 4 )
func (Result_ErrorCategory) Descriptor ¶ added in v2.7.2
func (Result_ErrorCategory) Descriptor() protoreflect.EnumDescriptor
func (Result_ErrorCategory) Enum ¶ added in v2.7.2
func (x Result_ErrorCategory) Enum() *Result_ErrorCategory
func (Result_ErrorCategory) EnumDescriptor
deprecated
added in
v2.7.2
func (Result_ErrorCategory) EnumDescriptor() ([]byte, []int)
Deprecated: Use Result_ErrorCategory.Descriptor instead.
func (Result_ErrorCategory) Number ¶ added in v2.7.2
func (x Result_ErrorCategory) Number() protoreflect.EnumNumber
func (Result_ErrorCategory) String ¶ added in v2.7.2
func (x Result_ErrorCategory) String() string
func (Result_ErrorCategory) Type ¶ added in v2.7.2
func (Result_ErrorCategory) Type() protoreflect.EnumType
type RunCommandRequest ¶ added in v2.5.0
type RunCommandRequest struct { // Types that are assignable to COrD: // // *RunCommandRequest_Command_ // *RunCommandRequest_Data // *RunCommandRequest_SoftCancel COrD isRunCommandRequest_COrD `protobuf_oneof:"c_or_d"` // contains filtered or unexported fields }
RunCommandRequest is the message that is streamed to RunCommand. The first message contains the actual command and its parameters. Subsequent messages will only contain data.
func (*RunCommandRequest) Descriptor
deprecated
added in
v2.5.0
func (*RunCommandRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunCommandRequest.ProtoReflect.Descriptor instead.
func (*RunCommandRequest) GetCOrD ¶ added in v2.7.2
func (m *RunCommandRequest) GetCOrD() isRunCommandRequest_COrD
func (*RunCommandRequest) GetCommand ¶ added in v2.7.2
func (x *RunCommandRequest) GetCommand() *RunCommandRequest_Command
func (*RunCommandRequest) GetData ¶ added in v2.7.2
func (x *RunCommandRequest) GetData() []byte
func (*RunCommandRequest) GetSoftCancel ¶ added in v2.7.3
func (x *RunCommandRequest) GetSoftCancel() bool
func (*RunCommandRequest) ProtoMessage ¶ added in v2.5.0
func (*RunCommandRequest) ProtoMessage()
func (*RunCommandRequest) ProtoReflect ¶ added in v2.5.0
func (x *RunCommandRequest) ProtoReflect() protoreflect.Message
func (*RunCommandRequest) Reset ¶ added in v2.5.0
func (x *RunCommandRequest) Reset()
func (*RunCommandRequest) String ¶ added in v2.5.0
func (x *RunCommandRequest) String() string
type RunCommandRequest_Command ¶ added in v2.7.2
type RunCommandRequest_Command struct { OsArgs []string `protobuf:"bytes,1,rep,name=os_args,json=osArgs,proto3" json:"os_args,omitempty"` Cwd string `protobuf:"bytes,2,opt,name=cwd,proto3" json:"cwd,omitempty"` // contains filtered or unexported fields }
func (*RunCommandRequest_Command) Descriptor
deprecated
added in
v2.7.2
func (*RunCommandRequest_Command) Descriptor() ([]byte, []int)
Deprecated: Use RunCommandRequest_Command.ProtoReflect.Descriptor instead.
func (*RunCommandRequest_Command) GetCwd ¶ added in v2.7.2
func (x *RunCommandRequest_Command) GetCwd() string
func (*RunCommandRequest_Command) GetOsArgs ¶ added in v2.7.2
func (x *RunCommandRequest_Command) GetOsArgs() []string
func (*RunCommandRequest_Command) ProtoMessage ¶ added in v2.7.2
func (*RunCommandRequest_Command) ProtoMessage()
func (*RunCommandRequest_Command) ProtoReflect ¶ added in v2.7.2
func (x *RunCommandRequest_Command) ProtoReflect() protoreflect.Message
func (*RunCommandRequest_Command) Reset ¶ added in v2.7.2
func (x *RunCommandRequest_Command) Reset()
func (*RunCommandRequest_Command) String ¶ added in v2.7.2
func (x *RunCommandRequest_Command) String() string
type RunCommandRequest_Command_ ¶ added in v2.7.2
type RunCommandRequest_Command_ struct {
Command *RunCommandRequest_Command `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}
type RunCommandRequest_Data ¶ added in v2.7.2
type RunCommandRequest_Data struct {
Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}
type RunCommandRequest_SoftCancel ¶ added in v2.7.3
type RunCommandRequest_SoftCancel struct {
SoftCancel bool `protobuf:"varint,3,opt,name=soft_cancel,json=softCancel,proto3,oneof"`
}
type StreamResult ¶ added in v2.7.2
type StreamResult struct { Data *Result `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Final bool `protobuf:"varint,2,opt,name=final,proto3" json:"final,omitempty"` // contains filtered or unexported fields }
StreamResult is like Result, but with a boolean final to indicate that a message is the last one on a stream. The stream can be closed by either actually closing it (receiver gets an EOF) or by sending a StreamResult with final = true. The latter method should be used when the called method ends with an error (non-gRPC related) that must be propagated to the caller.
func (*StreamResult) Descriptor
deprecated
added in
v2.7.2
func (*StreamResult) Descriptor() ([]byte, []int)
Deprecated: Use StreamResult.ProtoReflect.Descriptor instead.
func (*StreamResult) GetData ¶ added in v2.7.2
func (x *StreamResult) GetData() *Result
func (*StreamResult) GetFinal ¶ added in v2.7.2
func (x *StreamResult) GetFinal() bool
func (*StreamResult) ProtoMessage ¶ added in v2.7.2
func (*StreamResult) ProtoMessage()
func (*StreamResult) ProtoReflect ¶ added in v2.7.2
func (x *StreamResult) ProtoReflect() protoreflect.Message
func (*StreamResult) Reset ¶ added in v2.7.2
func (x *StreamResult) Reset()
func (*StreamResult) String ¶ added in v2.7.2
func (x *StreamResult) String() string
type UnimplementedConnectorServer ¶
type UnimplementedConnectorServer struct { }
UnimplementedConnectorServer must be embedded to have forward compatible implementations.
func (UnimplementedConnectorServer) AddInterceptor ¶ added in v2.6.0
func (UnimplementedConnectorServer) AddInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
func (UnimplementedConnectorServer) CanIntercept ¶ added in v2.4.10
func (UnimplementedConnectorServer) CanIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
func (UnimplementedConnectorServer) Connect ¶
func (UnimplementedConnectorServer) Connect(context.Context, *ConnectRequest) (*ConnectInfo, error)
func (UnimplementedConnectorServer) CreateIntercept ¶
func (UnimplementedConnectorServer) CreateIntercept(context.Context, *CreateInterceptRequest) (*InterceptResult, error)
func (UnimplementedConnectorServer) Disconnect ¶ added in v2.5.0
func (UnimplementedConnectorServer) GatherLogs ¶ added in v2.5.5
func (UnimplementedConnectorServer) GatherLogs(context.Context, *LogsRequest) (*LogsResponse, error)
func (UnimplementedConnectorServer) GetCloudAPIKey ¶ added in v2.1.4
func (UnimplementedConnectorServer) GetCloudAPIKey(context.Context, *KeyRequest) (*KeyData, error)
func (UnimplementedConnectorServer) GetCloudLicense ¶ added in v2.2.0
func (UnimplementedConnectorServer) GetCloudLicense(context.Context, *LicenseRequest) (*LicenseData, error)
func (UnimplementedConnectorServer) GetCloudUserInfo ¶ added in v2.3.7
func (UnimplementedConnectorServer) GetCloudUserInfo(context.Context, *UserInfoRequest) (*UserInfo, error)
func (UnimplementedConnectorServer) GetIngressInfos ¶ added in v2.5.0
func (UnimplementedConnectorServer) GetIngressInfos(context.Context, *emptypb.Empty) (*IngressInfos, error)
func (UnimplementedConnectorServer) GetNamespaces ¶ added in v2.7.2
func (UnimplementedConnectorServer) GetNamespaces(context.Context, *GetNamespacesRequest) (*GetNamespacesResponse, error)
func (UnimplementedConnectorServer) Helm ¶ added in v2.7.1
func (UnimplementedConnectorServer) Helm(context.Context, *HelmRequest) (*Result, error)
func (UnimplementedConnectorServer) List ¶
func (UnimplementedConnectorServer) List(context.Context, *ListRequest) (*WorkloadInfoSnapshot, error)
func (UnimplementedConnectorServer) ListCommands ¶ added in v2.5.0
func (UnimplementedConnectorServer) ListCommands(context.Context, *emptypb.Empty) (*CommandGroups, error)
func (UnimplementedConnectorServer) Login ¶ added in v2.1.4
func (UnimplementedConnectorServer) Login(context.Context, *LoginRequest) (*LoginResult, error)
func (UnimplementedConnectorServer) RemoveIntercept ¶
func (UnimplementedConnectorServer) RemoveIntercept(context.Context, *manager.RemoveInterceptRequest2) (*InterceptResult, error)
func (UnimplementedConnectorServer) RemoveInterceptor ¶ added in v2.6.0
func (UnimplementedConnectorServer) RemoveInterceptor(context.Context, *Interceptor) (*emptypb.Empty, error)
func (UnimplementedConnectorServer) ResolveIngressInfo ¶ added in v2.5.0
func (UnimplementedConnectorServer) ResolveIngressInfo(context.Context, *userdaemon.IngressInfoRequest) (*userdaemon.IngressInfoResponse, error)
func (UnimplementedConnectorServer) RunCommand ¶ added in v2.5.0
func (UnimplementedConnectorServer) RunCommand(Connector_RunCommandServer) error
func (UnimplementedConnectorServer) SetLogLevel ¶ added in v2.4.2
func (UnimplementedConnectorServer) SetLogLevel(context.Context, *manager.LogLevelRequest) (*emptypb.Empty, error)
func (UnimplementedConnectorServer) Status ¶ added in v2.1.4
func (UnimplementedConnectorServer) Status(context.Context, *emptypb.Empty) (*ConnectInfo, error)
func (UnimplementedConnectorServer) Uninstall ¶
func (UnimplementedConnectorServer) Uninstall(context.Context, *UninstallRequest) (*Result, error)
func (UnimplementedConnectorServer) UserNotifications ¶ added in v2.1.4
func (UnimplementedConnectorServer) UserNotifications(*emptypb.Empty, Connector_UserNotificationsServer) error
func (UnimplementedConnectorServer) ValidArgsForCommand ¶ added in v2.7.2
func (UnimplementedConnectorServer) ValidArgsForCommand(context.Context, *ValidArgsForCommandRequest) (*ValidArgsForCommandResponse, error)
func (UnimplementedConnectorServer) Version ¶
func (UnimplementedConnectorServer) Version(context.Context, *emptypb.Empty) (*common.VersionInfo, error)
func (UnimplementedConnectorServer) WatchWorkloads ¶ added in v2.5.0
func (UnimplementedConnectorServer) WatchWorkloads(*WatchWorkloadsRequest, Connector_WatchWorkloadsServer) 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 workloads UninstallRequest_NAMED_AGENTS UninstallRequest_UninstallType = 1 // Uninstalls all agents UninstallRequest_ALL_AGENTS UninstallRequest_UninstallType = 2 )
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 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"` Email string `protobuf:"bytes,7,opt,name=email,proto3" json:"email,omitempty"` // contains filtered or unexported fields }
func (*UserInfo) Descriptor
deprecated
added in
v2.3.7
func (*UserInfo) GetAccountAvatarUrl ¶ added in v2.3.7
func (*UserInfo) GetAccountId ¶ added in v2.3.7
func (*UserInfo) GetAccountName ¶ added in v2.3.7
func (*UserInfo) GetAvatarUrl ¶ added in v2.3.7
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
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 ValidArgsForCommandRequest ¶ added in v2.7.2
type ValidArgsForCommandRequest struct { CmdName string `protobuf:"bytes,1,opt,name=cmd_name,json=cmdName,proto3" json:"cmd_name,omitempty"` OsArgs []string `protobuf:"bytes,2,rep,name=os_args,json=osArgs,proto3" json:"os_args,omitempty"` ToComplete string `protobuf:"bytes,3,opt,name=to_complete,json=toComplete,proto3" json:"to_complete,omitempty"` // contains filtered or unexported fields }
func (*ValidArgsForCommandRequest) Descriptor
deprecated
added in
v2.7.2
func (*ValidArgsForCommandRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidArgsForCommandRequest.ProtoReflect.Descriptor instead.
func (*ValidArgsForCommandRequest) GetCmdName ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) GetCmdName() string
func (*ValidArgsForCommandRequest) GetOsArgs ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) GetOsArgs() []string
func (*ValidArgsForCommandRequest) GetToComplete ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) GetToComplete() string
func (*ValidArgsForCommandRequest) ProtoMessage ¶ added in v2.7.2
func (*ValidArgsForCommandRequest) ProtoMessage()
func (*ValidArgsForCommandRequest) ProtoReflect ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) ProtoReflect() protoreflect.Message
func (*ValidArgsForCommandRequest) Reset ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) Reset()
func (*ValidArgsForCommandRequest) String ¶ added in v2.7.2
func (x *ValidArgsForCommandRequest) String() string
type ValidArgsForCommandResponse ¶ added in v2.7.2
type ValidArgsForCommandResponse struct { Completions []string `protobuf:"bytes,1,rep,name=completions,proto3" json:"completions,omitempty"` ShellCompDirective int32 `protobuf:"varint,2,opt,name=shell_comp_directive,json=shellCompDirective,proto3" json:"shell_comp_directive,omitempty"` // contains filtered or unexported fields }
func (*ValidArgsForCommandResponse) Descriptor
deprecated
added in
v2.7.2
func (*ValidArgsForCommandResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidArgsForCommandResponse.ProtoReflect.Descriptor instead.
func (*ValidArgsForCommandResponse) GetCompletions ¶ added in v2.7.2
func (x *ValidArgsForCommandResponse) GetCompletions() []string
func (*ValidArgsForCommandResponse) GetShellCompDirective ¶ added in v2.7.2
func (x *ValidArgsForCommandResponse) GetShellCompDirective() int32
func (*ValidArgsForCommandResponse) ProtoMessage ¶ added in v2.7.2
func (*ValidArgsForCommandResponse) ProtoMessage()
func (*ValidArgsForCommandResponse) ProtoReflect ¶ added in v2.7.2
func (x *ValidArgsForCommandResponse) ProtoReflect() protoreflect.Message
func (*ValidArgsForCommandResponse) Reset ¶ added in v2.7.2
func (x *ValidArgsForCommandResponse) Reset()
func (*ValidArgsForCommandResponse) String ¶ added in v2.7.2
func (x *ValidArgsForCommandResponse) String() string
type WatchWorkloadsRequest ¶ added in v2.5.0
type WatchWorkloadsRequest struct { // Namespace to watch. Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"` // contains filtered or unexported fields }
func (*WatchWorkloadsRequest) Descriptor
deprecated
added in
v2.5.0
func (*WatchWorkloadsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchWorkloadsRequest.ProtoReflect.Descriptor instead.
func (*WatchWorkloadsRequest) GetNamespaces ¶ added in v2.5.0
func (x *WatchWorkloadsRequest) GetNamespaces() []string
func (*WatchWorkloadsRequest) ProtoMessage ¶ added in v2.5.0
func (*WatchWorkloadsRequest) ProtoMessage()
func (*WatchWorkloadsRequest) ProtoReflect ¶ added in v2.5.0
func (x *WatchWorkloadsRequest) ProtoReflect() protoreflect.Message
func (*WatchWorkloadsRequest) Reset ¶ added in v2.5.0
func (x *WatchWorkloadsRequest) Reset()
func (*WatchWorkloadsRequest) String ¶ added in v2.5.0
func (x *WatchWorkloadsRequest) 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"` // Namespace of workload Namespace string `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,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"` // InterceptInfos reported from the traffic manager in case the workload is currently intercepted InterceptInfos []*manager.InterceptInfo `protobuf:"bytes,9,rep,name=intercept_infos,json=interceptInfos,proto3" json:"intercept_infos,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"` Service *WorkloadInfo_ServiceReference `protobuf:"bytes,7,opt,name=service,proto3,oneof" json:"service,omitempty"` Uid string `protobuf:"bytes,8,opt,name=uid,proto3" json:"uid,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) GetInterceptInfos ¶ added in v2.6.0
func (x *WorkloadInfo) GetInterceptInfos() []*manager.InterceptInfo
func (*WorkloadInfo) GetName ¶ added in v2.1.3
func (x *WorkloadInfo) GetName() string
func (*WorkloadInfo) GetNamespace ¶ added in v2.5.0
func (x *WorkloadInfo) GetNamespace() string
func (*WorkloadInfo) GetNotInterceptableReason ¶ added in v2.1.3
func (x *WorkloadInfo) GetNotInterceptableReason() string
func (*WorkloadInfo) GetService ¶ added in v2.5.0
func (x *WorkloadInfo) GetService() *WorkloadInfo_ServiceReference
func (*WorkloadInfo) GetUid ¶ added in v2.5.0
func (x *WorkloadInfo) GetUid() 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
type WorkloadInfo_ServiceReference ¶ added in v2.5.0
type WorkloadInfo_ServiceReference struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` Ports []*WorkloadInfo_ServiceReference_Port `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"` // contains filtered or unexported fields }
func (*WorkloadInfo_ServiceReference) Descriptor
deprecated
added in
v2.5.0
func (*WorkloadInfo_ServiceReference) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadInfo_ServiceReference.ProtoReflect.Descriptor instead.
func (*WorkloadInfo_ServiceReference) GetName ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) GetName() string
func (*WorkloadInfo_ServiceReference) GetNamespace ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) GetNamespace() string
func (*WorkloadInfo_ServiceReference) GetPorts ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) GetPorts() []*WorkloadInfo_ServiceReference_Port
func (*WorkloadInfo_ServiceReference) GetUid ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) GetUid() string
func (*WorkloadInfo_ServiceReference) ProtoMessage ¶ added in v2.5.0
func (*WorkloadInfo_ServiceReference) ProtoMessage()
func (*WorkloadInfo_ServiceReference) ProtoReflect ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) ProtoReflect() protoreflect.Message
func (*WorkloadInfo_ServiceReference) Reset ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) Reset()
func (*WorkloadInfo_ServiceReference) String ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference) String() string
type WorkloadInfo_ServiceReference_Port ¶ added in v2.5.0
type WorkloadInfo_ServiceReference_Port struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*WorkloadInfo_ServiceReference_Port) Descriptor
deprecated
added in
v2.5.0
func (*WorkloadInfo_ServiceReference_Port) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadInfo_ServiceReference_Port.ProtoReflect.Descriptor instead.
func (*WorkloadInfo_ServiceReference_Port) GetName ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference_Port) GetName() string
func (*WorkloadInfo_ServiceReference_Port) GetPort ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference_Port) GetPort() int32
func (*WorkloadInfo_ServiceReference_Port) ProtoMessage ¶ added in v2.5.0
func (*WorkloadInfo_ServiceReference_Port) ProtoMessage()
func (*WorkloadInfo_ServiceReference_Port) ProtoReflect ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference_Port) ProtoReflect() protoreflect.Message
func (*WorkloadInfo_ServiceReference_Port) Reset ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference_Port) Reset()
func (*WorkloadInfo_ServiceReference_Port) String ¶ added in v2.5.0
func (x *WorkloadInfo_ServiceReference_Port) String() string