daemon

package
v2.3.2 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2021 License: Apache-2.0 Imports: 12 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DaemonStatus_ErrType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NOT_STARTED",
		3: "NO_NETWORK",
	}
	DaemonStatus_ErrType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"NOT_STARTED": 1,
		"NO_NETWORK":  3,
	}
)

Enum value maps for DaemonStatus_ErrType.

View Source 
var File_rpc_daemon_daemon_proto protoreflect.FileDescriptor

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)

Types

type DNSConfig added in v2.3.1 

type DNSConfig struct {

	// local_ip is the address of the local DNS server. Only used by Linux systems that have no
	// systemd.resolved configured. Defaults to the first line of /etc/resolv.conf
	LocalIp []byte `protobuf:"bytes,1,opt,name=local_ip,json=localIp,proto3" json:"local_ip,omitempty"`
	// remote_ip is the address of the kube-dns.kube-system, dns-default.openshift-dns, or similar service,
	RemoteIp []byte `protobuf:"bytes,2,opt,name=remote_ip,json=remoteIp,proto3" json:"remote_ip,omitempty"`
	// Suffixes to exclude
	ExcludeSuffixes []string `protobuf:"bytes,3,rep,name=exclude_suffixes,json=excludeSuffixes,proto3" json:"exclude_suffixes,omitempty"`
	// Suffixes to include. Has higher prio than the excludes
	IncludeSuffixes []string `protobuf:"bytes,4,rep,name=include_suffixes,json=includeSuffixes,proto3" json:"include_suffixes,omitempty"`
	// The maximum time wait for a cluster side host lookup.
	LookupTimeout int64 `protobuf:"varint,5,opt,name=lookup_timeout,json=lookupTimeout,proto3" json:"lookup_timeout,omitempty"`
	// contains filtered or unexported fields
}

DNS configuration for the local DNS resolver

func (*DNSConfig) Descriptor deprecated added in v2.3.1 

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

Deprecated: Use DNSConfig.ProtoReflect.Descriptor instead.

func (*DNSConfig) GetExcludeSuffixes added in v2.3.1 

func (x *DNSConfig) GetExcludeSuffixes() []string

func (*DNSConfig) GetIncludeSuffixes added in v2.3.1 

func (x *DNSConfig) GetIncludeSuffixes() []string

func (*DNSConfig) GetLocalIp added in v2.3.1 

func (x *DNSConfig) GetLocalIp() []byte

func (*DNSConfig) GetLookupTimeout added in v2.3.1 

func (x *DNSConfig) GetLookupTimeout() int64

func (*DNSConfig) GetRemoteIp added in v2.3.1 

func (x *DNSConfig) GetRemoteIp() []byte

func (*DNSConfig) ProtoMessage added in v2.3.1 

func (*DNSConfig) ProtoMessage()

func (*DNSConfig) ProtoReflect added in v2.3.1 

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

func (*DNSConfig) Reset added in v2.3.1 

func (x *DNSConfig) Reset()

func (*DNSConfig) String added in v2.3.1 

func (x *DNSConfig) String() string

type DaemonClient 

