userdaemon

package
v2.8.5-rc.0 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_rpc_userdaemon_userdaemon_proto protoreflect.FileDescriptor
View Source 
var SystemA_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.userdaemon.SystemA",
	HandlerType: (*SystemAServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNamespacesToWatch",
			Handler:    _SystemA_GetNamespacesToWatch_Handler,
		},
		{
			MethodName: "ResolveIngressInfo",
			Handler:    _SystemA_ResolveIngressInfo_Handler,
		},
		{
			MethodName: "ReportInterceptCreation",
			Handler:    _SystemA_ReportInterceptCreation_Handler,
		},
		{
			MethodName: "GetSavedIntercept",
			Handler:    _SystemA_GetSavedIntercept_Handler,
		},
		{
			MethodName: "AutocompleteSavedIntercept",
			Handler:    _SystemA_AutocompleteSavedIntercept_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReportAvailableServices",
			Handler:       _SystemA_ReportAvailableServices_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ReportAvailableNamespaces",
			Handler:       _SystemA_ReportAvailableNamespaces_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/userdaemon/userdaemon.proto",
}

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

Functions

func RegisterSystemAServer 

func RegisterSystemAServer(s grpc.ServiceRegistrar, srv SystemAServer)

Types

type AutocompleteSavedInterceptRequest added in v2.7.2 

type AutocompleteSavedInterceptRequest struct {
	ToComplete string `protobuf:"bytes,1,opt,name=to_complete,json=toComplete,proto3" json:"to_complete,omitempty"`
	// contains filtered or unexported fields
}

func (*AutocompleteSavedInterceptRequest) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use AutocompleteSavedInterceptRequest.ProtoReflect.Descriptor instead.

func (*AutocompleteSavedInterceptRequest) GetToComplete added in v2.7.2 

func (x *AutocompleteSavedInterceptRequest) GetToComplete() string

func (*AutocompleteSavedInterceptRequest) ProtoMessage added in v2.7.2 

func (*AutocompleteSavedInterceptRequest) ProtoMessage()

func (*AutocompleteSavedInterceptRequest) ProtoReflect added in v2.7.2 

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

func (*AutocompleteSavedInterceptRequest) Reset added in v2.7.2 

func (x *AutocompleteSavedInterceptRequest) Reset()

func (*AutocompleteSavedInterceptRequest) String added in v2.7.2 

func (x *AutocompleteSavedInterceptRequest) String() string

type AutocompleteSavedInterceptsResponse added in v2.7.2 

type AutocompleteSavedInterceptsResponse struct {
	Completions []string `protobuf:"bytes,1,rep,name=completions,proto3" json:"completions,omitempty"`
	// contains filtered or unexported fields
}

func (*AutocompleteSavedInterceptsResponse) Descriptor deprecated added in v2.7.2 

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

Deprecated: Use AutocompleteSavedInterceptsResponse.ProtoReflect.Descriptor instead.

func (*AutocompleteSavedInterceptsResponse) GetCompletions added in v2.7.2 

func (x *AutocompleteSavedInterceptsResponse) GetCompletions() []string

func (*AutocompleteSavedInterceptsResponse) ProtoMessage added in v2.7.2 

func (*AutocompleteSavedInterceptsResponse) ProtoMessage()

func (*AutocompleteSavedInterceptsResponse) ProtoReflect added in v2.7.2 

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

func (*AutocompleteSavedInterceptsResponse) Reset added in v2.7.2 

func (x *AutocompleteSavedInterceptsResponse) Reset()

func (*AutocompleteSavedInterceptsResponse) String added in v2.7.2 

func (x *AutocompleteSavedInterceptsResponse) String() string

type AvailableNamespacesRequest 

type AvailableNamespacesRequest struct {
	DaemonInfo          *DaemonInfo  `protobuf:"bytes,1,opt,name=daemon_info,json=daemonInfo,proto3" json:"daemon_info,omitempty"`
	AvailableNamespaces []*Namespace `protobuf:"bytes,2,rep,name=available_namespaces,json=availableNamespaces,proto3" json:"available_namespaces,omitempty"`
	// contains filtered or unexported fields
}

