Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCniDataplaneServer(s grpc.ServiceRegistrar, srv CniDataplaneServer)
- type AddReply
- func (*AddReply) Descriptor() ([]byte, []int)deprecated
- func (x *AddReply) GetContainerMac() string
- func (x *AddReply) GetErrorMessage() string
- func (x *AddReply) GetHostInterfaceName() string
- func (x *AddReply) GetSuccessful() bool
- func (*AddReply) ProtoMessage()
- func (x *AddReply) ProtoReflect() protoreflect.Message
- func (x *AddReply) Reset()
- func (x *AddReply) String() string
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddRequest) GetContainerIps() []*IPConfig
- func (x *AddRequest) GetContainerRoutes() []string
- func (x *AddRequest) GetDataplaneOptions() map[string]string
- func (x *AddRequest) GetDesiredHostInterfaceName() string
- func (x *AddRequest) GetInterfaceName() string
- func (x *AddRequest) GetNetns() string
- func (x *AddRequest) GetSettings() *ContainerSettings
- func (x *AddRequest) GetWorkload() *WorkloadIDs
- func (*AddRequest) ProtoMessage()
- func (x *AddRequest) ProtoReflect() protoreflect.Message
- func (x *AddRequest) Reset()
- func (x *AddRequest) String() string
- type CniDataplaneClient
- type CniDataplaneServer
- type ContainerSettings
- func (*ContainerSettings) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerSettings) GetAllowIpForwarding() bool
- func (x *ContainerSettings) GetMtu() int32
- func (*ContainerSettings) ProtoMessage()
- func (x *ContainerSettings) ProtoReflect() protoreflect.Message
- func (x *ContainerSettings) Reset()
- func (x *ContainerSettings) String() string
- type DelReply
- type DelRequest
- func (*DelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DelRequest) GetDataplaneOptions() map[string]string
- func (x *DelRequest) GetInterfaceName() string
- func (x *DelRequest) GetNetns() string
- func (*DelRequest) ProtoMessage()
- func (x *DelRequest) ProtoReflect() protoreflect.Message
- func (x *DelRequest) Reset()
- func (x *DelRequest) String() string
- type IPConfig
- type Port
- func (*Port) Descriptor() ([]byte, []int)deprecated
- func (x *Port) GetHostIp() string
- func (x *Port) GetHostPort() uint32
- func (x *Port) GetName() string
- func (x *Port) GetPort() uint32
- func (x *Port) GetProtocol() string
- func (*Port) ProtoMessage()
- func (x *Port) ProtoReflect() protoreflect.Message
- func (x *Port) Reset()
- func (x *Port) String() string
- type UnimplementedCniDataplaneServer
- type UnsafeCniDataplaneServer
- type WorkloadIDs
- func (*WorkloadIDs) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadIDs) GetAnnotations() map[string]string
- func (x *WorkloadIDs) GetEndpoint() string
- func (x *WorkloadIDs) GetLabels() map[string]string
- func (x *WorkloadIDs) GetName() string
- func (x *WorkloadIDs) GetNamespace() string
- func (x *WorkloadIDs) GetNode() string
- func (x *WorkloadIDs) GetOrchestrator() string
- func (x *WorkloadIDs) GetPod() string
- func (x *WorkloadIDs) GetPorts() []*Port
- func (*WorkloadIDs) ProtoMessage()
- func (x *WorkloadIDs) ProtoReflect() protoreflect.Message
- func (x *WorkloadIDs) Reset()
- func (x *WorkloadIDs) String() string
Constants ¶
const ( CniDataplane_Add_FullMethodName = "/cni.CniDataplane/Add" CniDataplane_Del_FullMethodName = "/cni.CniDataplane/Del" )
Variables ¶
var CniDataplane_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cni.CniDataplane", HandlerType: (*CniDataplaneServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Add", Handler: _CniDataplane_Add_Handler, }, { MethodName: "Del", Handler: _CniDataplane_Del_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cnibackend.proto", }
CniDataplane_ServiceDesc is the grpc.ServiceDesc for CniDataplane service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_cnibackend_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCniDataplaneServer ¶
func RegisterCniDataplaneServer(s grpc.ServiceRegistrar, srv CniDataplaneServer)
Types ¶
type AddReply ¶
type AddReply struct { Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` HostInterfaceName string `protobuf:"bytes,3,opt,name=host_interface_name,json=hostInterfaceName,proto3" json:"host_interface_name,omitempty"` ContainerMac string `protobuf:"bytes,4,opt,name=container_mac,json=containerMac,proto3" json:"container_mac,omitempty"` // contains filtered or unexported fields }
func (*AddReply) Descriptor
deprecated
func (*AddReply) GetContainerMac ¶
func (*AddReply) GetErrorMessage ¶
func (*AddReply) GetHostInterfaceName ¶
func (*AddReply) GetSuccessful ¶
func (*AddReply) ProtoMessage ¶
func (*AddReply) ProtoMessage()
func (*AddReply) ProtoReflect ¶
func (x *AddReply) ProtoReflect() protoreflect.Message
type AddRequest ¶
type AddRequest struct { InterfaceName string `protobuf:"bytes,1,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"` Netns string `protobuf:"bytes,2,opt,name=netns,proto3" json:"netns,omitempty"` DesiredHostInterfaceName string `` /* 137-byte string literal not displayed */ Settings *ContainerSettings `protobuf:"bytes,4,opt,name=settings,proto3" json:"settings,omitempty"` ContainerIps []*IPConfig `protobuf:"bytes,5,rep,name=container_ips,json=containerIps,proto3" json:"container_ips,omitempty"` ContainerRoutes []string `protobuf:"bytes,6,rep,name=container_routes,json=containerRoutes,proto3" json:"container_routes,omitempty"` Workload *WorkloadIDs `protobuf:"bytes,7,opt,name=workload,proto3" json:"workload,omitempty"` DataplaneOptions map[string]string `` /* 183-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetContainerIps ¶
func (x *AddRequest) GetContainerIps() []*IPConfig
func (*AddRequest) GetContainerRoutes ¶
func (x *AddRequest) GetContainerRoutes() []string
func (*AddRequest) GetDataplaneOptions ¶
func (x *AddRequest) GetDataplaneOptions() map[string]string
func (*AddRequest) GetDesiredHostInterfaceName ¶
func (x *AddRequest) GetDesiredHostInterfaceName() string
func (*AddRequest) GetInterfaceName ¶
func (x *AddRequest) GetInterfaceName() string
func (*AddRequest) GetNetns ¶
func (x *AddRequest) GetNetns() string
func (*AddRequest) GetSettings ¶
func (x *AddRequest) GetSettings() *ContainerSettings
func (*AddRequest) GetWorkload ¶
func (x *AddRequest) GetWorkload() *WorkloadIDs
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
type CniDataplaneClient ¶
type CniDataplaneClient interface { Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddReply, error) Del(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelReply, error) }
CniDataplaneClient is the client API for CniDataplane 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 NewCniDataplaneClient ¶
func NewCniDataplaneClient(cc grpc.ClientConnInterface) CniDataplaneClient
type CniDataplaneServer ¶
type CniDataplaneServer interface { Add(context.Context, *AddRequest) (*AddReply, error) Del(context.Context, *DelRequest) (*DelReply, error) // contains filtered or unexported methods }
CniDataplaneServer is the server API for CniDataplane service. All implementations must embed UnimplementedCniDataplaneServer for forward compatibility.
type ContainerSettings ¶
type ContainerSettings struct { AllowIpForwarding bool `protobuf:"varint,1,opt,name=allow_ip_forwarding,json=allowIpForwarding,proto3" json:"allow_ip_forwarding,omitempty"` Mtu int32 `protobuf:"varint,2,opt,name=mtu,proto3" json:"mtu,omitempty"` // contains filtered or unexported fields }
func (*ContainerSettings) Descriptor
deprecated
func (*ContainerSettings) Descriptor() ([]byte, []int)
Deprecated: Use ContainerSettings.ProtoReflect.Descriptor instead.
func (*ContainerSettings) GetAllowIpForwarding ¶
func (x *ContainerSettings) GetAllowIpForwarding() bool
func (*ContainerSettings) GetMtu ¶
func (x *ContainerSettings) GetMtu() int32
func (*ContainerSettings) ProtoMessage ¶
func (*ContainerSettings) ProtoMessage()
func (*ContainerSettings) ProtoReflect ¶
func (x *ContainerSettings) ProtoReflect() protoreflect.Message
func (*ContainerSettings) Reset ¶
func (x *ContainerSettings) Reset()
func (*ContainerSettings) String ¶
func (x *ContainerSettings) String() string
type DelReply ¶
type DelReply struct { Successful bool `protobuf:"varint,1,opt,name=successful,proto3" json:"successful,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"` // contains filtered or unexported fields }
func (*DelReply) Descriptor
deprecated
func (*DelReply) GetErrorMessage ¶
func (*DelReply) GetSuccessful ¶
func (*DelReply) ProtoMessage ¶
func (*DelReply) ProtoMessage()
func (*DelReply) ProtoReflect ¶
func (x *DelReply) ProtoReflect() protoreflect.Message
type DelRequest ¶
type DelRequest struct { InterfaceName string `protobuf:"bytes,1,opt,name=interface_name,json=interfaceName,proto3" json:"interface_name,omitempty"` Netns string `protobuf:"bytes,2,opt,name=netns,proto3" json:"netns,omitempty"` DataplaneOptions map[string]string `` /* 183-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DelRequest) Descriptor
deprecated
func (*DelRequest) Descriptor() ([]byte, []int)
Deprecated: Use DelRequest.ProtoReflect.Descriptor instead.
func (*DelRequest) GetDataplaneOptions ¶
func (x *DelRequest) GetDataplaneOptions() map[string]string
func (*DelRequest) GetInterfaceName ¶
func (x *DelRequest) GetInterfaceName() string
func (*DelRequest) GetNetns ¶
func (x *DelRequest) GetNetns() string
func (*DelRequest) ProtoMessage ¶
func (*DelRequest) ProtoMessage()
func (*DelRequest) ProtoReflect ¶
func (x *DelRequest) ProtoReflect() protoreflect.Message
func (*DelRequest) Reset ¶
func (x *DelRequest) Reset()
func (*DelRequest) String ¶
func (x *DelRequest) String() string
type IPConfig ¶
type IPConfig struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Gateway string `protobuf:"bytes,2,opt,name=gateway,proto3" json:"gateway,omitempty"` // contains filtered or unexported fields }
func (*IPConfig) Descriptor
deprecated
func (*IPConfig) GetAddress ¶
func (*IPConfig) GetGateway ¶
func (*IPConfig) ProtoMessage ¶
func (*IPConfig) ProtoMessage()
func (*IPConfig) ProtoReflect ¶
func (x *IPConfig) ProtoReflect() protoreflect.Message
type Port ¶
type Port struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"` Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` HostPort uint32 `protobuf:"varint,4,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"` HostIp string `protobuf:"bytes,5,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"` // contains filtered or unexported fields }
func (*Port) Descriptor
deprecated
func (*Port) GetHostPort ¶
func (*Port) GetProtocol ¶
func (*Port) ProtoMessage ¶
func (*Port) ProtoMessage()
func (*Port) ProtoReflect ¶
func (x *Port) ProtoReflect() protoreflect.Message
type UnimplementedCniDataplaneServer ¶
type UnimplementedCniDataplaneServer struct{}
UnimplementedCniDataplaneServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCniDataplaneServer) Add ¶
func (UnimplementedCniDataplaneServer) Add(context.Context, *AddRequest) (*AddReply, error)
func (UnimplementedCniDataplaneServer) Del ¶
func (UnimplementedCniDataplaneServer) Del(context.Context, *DelRequest) (*DelReply, error)
type UnsafeCniDataplaneServer ¶
type UnsafeCniDataplaneServer interface {
// contains filtered or unexported methods
}
UnsafeCniDataplaneServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CniDataplaneServer will result in compilation errors.
type WorkloadIDs ¶
type WorkloadIDs struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Labels map[string]string `` /* 139-byte string literal not displayed */ Annotations map[string]string `` /* 149-byte string literal not displayed */ Endpoint string `protobuf:"bytes,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Node string `protobuf:"bytes,6,opt,name=node,proto3" json:"node,omitempty"` Orchestrator string `protobuf:"bytes,7,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"` Pod string `protobuf:"bytes,8,opt,name=pod,proto3" json:"pod,omitempty"` Ports []*Port `protobuf:"bytes,9,rep,name=ports,proto3" json:"ports,omitempty"` // contains filtered or unexported fields }
func (*WorkloadIDs) Descriptor
deprecated
func (*WorkloadIDs) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadIDs.ProtoReflect.Descriptor instead.
func (*WorkloadIDs) GetAnnotations ¶
func (x *WorkloadIDs) GetAnnotations() map[string]string
func (*WorkloadIDs) GetEndpoint ¶
func (x *WorkloadIDs) GetEndpoint() string
func (*WorkloadIDs) GetLabels ¶
func (x *WorkloadIDs) GetLabels() map[string]string
func (*WorkloadIDs) GetName ¶
func (x *WorkloadIDs) GetName() string
func (*WorkloadIDs) GetNamespace ¶
func (x *WorkloadIDs) GetNamespace() string
func (*WorkloadIDs) GetNode ¶
func (x *WorkloadIDs) GetNode() string
func (*WorkloadIDs) GetOrchestrator ¶
func (x *WorkloadIDs) GetOrchestrator() string
func (*WorkloadIDs) GetPod ¶
func (x *WorkloadIDs) GetPod() string
func (*WorkloadIDs) GetPorts ¶
func (x *WorkloadIDs) GetPorts() []*Port
func (*WorkloadIDs) ProtoMessage ¶
func (*WorkloadIDs) ProtoMessage()
func (*WorkloadIDs) ProtoReflect ¶
func (x *WorkloadIDs) ProtoReflect() protoreflect.Message
func (*WorkloadIDs) Reset ¶
func (x *WorkloadIDs) Reset()
func (*WorkloadIDs) String ¶
func (x *WorkloadIDs) String() string