type DaemonClient interface {
	// Version returns version information from the Daemon
	Version(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.VersionInfo, error)
	// Status returns the current connectivity status
	Status(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DaemonStatus, error)
	// Quit quits (terminates) the service.
	Quit(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetOutboundInfo provides the information needed to set up outbound connectivity
	SetOutboundInfo(ctx context.Context, in *OutboundInfo, opts ...grpc.CallOption) (*empty.Empty, error)
	// SetDnsSearchPath sets a new search path.
	SetDnsSearchPath(ctx context.Context, in *Paths, opts ...grpc.CallOption) (*empty.Empty, error)
}

DaemonClient is the client API for Daemon 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 NewDaemonClient 

func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient

type DaemonServer 

type DaemonServer interface {
	// Version returns version information from the Daemon
	Version(context.Context, *empty.Empty) (*common.VersionInfo, error)
	// Status returns the current connectivity status
	Status(context.Context, *empty.Empty) (*DaemonStatus, error)
	// Quit quits (terminates) the service.
	Quit(context.Context, *empty.Empty) (*empty.Empty, error)
	// SetOutboundInfo provides the information needed to set up outbound connectivity
	SetOutboundInfo(context.Context, *OutboundInfo) (*empty.Empty, error)
	// SetDnsSearchPath sets a new search path.
	SetDnsSearchPath(context.Context, *Paths) (*empty.Empty, error)
	// contains filtered or unexported methods
}

DaemonServer is the server API for Daemon service. All implementations must embed UnimplementedDaemonServer for forward compatibility

type DaemonStatus 

type DaemonStatus struct {
	Error DaemonStatus_ErrType `protobuf:"varint,1,opt,name=error,proto3,enum=telepresence.daemon.DaemonStatus_ErrType" json:"error,omitempty"`
	Dns   string               `protobuf:"bytes,2,opt,name=dns,proto3" json:"dns,omitempty"`
	// contains filtered or unexported fields
}

func (*DaemonStatus) Descriptor deprecated 

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

Deprecated: Use DaemonStatus.ProtoReflect.Descriptor instead.

func (*DaemonStatus) GetDns 

func (x *DaemonStatus) GetDns() string

func (*DaemonStatus) GetError 

func (x *DaemonStatus) GetError() DaemonStatus_ErrType

func (*DaemonStatus) ProtoMessage 

func (*DaemonStatus) ProtoMessage()

func (*DaemonStatus) ProtoReflect 

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

func (*DaemonStatus) Reset 

func (x *DaemonStatus) Reset()

func (*DaemonStatus) String 

func (x *DaemonStatus) String() string

type DaemonStatus_ErrType 

type DaemonStatus_ErrType int32
const (
	DaemonStatus_UNSPECIFIED DaemonStatus_ErrType = 0
	DaemonStatus_NOT_STARTED DaemonStatus_ErrType = 1
	DaemonStatus_NO_NETWORK  DaemonStatus_ErrType = 3
)

func (DaemonStatus_ErrType) Descriptor 

func (DaemonStatus_ErrType) Descriptor() protoreflect.EnumDescriptor

func (DaemonStatus_ErrType) Enum 

func (x DaemonStatus_ErrType) Enum() *DaemonStatus_ErrType

func (DaemonStatus_ErrType) EnumDescriptor deprecated 

func (DaemonStatus_ErrType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DaemonStatus_ErrType.Descriptor instead.

func (DaemonStatus_ErrType) Number 

func (x DaemonStatus_ErrType) Number() protoreflect.EnumNumber

func (DaemonStatus_ErrType) String 

func (x DaemonStatus_ErrType) String() string

func (DaemonStatus_ErrType) Type 

func (DaemonStatus_ErrType) Type() protoreflect.EnumType

type OutboundInfo added in v2.3.0 

type OutboundInfo struct {

	// manager_port is the port for the traffic-manager gRPC API.
	ManagerPort int32 `protobuf:"varint,1,opt,name=manager_port,json=managerPort,proto3" json:"manager_port,omitempty"`
	// session makes it possible for the root daemon to identify itself as the
	// same client as the user daemon.
	Session *manager.SessionInfo `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"`
	// DNS configuration
	Dns *DNSConfig `protobuf:"bytes,3,opt,name=dns,proto3" json:"dns,omitempty"`
	// also_proxy are user-added subnets.
	AlsoProxySubnets []*manager.IPNet `protobuf:"bytes,5,rep,name=also_proxy_subnets,json=alsoProxySubnets,proto3" json:"also_proxy_subnets,omitempty"`
	// contains filtered or unexported fields
}

OutboundInfo contains all information that the root daemon needs in order to establish outbound traffic to the cluster.

func (*OutboundInfo) Descriptor deprecated added in v2.3.0 

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

Deprecated: Use OutboundInfo.ProtoReflect.Descriptor instead.

func (*OutboundInfo) GetAlsoProxySubnets added in v2.3.2 

func (x *OutboundInfo) GetAlsoProxySubnets() []*manager.IPNet

func (*OutboundInfo) GetDns added in v2.3.1 

func (x *OutboundInfo) GetDns() *DNSConfig

func (*OutboundInfo) GetManagerPort added in v2.3.0 

func (x *OutboundInfo) GetManagerPort() int32

func (*OutboundInfo) GetSession added in v2.3.0 

func (x *OutboundInfo) GetSession() *manager.SessionInfo

func (*OutboundInfo) ProtoMessage added in v2.3.0 

func (*OutboundInfo) ProtoMessage()

func (*OutboundInfo) ProtoReflect added in v2.3.0 

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

func (*OutboundInfo) Reset added in v2.3.0 

func (x *OutboundInfo) Reset()

func (*OutboundInfo) String added in v2.3.0 

func (x *OutboundInfo) String() string

type Paths 

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

func (*Paths) Descriptor deprecated 

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

Deprecated: Use Paths.ProtoReflect.Descriptor instead.

func (*Paths) GetPaths 

func (x *Paths) GetPaths() []string

func (*Paths) ProtoMessage 

func (*Paths) ProtoMessage()

func (*Paths) ProtoReflect 

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

func (*Paths) Reset 

func (x *Paths) Reset()

func (*Paths) String 

func (x *Paths) String() string

type UnimplementedDaemonServer 

type UnimplementedDaemonServer struct {
}

UnimplementedDaemonServer must be embedded to have forward compatible implementations.

func (UnimplementedDaemonServer) Quit 

func (UnimplementedDaemonServer) Quit(context.Context, *empty.Empty) (*empty.Empty, error)

func (UnimplementedDaemonServer) SetDnsSearchPath 

func (UnimplementedDaemonServer) SetDnsSearchPath(context.Context, *Paths) (*empty.Empty, error)

func (UnimplementedDaemonServer) SetOutboundInfo added in v2.3.0 

func (UnimplementedDaemonServer) SetOutboundInfo(context.Context, *OutboundInfo) (*empty.Empty, error)

func (UnimplementedDaemonServer) Status 

func (UnimplementedDaemonServer) Status(context.Context, *empty.Empty) (*DaemonStatus, error)

func (UnimplementedDaemonServer) Version 

func (UnimplementedDaemonServer) Version(context.Context, *empty.Empty) (*common.VersionInfo, error)

type UnsafeDaemonServer 

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

UnsafeDaemonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DaemonServer 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.