v1beta1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2021 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_daemon_proto_meshnet_v1beta1_meshnet_proto protoreflect.FileDescriptor
View Source 
var Local_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meshnet.v1beta1.Local",
	HandlerType: (*LocalServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Local_Get_Handler,
		},
		{
			MethodName: "SetAlive",
			Handler:    _Local_SetAlive_Handler,
		},
		{
			MethodName: "SkipReverse",
			Handler:    _Local_SkipReverse_Handler,
		},
		{
			MethodName: "Skip",
			Handler:    _Local_Skip_Handler,
		},
		{
			MethodName: "IsSkipped",
			Handler:    _Local_IsSkipped_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "daemon/proto/meshnet/v1beta1/meshnet.proto",
}

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

View Source 
var Remote_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meshnet.v1beta1.Remote",
	HandlerType: (*RemoteServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Update",
			Handler:    _Remote_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "daemon/proto/meshnet/v1beta1/meshnet.proto",
}

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

Functions

func RegisterLocalServer 

func RegisterLocalServer(s grpc.ServiceRegistrar, srv LocalServer)

func RegisterRemoteServer 

func RegisterRemoteServer(s grpc.ServiceRegistrar, srv RemoteServer)

Types

type BoolResponse 

type BoolResponse struct {
	Response bool `protobuf:"varint,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*BoolResponse) Descriptor deprecated 

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

Deprecated: Use BoolResponse.ProtoReflect.Descriptor instead.

func (*BoolResponse) GetResponse 

func (x *BoolResponse) GetResponse() bool

func (*BoolResponse) ProtoMessage 

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) ProtoReflect 

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

func (*BoolResponse) Reset 

func (x *BoolResponse) Reset()

func (*BoolResponse) String 

func (x *BoolResponse) String() string
type Link struct {
	PeerPod   string `protobuf:"bytes,1,opt,name=peer_pod,json=peerPod,proto3" json:"peer_pod,omitempty"`
	LocalIntf string `protobuf:"bytes,2,opt,name=local_intf,json=localIntf,proto3" json:"local_intf,omitempty"`
	PeerIntf  string `protobuf:"bytes,3,opt,name=peer_intf,json=peerIntf,proto3" json:"peer_intf,omitempty"`
	LocalIp   string `protobuf:"bytes,4,opt,name=local_ip,json=localIp,proto3" json:"local_ip,omitempty"`
	PeerIp    string `protobuf:"bytes,5,opt,name=peer_ip,json=peerIp,proto3" json:"peer_ip,omitempty"`
	Uid       int64  `protobuf:"varint,6,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*Link) Descriptor deprecated 

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetLocalIntf 

func (x *Link) GetLocalIntf() string

func (*Link) GetLocalIp 

func (x *Link) GetLocalIp() string

func (*Link) GetPeerIntf 

func (x *Link) GetPeerIntf() string

func (*Link) GetPeerIp 

func (x *Link) GetPeerIp() string

func (*Link) GetPeerPod 

func (x *Link) GetPeerPod() string

func (*Link) GetUid 

func (x *Link) GetUid() int64

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

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

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) String 

func (x *Link) String() string

type LocalClient 

type LocalClient interface {
	Get(ctx context.Context, in *PodQuery, opts ...grpc.CallOption) (*Pod, error)
	SetAlive(ctx context.Context, in *Pod, opts ...grpc.CallOption) (*BoolResponse, error)
	SkipReverse(ctx context.Context, in *SkipQuery, opts ...grpc.CallOption) (*BoolResponse, error)
	Skip(ctx context.Context, in *SkipQuery, opts ...grpc.CallOption) (*BoolResponse, error)
	IsSkipped(ctx context.Context, in *SkipQuery, opts ...grpc.CallOption) (*BoolResponse, error)
}

LocalClient is the client API for Local 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 NewLocalClient 

func NewLocalClient(cc grpc.ClientConnInterface) LocalClient

type LocalServer 

type LocalServer interface {
	Get(context.Context, *PodQuery) (*Pod, error)
	SetAlive(context.Context, *Pod) (*BoolResponse, error)
	SkipReverse(context.Context, *SkipQuery) (*BoolResponse, error)
	Skip(context.Context, *SkipQuery) (*BoolResponse, error)
	IsSkipped(context.Context, *SkipQuery) (*BoolResponse, error)
	// contains filtered or unexported methods
}

LocalServer is the server API for Local service. All implementations must embed UnimplementedLocalServer for forward compatibility

type Pod 

