agent

Documentation

Index

• Constants
• Variables
• func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
• type AgentClient
  • func NewAgentClient(cc grpc.ClientConnInterface) AgentClient
• type AgentServer
• type Agent_TunnelClient
• type Agent_TunnelServer
• type Agent_WatchDialClient
• type Agent_WatchDialServer
• type UnimplementedAgentServer
  • func (UnimplementedAgentServer) Tunnel(Agent_TunnelServer) error
  • func (UnimplementedAgentServer) Version(context.Context, *emptypb.Empty) (*manager.VersionInfo2, error)
  • func (UnimplementedAgentServer) WatchDial(*manager.SessionInfo, Agent_WatchDialServer) error
• type UnsafeAgentServer

Constants

const (
	Agent_Tunnel_FullMethodName    = "/telepresence.agent.Agent/Tunnel"
	Agent_Version_FullMethodName   = "/telepresence.agent.Agent/Version"
	Agent_WatchDial_FullMethodName = "/telepresence.agent.Agent/WatchDial"
)

Variables

var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.agent.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _Agent_Version_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Tunnel",
			Handler:       _Agent_Tunnel_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "WatchDial",
			Handler:       _Agent_WatchDial_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent/agent.proto",
}

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

var File_agent_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

Types

type AgentClient

type AgentClient interface {
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (Agent_TunnelClient, error)
	// Version returns the version information of the Manager.
	Version(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*manager.VersionInfo2, error)
	// WatchDial makes it possible for the client side to receive DialRequests
	// from the traffic-agent. Requests are sent when an intercepted agent needs
	// a Tunnel to the Telepresence client on the workstation. The receiver of
	// the request dials a connection and responds with the needed Tunnel.
	WatchDial(ctx context.Context, in *manager.SessionInfo, opts ...grpc.CallOption) (Agent_WatchDialClient, error)
}

AgentClient is the client API for Agent 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 NewAgentClient

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer

type AgentServer interface {
	Tunnel(Agent_TunnelServer) error
	// Version returns the version information of the Manager.
	Version(context.Context, *emptypb.Empty) (*manager.VersionInfo2, error)
	// WatchDial makes it possible for the client side to receive DialRequests
	// from the traffic-agent. Requests are sent when an intercepted agent needs
	// a Tunnel to the Telepresence client on the workstation. The receiver of
	// the request dials a connection and responds with the needed Tunnel.
	WatchDial(*manager.SessionInfo, Agent_WatchDialServer) error
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_TunnelClient

type Agent_TunnelClient interface {
	Send(*manager.TunnelMessage) error
	Recv() (*manager.TunnelMessage, error)
	grpc.ClientStream
}

type Agent_TunnelServer

type Agent_TunnelServer interface {
	Send(*manager.TunnelMessage) error
	Recv() (*manager.TunnelMessage, error)
	grpc.ServerStream
}

type Agent_WatchDialClient

type Agent_WatchDialClient interface {
	Recv() (*manager.DialRequest, error)
	grpc.ClientStream
}

type Agent_WatchDialServer

type Agent_WatchDialServer interface {
	Send(*manager.DialRequest) error
	grpc.ServerStream
}

type UnimplementedAgentServer

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) Tunnel

func (UnimplementedAgentServer) Tunnel(Agent_TunnelServer) error

func (UnimplementedAgentServer) Version

func (UnimplementedAgentServer) Version(context.Context, *emptypb.Empty) (*manager.VersionInfo2, error)

func (UnimplementedAgentServer) WatchDial

func (UnimplementedAgentServer) WatchDial(*manager.SessionInfo, Agent_WatchDialServer) error

type UnsafeAgentServer

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

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