userdaemon

package
v2.6.6 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2022 License: Apache-2.0 Imports: 9 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,
		},
	},
	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 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"`
	// 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) GetDaemonId 

func (x *DaemonInfo) GetDaemonId() 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 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 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 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)
}

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
	// 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) GetNamespacesToWatch added in v2.5.5 

func (UnimplementedSystemAServer) GetNamespacesToWatch(context.Context, *NamespacesToWatchRequest) (*NamespacesToWatchResponse, 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) 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.