type Pod struct {
	Name   string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SrcIp  string  `protobuf:"bytes,2,opt,name=src_ip,json=srcIp,proto3" json:"src_ip,omitempty"`
	NetNs  string  `protobuf:"bytes,3,opt,name=net_ns,json=netNs,proto3" json:"net_ns,omitempty"`
	KubeNs string  `protobuf:"bytes,4,opt,name=kube_ns,json=kubeNs,proto3" json:"kube_ns,omitempty"`
	Links  []*Link `protobuf:"bytes,5,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*Pod) Descriptor deprecated 

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

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetKubeNs 

func (x *Pod) GetKubeNs() string
func (x *Pod) GetLinks() []*Link

func (*Pod) GetName 

func (x *Pod) GetName() string

func (*Pod) GetNetNs 

func (x *Pod) GetNetNs() string

func (*Pod) GetSrcIp 

func (x *Pod) GetSrcIp() string

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect 

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

func (*Pod) Reset 

func (x *Pod) Reset()

func (*Pod) String 

func (x *Pod) String() string

type PodQuery 

type PodQuery struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	KubeNs string `protobuf:"bytes,2,opt,name=kube_ns,json=kubeNs,proto3" json:"kube_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PodQuery) Descriptor deprecated 

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

Deprecated: Use PodQuery.ProtoReflect.Descriptor instead.

func (*PodQuery) GetKubeNs 

func (x *PodQuery) GetKubeNs() string

func (*PodQuery) GetName 

func (x *PodQuery) GetName() string

func (*PodQuery) ProtoMessage 

func (*PodQuery) ProtoMessage()

func (*PodQuery) ProtoReflect 

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

func (*PodQuery) Reset 

func (x *PodQuery) Reset()

func (*PodQuery) String 

func (x *PodQuery) String() string

type RemoteClient 

type RemoteClient interface {
	Update(ctx context.Context, in *RemotePod, opts ...grpc.CallOption) (*BoolResponse, error)
}

RemoteClient is the client API for Remote 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 NewRemoteClient 

func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient

type RemotePod 

type RemotePod struct {
	NetNs    string `protobuf:"bytes,1,opt,name=net_ns,json=netNs,proto3" json:"net_ns,omitempty"`
	IntfName string `protobuf:"bytes,2,opt,name=intf_name,json=intfName,proto3" json:"intf_name,omitempty"`
	IntfIp   string `protobuf:"bytes,3,opt,name=intf_ip,json=intfIp,proto3" json:"intf_ip,omitempty"`
	PeerVtep string `protobuf:"bytes,4,opt,name=peer_vtep,json=peerVtep,proto3" json:"peer_vtep,omitempty"`
	KubeNs   string `protobuf:"bytes,5,opt,name=kube_ns,json=kubeNs,proto3" json:"kube_ns,omitempty"`
	Vni      int64  `protobuf:"varint,6,opt,name=vni,proto3" json:"vni,omitempty"`
	// contains filtered or unexported fields
}

func (*RemotePod) Descriptor deprecated 

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

Deprecated: Use RemotePod.ProtoReflect.Descriptor instead.

func (*RemotePod) GetIntfIp 

func (x *RemotePod) GetIntfIp() string

func (*RemotePod) GetIntfName 

func (x *RemotePod) GetIntfName() string

func (*RemotePod) GetKubeNs 

func (x *RemotePod) GetKubeNs() string

func (*RemotePod) GetNetNs 

func (x *RemotePod) GetNetNs() string

func (*RemotePod) GetPeerVtep 

func (x *RemotePod) GetPeerVtep() string

func (*RemotePod) GetVni 

func (x *RemotePod) GetVni() int64

func (*RemotePod) ProtoMessage 

func (*RemotePod) ProtoMessage()

func (*RemotePod) ProtoReflect 

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

func (*RemotePod) Reset 

func (x *RemotePod) Reset()

func (*RemotePod) String 

func (x *RemotePod) String() string

type RemoteServer 

type RemoteServer interface {
	Update(context.Context, *RemotePod) (*BoolResponse, error)
	// contains filtered or unexported methods
}

RemoteServer is the server API for Remote service. All implementations must embed UnimplementedRemoteServer for forward compatibility

type SkipQuery 

type SkipQuery struct {
	Pod    string `protobuf:"bytes,1,opt,name=pod,proto3" json:"pod,omitempty"`
	Peer   string `protobuf:"bytes,2,opt,name=peer,proto3" json:"peer,omitempty"`
	KubeNs string `protobuf:"bytes,3,opt,name=kube_ns,json=kubeNs,proto3" json:"kube_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*SkipQuery) Descriptor deprecated 

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

Deprecated: Use SkipQuery.ProtoReflect.Descriptor instead.

func (*SkipQuery) GetKubeNs 

func (x *SkipQuery) GetKubeNs() string

func (*SkipQuery) GetPeer 

func (x *SkipQuery) GetPeer() string

func (*SkipQuery) GetPod 

func (x *SkipQuery) GetPod() string

func (*SkipQuery) ProtoMessage 

func (*SkipQuery) ProtoMessage()

func (*SkipQuery) ProtoReflect 

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

func (*SkipQuery) Reset 

func (x *SkipQuery) Reset()

func (*SkipQuery) String 

func (x *SkipQuery) String() string

type UnimplementedLocalServer 

type UnimplementedLocalServer struct {
}

UnimplementedLocalServer must be embedded to have forward compatible implementations.

func (UnimplementedLocalServer) Get 

func (UnimplementedLocalServer) Get(context.Context, *PodQuery) (*Pod, error)

func (UnimplementedLocalServer) IsSkipped 

func (UnimplementedLocalServer) IsSkipped(context.Context, *SkipQuery) (*BoolResponse, error)

func (UnimplementedLocalServer) SetAlive 

func (UnimplementedLocalServer) SetAlive(context.Context, *Pod) (*BoolResponse, error)

func (UnimplementedLocalServer) Skip 

func (UnimplementedLocalServer) Skip(context.Context, *SkipQuery) (*BoolResponse, error)

func (UnimplementedLocalServer) SkipReverse 

func (UnimplementedLocalServer) SkipReverse(context.Context, *SkipQuery) (*BoolResponse, error)

type UnimplementedRemoteServer 

type UnimplementedRemoteServer struct {
}

UnimplementedRemoteServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteServer) Update 

func (UnimplementedRemoteServer) Update(context.Context, *RemotePod) (*BoolResponse, error)

type UnsafeLocalServer 

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

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

type UnsafeRemoteServer 

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

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