AvailableNamespacesRequest contains a list of namespaces that can be intercepted by the daemon

func (*AvailableNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use AvailableNamespacesRequest.ProtoReflect.Descriptor instead.

func (*AvailableNamespacesRequest) GetAvailableNamespaces 

func (x *AvailableNamespacesRequest) GetAvailableNamespaces() []*Namespace

func (*AvailableNamespacesRequest) GetDaemonInfo 

func (x *AvailableNamespacesRequest) GetDaemonInfo() *DaemonInfo

func (*AvailableNamespacesRequest) ProtoMessage 

func (*AvailableNamespacesRequest) ProtoMessage()

func (*AvailableNamespacesRequest) ProtoReflect 

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

func (*AvailableNamespacesRequest) Reset 

func (x *AvailableNamespacesRequest) Reset()

func (*AvailableNamespacesRequest) String 

func (x *AvailableNamespacesRequest) String() string

type AvailableServicesRequest added in v2.5.5 

type AvailableServicesRequest struct {
	DaemonInfo        *DaemonInfo `protobuf:"bytes,1,opt,name=daemon_info,json=daemonInfo,proto3" json:"daemon_info,omitempty"`
	AvailableServices []*Service  `protobuf:"bytes,2,rep,name=available_services,json=availableServices,proto3" json:"available_services,omitempty"`
	// contains filtered or unexported fields
}

AvailableServicesRequest contains a list of services that can be intercepted by the daemon

func (*AvailableServicesRequest) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use AvailableServicesRequest.ProtoReflect.Descriptor instead.

func (*AvailableServicesRequest) GetAvailableServices added in v2.5.5 

func (x *AvailableServicesRequest) GetAvailableServices() []*Service

func (*AvailableServicesRequest) GetDaemonInfo added in v2.5.5 

func (x *AvailableServicesRequest) GetDaemonInfo() *DaemonInfo

func (*AvailableServicesRequest) ProtoMessage added in v2.5.5 

func (*AvailableServicesRequest) ProtoMessage()

func (*AvailableServicesRequest) ProtoReflect added in v2.5.5 

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

func (*AvailableServicesRequest) Reset added in v2.5.5 

func (x *AvailableServicesRequest) Reset()

func (*AvailableServicesRequest) String added in v2.5.5 

func (x *AvailableServicesRequest) String() string

type DaemonInfo 

type DaemonInfo struct {
	DaemonId        string  `protobuf:"bytes,1,opt,name=daemon_id,json=daemonId,proto3" json:"daemon_id,omitempty"`
	WorkstationName string  `protobuf:"bytes,2,opt,name=workstation_name,json=workstationName,proto3" json:"workstation_name,omitempty"`
	KubeContextName string  `protobuf:"bytes,3,opt,name=kube_context_name,json=kubeContextName,proto3" json:"kube_context_name,omitempty"`
	SessionId       string  `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	CliVersion      *string `protobuf:"bytes,5,opt,name=cli_version,json=cliVersion,proto3,oneof" json:"cli_version,omitempty"`
	DaemonVersion   *string `protobuf:"bytes,6,opt,name=daemon_version,json=daemonVersion,proto3,oneof" json:"daemon_version,omitempty"`
	// contains filtered or unexported fields
}

DaemonIdentity identifies a daemon so that System A can reach it back

func (*DaemonInfo) Descriptor deprecated 

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

Deprecated: Use DaemonInfo.ProtoReflect.Descriptor instead.

func (*DaemonInfo) GetCliVersion added in v2.7.0 

func (x *DaemonInfo) GetCliVersion() string

func (*DaemonInfo) GetDaemonId 

func (x *DaemonInfo) GetDaemonId() string

func (*DaemonInfo) GetDaemonVersion added in v2.7.0 

func (x *DaemonInfo) GetDaemonVersion() string

func (*DaemonInfo) GetKubeContextName 

func (x *DaemonInfo) GetKubeContextName() string

func (*DaemonInfo) GetSessionId 

func (x *DaemonInfo) GetSessionId() string

func (*DaemonInfo) GetWorkstationName 

func (x *DaemonInfo) GetWorkstationName() string

func (*DaemonInfo) ProtoMessage 

func (*DaemonInfo) ProtoMessage()

func (*DaemonInfo) ProtoReflect 

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

func (*DaemonInfo) Reset 

func (x *DaemonInfo) Reset()

func (*DaemonInfo) String 

func (x *DaemonInfo) String() string

type GetSavedInterceptRequest added in v2.7.0 

type GetSavedInterceptRequest struct {

	// Name of the intercept definition to look up
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetSavedInterceptRequest represents a request to get a specific InterceptDefinition by its name

func (*GetSavedInterceptRequest) Descriptor deprecated added in v2.7.0 

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

Deprecated: Use GetSavedInterceptRequest.ProtoReflect.Descriptor instead.

func (*GetSavedInterceptRequest) GetName added in v2.7.0 

func (x *GetSavedInterceptRequest) GetName() string

func (*GetSavedInterceptRequest) ProtoMessage added in v2.7.0 

func (*GetSavedInterceptRequest) ProtoMessage()

func (*GetSavedInterceptRequest) ProtoReflect added in v2.7.0 

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

func (*GetSavedInterceptRequest) Reset added in v2.7.0 

func (x *GetSavedInterceptRequest) Reset()

func (*GetSavedInterceptRequest) String added in v2.7.0 

func (x *GetSavedInterceptRequest) String() string

type IngressInfoRequest 

type IngressInfoRequest struct {

	// The service uid defined in the service's metadata
	ServiceUid string `protobuf:"bytes,1,opt,name=service_uid,json=serviceUid,proto3" json:"service_uid,omitempty"`
	// The service name
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The port name as defined in the service specs
	ServicePortIdentifier string `` /* 126-byte string literal not displayed */
	// The port value as defined in the service specs
	ServicePort int32 `protobuf:"varint,4,opt,name=service_port,json=servicePort,proto3" json:"service_port,omitempty"`
	// The namespace in which the intercept takes place
	Namespace string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

IngressInfoRequest represents the intercept properties required to resolve ingress info

func (*IngressInfoRequest) Descriptor deprecated 

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

Deprecated: Use IngressInfoRequest.ProtoReflect.Descriptor instead.

func (*IngressInfoRequest) GetNamespace 

func (x *IngressInfoRequest) GetNamespace() string

func (*IngressInfoRequest) GetServiceName 

func (x *IngressInfoRequest) GetServiceName() string

func (*IngressInfoRequest) GetServicePort 

func (x *IngressInfoRequest) GetServicePort() int32

func (*IngressInfoRequest) GetServicePortIdentifier 

func (x *IngressInfoRequest) GetServicePortIdentifier() string

func (*IngressInfoRequest) GetServiceUid 

func (x *IngressInfoRequest) GetServiceUid() string

func (*IngressInfoRequest) ProtoMessage 

func (*IngressInfoRequest) ProtoMessage()

func (*IngressInfoRequest) ProtoReflect 

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

func (*IngressInfoRequest) Reset 

func (x *IngressInfoRequest) Reset()

func (*IngressInfoRequest) String 

func (x *IngressInfoRequest) String() string

type IngressInfoResponse 

type IngressInfoResponse struct {

	// The layer-3 host
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The layer-4 port
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Whether or not to use TLS on the port
	UseTls bool `protobuf:"varint,3,opt,name=use_tls,json=useTls,proto3" json:"use_tls,omitempty"`
	// The layer-5 host
	L5Host string `protobuf:"bytes,4,opt,name=l5host,proto3" json:"l5host,omitempty"`
	// contains filtered or unexported fields
}

IngressInfoResponse represents the ingress properties required to configure a preview url

func (*IngressInfoResponse) Descriptor deprecated 

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

Deprecated: Use IngressInfoResponse.ProtoReflect.Descriptor instead.

func (*IngressInfoResponse) GetHost 

func (x *IngressInfoResponse) GetHost() string

func (*IngressInfoResponse) GetL5Host 

func (x *IngressInfoResponse) GetL5Host() string

func (*IngressInfoResponse) GetPort 

func (x *IngressInfoResponse) GetPort() int32

func (*IngressInfoResponse) GetUseTls 

func (x *IngressInfoResponse) GetUseTls() bool

func (*IngressInfoResponse) ProtoMessage 

func (*IngressInfoResponse) ProtoMessage()

func (*IngressInfoResponse) ProtoReflect 

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

func (*IngressInfoResponse) Reset 

func (x *IngressInfoResponse) Reset()

func (*IngressInfoResponse) String 

func (x *IngressInfoResponse) String() string

type InterceptCreationResult added in v2.7.0 

type InterceptCreationResult struct {

	// Daemon ID, as defined in DaemonInfo
	DaemonId string `protobuf:"bytes,1,opt,name=daemon_id,json=daemonId,proto3" json:"daemon_id,omitempty"`
	// Time at which the command execution started
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Time at which the command execution completed
	EndedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
	// Base name of the intercept, as represented by `telepresence intercept <intercept_base_name>`
	InterceptBaseName string `protobuf:"bytes,4,opt,name=intercept_base_name,json=interceptBaseName,proto3" json:"intercept_base_name,omitempty"`
	// List of parameters that were passed to the command
	InterceptParameters []*InterceptParameter `protobuf:"bytes,5,rep,name=intercept_parameters,json=interceptParameters,proto3" json:"intercept_parameters,omitempty"`
	// Exec command and arguments that can optionally be passed
	InterceptExecCommand string `protobuf:"bytes,6,opt,name=intercept_exec_command,json=interceptExecCommand,proto3" json:"intercept_exec_command,omitempty"`
	// InterceptError resulting from the execution
	InterceptError common.InterceptError `` /* 144-byte string literal not displayed */
	// Error text message if any
	InterceptErrorText string `protobuf:"bytes,8,opt,name=intercept_error_text,json=interceptErrorText,proto3" json:"intercept_error_text,omitempty"`
	// Cluster ID in which the intercept was executed
	ClusterId string `protobuf:"bytes,9,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Namespace in which the intercept was executed. Must be the same as the `--namespace` argument if passed.
	ClusterNamespace string `protobuf:"bytes,10,opt,name=cluster_namespace,json=clusterNamespace,proto3" json:"cluster_namespace,omitempty"`
	// contains filtered or unexported fields
}

InterceptCreationResult represents the result of an intercept execution

func (*InterceptCreationResult) Descriptor deprecated added in v2.7.0 

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

Deprecated: Use InterceptCreationResult.ProtoReflect.Descriptor instead.

func (*InterceptCreationResult) GetClusterId added in v2.7.0 

func (x *InterceptCreationResult) GetClusterId() string

func (*InterceptCreationResult) GetClusterNamespace added in v2.7.0 

func (x *InterceptCreationResult) GetClusterNamespace() string

func (*InterceptCreationResult) GetDaemonId added in v2.7.0 

func (x *InterceptCreationResult) GetDaemonId() string

func (*InterceptCreationResult) GetEndedAt added in v2.7.0 

func (x *InterceptCreationResult) GetEndedAt() *timestamppb.Timestamp

func (*InterceptCreationResult) GetInterceptBaseName added in v2.7.0 

func (x *InterceptCreationResult) GetInterceptBaseName() string

func (*InterceptCreationResult) GetInterceptError added in v2.7.0 

func (x *InterceptCreationResult) GetInterceptError() common.InterceptError

func (*InterceptCreationResult) GetInterceptErrorText added in v2.7.0 

func (x *InterceptCreationResult) GetInterceptErrorText() string

func (*InterceptCreationResult) GetInterceptExecCommand added in v2.7.0 

func (x *InterceptCreationResult) GetInterceptExecCommand() string

func (*InterceptCreationResult) GetInterceptParameters added in v2.7.0 

func (x *InterceptCreationResult) GetInterceptParameters() []*InterceptParameter

func (*InterceptCreationResult) GetStartedAt added in v2.7.0 

func (x *InterceptCreationResult) GetStartedAt() *timestamppb.Timestamp

func (*InterceptCreationResult) ProtoMessage added in v2.7.0 

func (*InterceptCreationResult) ProtoMessage()

func (*InterceptCreationResult) ProtoReflect added in v2.7.0 

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

func (*InterceptCreationResult) Reset added in v2.7.0 

func (x *InterceptCreationResult) Reset()

func (*InterceptCreationResult) String added in v2.7.0 

func (x *InterceptCreationResult) String() string

type InterceptParameter added in v2.7.0 

type InterceptParameter struct {

	// Name of the parameter
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value of the parameter
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

InterceptParameter represents a parameter passed to the intercept command

func (*InterceptParameter) Descriptor deprecated added in v2.7.0 

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

Deprecated: Use InterceptParameter.ProtoReflect.Descriptor instead.

func (*InterceptParameter) GetName added in v2.7.0 

func (x *InterceptParameter) GetName() string

func (*InterceptParameter) GetValue added in v2.7.0 

func (x *InterceptParameter) GetValue() string

func (*InterceptParameter) ProtoMessage added in v2.7.0 

func (*InterceptParameter) ProtoMessage()

func (*InterceptParameter) ProtoReflect added in v2.7.0 

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

func (*InterceptParameter) Reset added in v2.7.0 

func (x *InterceptParameter) Reset()

func (*InterceptParameter) String added in v2.7.0 

func (x *InterceptParameter) String() string

type Namespace 

type Namespace struct {
	Uid       string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	IsDefault bool   `protobuf:"varint,3,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated 

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetIsDefault 

func (x *Namespace) GetIsDefault() bool

func (*Namespace) GetName 

func (x *Namespace) GetName() string

func (*Namespace) GetUid 

func (x *Namespace) GetUid() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

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

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

type NamespacesToWatchRequest added in v2.5.5 

type NamespacesToWatchRequest struct {
	DaemonInfo *DaemonInfo  `protobuf:"bytes,1,opt,name=daemon_info,json=daemonInfo,proto3" json:"daemon_info,omitempty"`
	Namespaces []*Namespace `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespacesToWatchRequest) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use NamespacesToWatchRequest.ProtoReflect.Descriptor instead.

func (*NamespacesToWatchRequest) GetDaemonInfo added in v2.5.5 

func (x *NamespacesToWatchRequest) GetDaemonInfo() *DaemonInfo

func (*NamespacesToWatchRequest) GetNamespaces added in v2.5.5 

func (x *NamespacesToWatchRequest) GetNamespaces() []*Namespace

func (*NamespacesToWatchRequest) ProtoMessage added in v2.5.5 

func (*NamespacesToWatchRequest) ProtoMessage()

func (*NamespacesToWatchRequest) ProtoReflect added in v2.5.5 

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

func (*NamespacesToWatchRequest) Reset added in v2.5.5 

func (x *NamespacesToWatchRequest) Reset()

func (*NamespacesToWatchRequest) String added in v2.5.5 

func (x *NamespacesToWatchRequest) String() string

type NamespacesToWatchResponse added in v2.5.5 

type NamespacesToWatchResponse struct {
	Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*NamespacesToWatchResponse) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use NamespacesToWatchResponse.ProtoReflect.Descriptor instead.

func (*NamespacesToWatchResponse) GetNamespaces added in v2.5.5 

func (x *NamespacesToWatchResponse) GetNamespaces() []*Namespace

func (*NamespacesToWatchResponse) ProtoMessage added in v2.5.5 

func (*NamespacesToWatchResponse) ProtoMessage()

func (*NamespacesToWatchResponse) ProtoReflect added in v2.5.5 

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

func (*NamespacesToWatchResponse) Reset added in v2.5.5 

func (x *NamespacesToWatchResponse) Reset()

func (*NamespacesToWatchResponse) String added in v2.5.5 

func (x *NamespacesToWatchResponse) String() string

type Port added in v2.5.5 

type 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 (*Port) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use Port.ProtoReflect.Descriptor instead.

func (*Port) GetName added in v2.5.5 

func (x *Port) GetName() string

func (*Port) GetPort added in v2.5.5 

func (x *Port) GetPort() int32

func (*Port) ProtoMessage added in v2.5.5 

func (*Port) ProtoMessage()

func (*Port) ProtoReflect added in v2.5.5 

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

func (*Port) Reset added in v2.5.5 

func (x *Port) Reset()

func (*Port) String added in v2.5.5 

func (x *Port) String() string

type SavedIntercept added in v2.7.0 

type SavedIntercept struct {

	// Telepresence CLI version
	TelepresenceCliVersion string `` /* 129-byte string literal not displayed */
	// Telepresence User Daemon version
	TelepresenceUserDaemonVersion string `` /* 152-byte string literal not displayed */
	// Base name of the intercept, as represented by `telepresence intercept <intercept_base_name>`
	InterceptBaseName string `protobuf:"bytes,3,opt,name=intercept_base_name,json=interceptBaseName,proto3" json:"intercept_base_name,omitempty"`
	// List of parameters that were passed to the command
	InterceptParameters []*InterceptParameter `protobuf:"bytes,4,rep,name=intercept_parameters,json=interceptParameters,proto3" json:"intercept_parameters,omitempty"`
	// Exec command and arguments that can optionally be passed
	InterceptExecCommand string `protobuf:"bytes,5,opt,name=intercept_exec_command,json=interceptExecCommand,proto3" json:"intercept_exec_command,omitempty"`
	// contains filtered or unexported fields
}

SavedIntercept represents a set of properties that can be put back together to instantiate an intercept

func (*SavedIntercept) Descriptor deprecated added in v2.7.0 

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

Deprecated: Use SavedIntercept.ProtoReflect.Descriptor instead.

func (*SavedIntercept) GetInterceptBaseName added in v2.7.0 

func (x *SavedIntercept) GetInterceptBaseName() string

func (*SavedIntercept) GetInterceptExecCommand added in v2.7.0 

func (x *SavedIntercept) GetInterceptExecCommand() string

func (*SavedIntercept) GetInterceptParameters added in v2.7.0 

func (x *SavedIntercept) GetInterceptParameters() []*InterceptParameter

func (*SavedIntercept) GetTelepresenceCliVersion added in v2.7.0 

func (x *SavedIntercept) GetTelepresenceCliVersion() string

func (*SavedIntercept) GetTelepresenceUserDaemonVersion added in v2.7.0 

func (x *SavedIntercept) GetTelepresenceUserDaemonVersion() string

func (*SavedIntercept) ProtoMessage added in v2.7.0 

func (*SavedIntercept) ProtoMessage()

func (*SavedIntercept) ProtoReflect added in v2.7.0 

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

func (*SavedIntercept) Reset added in v2.7.0 

func (x *SavedIntercept) Reset()

func (*SavedIntercept) String added in v2.7.0 

func (x *SavedIntercept) String() string

type Service added in v2.5.5 

type Service struct {

	// uid corresponds to the Kubernetes service's metadata.uid
	Uid       string  `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name      string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string  `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Ports     []*Port `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// Most of the time, we'll get only 1 workload, but since we want to be able to eventually inform the user about the
	// edge case of having multiple workloads behind a service without needing to update the pro daemon version, the
	// information should be provided as a list and the UI will display the error when it's ready to do so
	Workloads []*Workload `protobuf:"bytes,5,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

Service represents a Kubernetes service

func (*Service) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetName added in v2.5.5 

func (x *Service) GetName() string

func (*Service) GetNamespace added in v2.5.5 

func (x *Service) GetNamespace() string

func (*Service) GetPorts added in v2.5.5 

func (x *Service) GetPorts() []*Port

func (*Service) GetUid added in v2.5.5 

func (x *Service) GetUid() string

func (*Service) GetWorkloads added in v2.5.5 

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

func (*Service) ProtoMessage added in v2.5.5 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect added in v2.5.5 

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

func (*Service) Reset added in v2.5.5 

func (x *Service) Reset()

func (*Service) String added in v2.5.5 

func (x *Service) String() string

type SystemAClient 

type SystemAClient interface {
	// ReportAvailableServices sends a list of services that the daemon has access to.
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	ReportAvailableServices(ctx context.Context, opts ...grpc.CallOption) (SystemA_ReportAvailableServicesClient, error)
	// GetNamespacesToWatch returns a list of namespaces that the user daemon should watch for workloads that can be
	// intercepted based on a list of namespaces that the user has access to.
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	GetNamespacesToWatch(ctx context.Context, in *NamespacesToWatchRequest, opts ...grpc.CallOption) (*NamespacesToWatchResponse, error)
	// ResolveInterceptIngressInfo gets the ingress information that the daemon should use to create the preview url
	// associated with an intercept
	ResolveIngressInfo(ctx context.Context, in *IngressInfoRequest, opts ...grpc.CallOption) (*IngressInfoResponse, error)
	// ReportAvailableNamespaces
	ReportAvailableNamespaces(ctx context.Context, opts ...grpc.CallOption) (SystemA_ReportAvailableNamespacesClient, error)
	// ReportInterceptCreation allows the proprietary user-daemon to report intercept creation once the intercept command
	// has completed
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	ReportInterceptCreation(ctx context.Context, in *InterceptCreationResult, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetSavedIntercept allows the proprietary user-daemon to retrieve a saved intercept so that it can instantiate it
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	GetSavedIntercept(ctx context.Context, in *GetSavedInterceptRequest, opts ...grpc.CallOption) (*SavedIntercept, error)
	// AutocompleteSavedIntercept provides the functionality for autocompleting saved intercept names on the cli
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	AutocompleteSavedIntercept(ctx context.Context, in *AutocompleteSavedInterceptRequest, opts ...grpc.CallOption) (*AutocompleteSavedInterceptsResponse, error)
}

SystemAClient is the client API for SystemA 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 NewSystemAClient 

func NewSystemAClient(cc grpc.ClientConnInterface) SystemAClient

type SystemAServer 

type SystemAServer interface {
	// ReportAvailableServices sends a list of services that the daemon has access to.
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	ReportAvailableServices(SystemA_ReportAvailableServicesServer) error
	// GetNamespacesToWatch returns a list of namespaces that the user daemon should watch for workloads that can be
	// intercepted based on a list of namespaces that the user has access to.
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	GetNamespacesToWatch(context.Context, *NamespacesToWatchRequest) (*NamespacesToWatchResponse, error)
	// ResolveInterceptIngressInfo gets the ingress information that the daemon should use to create the preview url
	// associated with an intercept
	ResolveIngressInfo(context.Context, *IngressInfoRequest) (*IngressInfoResponse, error)
	// ReportAvailableNamespaces
	ReportAvailableNamespaces(SystemA_ReportAvailableNamespacesServer) error
	// ReportInterceptCreation allows the proprietary user-daemon to report intercept creation once the intercept command
	// has completed
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	ReportInterceptCreation(context.Context, *InterceptCreationResult) (*emptypb.Empty, error)
	// GetSavedIntercept allows the proprietary user-daemon to retrieve a saved intercept so that it can instantiate it
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	GetSavedIntercept(context.Context, *GetSavedInterceptRequest) (*SavedIntercept, error)
	// AutocompleteSavedIntercept provides the functionality for autocompleting saved intercept names on the cli
	//
	// This RPC is only used by the proprietary user-daemon and not the OSS one.
	AutocompleteSavedIntercept(context.Context, *AutocompleteSavedInterceptRequest) (*AutocompleteSavedInterceptsResponse, error)
	// contains filtered or unexported methods
}

SystemAServer is the server API for SystemA service. All implementations must embed UnimplementedSystemAServer for forward compatibility

type SystemA_ReportAvailableNamespacesClient 

type SystemA_ReportAvailableNamespacesClient interface {
	Send(*AvailableNamespacesRequest) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type SystemA_ReportAvailableNamespacesServer 

type SystemA_ReportAvailableNamespacesServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*AvailableNamespacesRequest, error)
	grpc.ServerStream
}

type SystemA_ReportAvailableServicesClient added in v2.5.5 

type SystemA_ReportAvailableServicesClient interface {
	Send(*AvailableServicesRequest) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type SystemA_ReportAvailableServicesServer added in v2.5.5 

type SystemA_ReportAvailableServicesServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*AvailableServicesRequest, error)
	grpc.ServerStream
}

type UnimplementedSystemAServer 

type UnimplementedSystemAServer struct {
}

UnimplementedSystemAServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemAServer) AutocompleteSavedIntercept added in v2.7.2 

func (UnimplementedSystemAServer) AutocompleteSavedIntercept(context.Context, *AutocompleteSavedInterceptRequest) (*AutocompleteSavedInterceptsResponse, error)

func (UnimplementedSystemAServer) GetNamespacesToWatch added in v2.5.5 

func (UnimplementedSystemAServer) GetNamespacesToWatch(context.Context, *NamespacesToWatchRequest) (*NamespacesToWatchResponse, error)

func (UnimplementedSystemAServer) GetSavedIntercept added in v2.7.0 

func (UnimplementedSystemAServer) GetSavedIntercept(context.Context, *GetSavedInterceptRequest) (*SavedIntercept, error)

func (UnimplementedSystemAServer) ReportAvailableNamespaces 

func (UnimplementedSystemAServer) ReportAvailableNamespaces(SystemA_ReportAvailableNamespacesServer) error

func (UnimplementedSystemAServer) ReportAvailableServices added in v2.5.5 

func (UnimplementedSystemAServer) ReportAvailableServices(SystemA_ReportAvailableServicesServer) error

func (UnimplementedSystemAServer) ReportInterceptCreation added in v2.7.0 

func (UnimplementedSystemAServer) ReportInterceptCreation(context.Context, *InterceptCreationResult) (*emptypb.Empty, error)

func (UnimplementedSystemAServer) ResolveIngressInfo 

func (UnimplementedSystemAServer) ResolveIngressInfo(context.Context, *IngressInfoRequest) (*IngressInfoResponse, error)

type UnsafeSystemAServer 

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

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

type Workload added in v2.5.5 

type Workload struct {
	Uid  string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Workload represents a Kubernetes workload (deployment, stateful set, replica set, ...)

func (*Workload) Descriptor deprecated added in v2.5.5 

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

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetKind added in v2.5.5 

func (x *Workload) GetKind() string

func (*Workload) GetName added in v2.5.5 

func (x *Workload) GetName() string

func (*Workload) GetUid added in v2.5.5 

func (x *Workload) GetUid() string

func (*Workload) ProtoMessage added in v2.5.5 

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect added in v2.5.5 

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

func (*Workload) Reset added in v2.5.5 

func (x *Workload) Reset()

func (*Workload) String added in v2.5.5 

func (x *Workload) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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