proto

package
v1.11.0-cni-plu...-afc7ce6 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2024 License: Apache-2.0, Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCniDataplaneServer 

func RegisterCniDataplaneServer(s *grpc.Server, 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddReply) Descriptor 

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

func (*AddReply) GetContainerMac 

func (m *AddReply) GetContainerMac() string

func (*AddReply) GetErrorMessage 

func (m *AddReply) GetErrorMessage() string

func (*AddReply) GetHostInterfaceName 

func (m *AddReply) GetHostInterfaceName() string

func (*AddReply) GetSuccessful 

func (m *AddReply) GetSuccessful() bool

func (*AddReply) ProtoMessage 

func (*AddReply) ProtoMessage()

func (*AddReply) Reset 

func (m *AddReply) Reset()

func (*AddReply) String 

func (m *AddReply) String() string

func (*AddReply) XXX_DiscardUnknown 

func (m *AddReply) XXX_DiscardUnknown()

func (*AddReply) XXX_Marshal 

func (m *AddReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddReply) XXX_Merge 

func (m *AddReply) XXX_Merge(src proto.Message)

func (*AddReply) XXX_Size 

func (m *AddReply) XXX_Size() int

func (*AddReply) XXX_Unmarshal 

func (m *AddReply) XXX_Unmarshal(b []byte) error

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  `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{}           `json:"-"`
	XXX_unrecognized         []byte             `json:"-"`
	XXX_sizecache            int32              `json:"-"`
}

func (*AddRequest) Descriptor 

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

func (*AddRequest) GetContainerIps 

func (m *AddRequest) GetContainerIps() []*IPConfig

func (*AddRequest) GetContainerRoutes 

func (m *AddRequest) GetContainerRoutes() []string

func (*AddRequest) GetDataplaneOptions 

func (m *AddRequest) GetDataplaneOptions() map[string]string

func (*AddRequest) GetDesiredHostInterfaceName 

func (m *AddRequest) GetDesiredHostInterfaceName() string

func (*AddRequest) GetInterfaceName 

func (m *AddRequest) GetInterfaceName() string

func (*AddRequest) GetNetns 

func (m *AddRequest) GetNetns() string

func (*AddRequest) GetSettings 

func (m *AddRequest) GetSettings() *ContainerSettings

func (*AddRequest) GetWorkload 

func (m *AddRequest) GetWorkload() *WorkloadIDs

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) String 

func (m *AddRequest) String() string

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddRequest) XXX_Merge 

func (m *AddRequest) XXX_Merge(src proto.Message)

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

func (m *AddRequest) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCniDataplaneClient 

func NewCniDataplaneClient(cc *grpc.ClientConn) CniDataplaneClient

type CniDataplaneServer 

type CniDataplaneServer interface {
	Add(context.Context, *AddRequest) (*AddReply, error)
	Del(context.Context, *DelRequest) (*DelReply, error)
}

CniDataplaneServer is the server API for CniDataplane service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerSettings) Descriptor 

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

func (*ContainerSettings) GetAllowIpForwarding 

func (m *ContainerSettings) GetAllowIpForwarding() bool

func (*ContainerSettings) GetMtu 

func (m *ContainerSettings) GetMtu() int32

func (*ContainerSettings) ProtoMessage 

func (*ContainerSettings) ProtoMessage()

func (*ContainerSettings) Reset 

func (m *ContainerSettings) Reset()

func (*ContainerSettings) String 

func (m *ContainerSettings) String() string

func (*ContainerSettings) XXX_DiscardUnknown 

func (m *ContainerSettings) XXX_DiscardUnknown()

func (*ContainerSettings) XXX_Marshal 

func (m *ContainerSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerSettings) XXX_Merge 

func (m *ContainerSettings) XXX_Merge(src proto.Message)

func (*ContainerSettings) XXX_Size 

func (m *ContainerSettings) XXX_Size() int

func (*ContainerSettings) XXX_Unmarshal 

func (m *ContainerSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelReply) Descriptor 

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

func (*DelReply) GetErrorMessage 

func (m *DelReply) GetErrorMessage() string

func (*DelReply) GetSuccessful 

func (m *DelReply) GetSuccessful() bool

func (*DelReply) ProtoMessage 

func (*DelReply) ProtoMessage()

func (*DelReply) Reset 

func (m *DelReply) Reset()

func (*DelReply) String 

func (m *DelReply) String() string

func (*DelReply) XXX_DiscardUnknown 

func (m *DelReply) XXX_DiscardUnknown()

func (*DelReply) XXX_Marshal 

func (m *DelReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelReply) XXX_Merge 

func (m *DelReply) XXX_Merge(src proto.Message)

func (*DelReply) XXX_Size 

func (m *DelReply) XXX_Size() int

func (*DelReply) XXX_Unmarshal 

func (m *DelReply) XXX_Unmarshal(b []byte) error

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 `` /* 197-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DelRequest) Descriptor 

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

func (*DelRequest) GetDataplaneOptions 

func (m *DelRequest) GetDataplaneOptions() map[string]string

func (*DelRequest) GetInterfaceName 

func (m *DelRequest) GetInterfaceName() string

func (*DelRequest) GetNetns 

func (m *DelRequest) GetNetns() string

func (*DelRequest) ProtoMessage 

func (*DelRequest) ProtoMessage()

func (*DelRequest) Reset 

func (m *DelRequest) Reset()

func (*DelRequest) String 

func (m *DelRequest) String() string

func (*DelRequest) XXX_DiscardUnknown 

func (m *DelRequest) XXX_DiscardUnknown()

func (*DelRequest) XXX_Marshal 

func (m *DelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelRequest) XXX_Merge 

func (m *DelRequest) XXX_Merge(src proto.Message)

func (*DelRequest) XXX_Size 

func (m *DelRequest) XXX_Size() int

func (*DelRequest) XXX_Unmarshal 

func (m *DelRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IPConfig) Descriptor 

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

func (*IPConfig) GetAddress 

func (m *IPConfig) GetAddress() string

func (*IPConfig) GetGateway 

func (m *IPConfig) GetGateway() string

func (*IPConfig) ProtoMessage 

func (*IPConfig) ProtoMessage()

func (*IPConfig) Reset 

func (m *IPConfig) Reset()

func (*IPConfig) String 

func (m *IPConfig) String() string

func (*IPConfig) XXX_DiscardUnknown 

func (m *IPConfig) XXX_DiscardUnknown()

func (*IPConfig) XXX_Marshal 

func (m *IPConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IPConfig) XXX_Merge 

func (m *IPConfig) XXX_Merge(src proto.Message)

func (*IPConfig) XXX_Size 

func (m *IPConfig) XXX_Size() int

func (*IPConfig) XXX_Unmarshal 

func (m *IPConfig) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Port) Descriptor 

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

func (*Port) GetHostIp 

func (m *Port) GetHostIp() string

func (*Port) GetHostPort 

func (m *Port) GetHostPort() uint32

func (*Port) GetName 

func (m *Port) GetName() string

func (*Port) GetPort 

func (m *Port) GetPort() uint32

func (*Port) GetProtocol 

func (m *Port) GetProtocol() string

func (*Port) ProtoMessage 

func (*Port) ProtoMessage()

func (*Port) Reset 

func (m *Port) Reset()

func (*Port) String 

func (m *Port) String() string

func (*Port) XXX_DiscardUnknown 

func (m *Port) XXX_DiscardUnknown()

func (*Port) XXX_Marshal 

func (m *Port) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Port) XXX_Merge 

func (m *Port) XXX_Merge(src proto.Message)

func (*Port) XXX_Size 

func (m *Port) XXX_Size() int

func (*Port) XXX_Unmarshal 

func (m *Port) XXX_Unmarshal(b []byte) error

type UnimplementedCniDataplaneServer 

type UnimplementedCniDataplaneServer struct {
}

UnimplementedCniDataplaneServer can be embedded to have forward compatible implementations.

func (*UnimplementedCniDataplaneServer) Add 

func (*UnimplementedCniDataplaneServer) Add(ctx context.Context, req *AddRequest) (*AddReply, error)

func (*UnimplementedCniDataplaneServer) Del 

func (*UnimplementedCniDataplaneServer) Del(ctx context.Context, req *DelRequest) (*DelReply, error)

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 `` /* 153-byte string literal not displayed */
	Annotations          map[string]string `` /* 163-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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkloadIDs) Descriptor 

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

func (*WorkloadIDs) GetAnnotations 

func (m *WorkloadIDs) GetAnnotations() map[string]string

func (*WorkloadIDs) GetEndpoint 

func (m *WorkloadIDs) GetEndpoint() string

func (*WorkloadIDs) GetLabels 

func (m *WorkloadIDs) GetLabels() map[string]string

func (*WorkloadIDs) GetName 

func (m *WorkloadIDs) GetName() string

func (*WorkloadIDs) GetNamespace 

func (m *WorkloadIDs) GetNamespace() string

func (*WorkloadIDs) GetNode 

func (m *WorkloadIDs) GetNode() string

func (*WorkloadIDs) GetOrchestrator 

func (m *WorkloadIDs) GetOrchestrator() string

func (*WorkloadIDs) GetPod 

func (m *WorkloadIDs) GetPod() string

func (*WorkloadIDs) GetPorts 

func (m *WorkloadIDs) GetPorts() []*Port

func (*WorkloadIDs) ProtoMessage 

func (*WorkloadIDs) ProtoMessage()

func (*WorkloadIDs) Reset 

func (m *WorkloadIDs) Reset()

func (*WorkloadIDs) String 

func (m *WorkloadIDs) String() string

func (*WorkloadIDs) XXX_DiscardUnknown 

func (m *WorkloadIDs) XXX_DiscardUnknown()

func (*WorkloadIDs) XXX_Marshal 

func (m *WorkloadIDs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkloadIDs) XXX_Merge 

func (m *WorkloadIDs) XXX_Merge(src proto.Message)

func (*WorkloadIDs) XXX_Size 

func (m *WorkloadIDs) XXX_Size() int

func (*WorkloadIDs) XXX_Unmarshal 

func (m *WorkloadIDs) XXX_Unmarshal(b []byte) error

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.