userdaemon

package
v2.5.4-rc.4 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 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: "ResolveIngressInfo",
			Handler:    _SystemA_ResolveIngressInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			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 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 SystemAClient 

type SystemAClient interface {
	// 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 {
	// 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 UnimplementedSystemAServer 

type UnimplementedSystemAServer struct {
}

UnimplementedSystemAServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemAServer) ReportAvailableNamespaces 

func (UnimplementedSystemAServer) ReportAvailableNamespaces(SystemA_ReportAvailableNamespacesServer) 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.

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.