rpc

package
v1.7.8 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2020 License: Apache-2.0 Imports: 5 Imported by: 76

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterCNIBackendServer 

func RegisterCNIBackendServer(s *grpc.Server, srv CNIBackendServer)

Types

type AddNetworkReply 

type AddNetworkReply struct {
	Success         bool     `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	IPv4Addr        string   `protobuf:"bytes,2,opt,name=IPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	DeviceNumber    int32    `protobuf:"varint,4,opt,name=DeviceNumber,proto3" json:"DeviceNumber,omitempty"`
	UseExternalSNAT bool     `protobuf:"varint,5,opt,name=UseExternalSNAT,proto3" json:"UseExternalSNAT,omitempty"`
	VPCcidrs        []string `protobuf:"bytes,6,rep,name=VPCcidrs,proto3" json:"VPCcidrs,omitempty"`
	// start of pod-eni parameters
	PodVlanId            int32    `protobuf:"varint,7,opt,name=PodVlanId,proto3" json:"PodVlanId,omitempty"`
	PodENIMAC            string   `protobuf:"bytes,8,opt,name=PodENIMAC,proto3" json:"PodENIMAC,omitempty"`
	PodENISubnetGW       string   `protobuf:"bytes,9,opt,name=PodENISubnetGW,proto3" json:"PodENISubnetGW,omitempty"`
	ParentIfIndex        int32    `protobuf:"varint,10,opt,name=ParentIfIndex,proto3" json:"ParentIfIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddNetworkReply) Descriptor 

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

func (*AddNetworkReply) GetDeviceNumber 

func (m *AddNetworkReply) GetDeviceNumber() int32

func (*AddNetworkReply) GetIPv4Addr 

func (m *AddNetworkReply) GetIPv4Addr() string

func (*AddNetworkReply) GetParentIfIndex added in v1.6.4 

func (m *AddNetworkReply) GetParentIfIndex() int32

func (*AddNetworkReply) GetPodENIMAC added in v1.6.4 

func (m *AddNetworkReply) GetPodENIMAC() string

func (*AddNetworkReply) GetPodENISubnetGW added in v1.6.4 

func (m *AddNetworkReply) GetPodENISubnetGW() string

func (*AddNetworkReply) GetPodVlanId added in v1.6.4 

func (m *AddNetworkReply) GetPodVlanId() int32

func (*AddNetworkReply) GetSuccess 

func (m *AddNetworkReply) GetSuccess() bool

func (*AddNetworkReply) GetUseExternalSNAT added in v1.3.0 

func (m *AddNetworkReply) GetUseExternalSNAT() bool

func (*AddNetworkReply) GetVPCcidrs added in v1.3.0 

func (m *AddNetworkReply) GetVPCcidrs() []string

func (*AddNetworkReply) ProtoMessage 

func (*AddNetworkReply) ProtoMessage()

func (*AddNetworkReply) Reset 

func (m *AddNetworkReply) Reset()

func (*AddNetworkReply) String 

func (m *AddNetworkReply) String() string

func (*AddNetworkReply) XXX_DiscardUnknown added in v1.6.1 

func (m *AddNetworkReply) XXX_DiscardUnknown()

func (*AddNetworkReply) XXX_Marshal added in v1.6.1 

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

func (*AddNetworkReply) XXX_Merge added in v1.6.1 

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

func (*AddNetworkReply) XXX_Size added in v1.6.1 

func (m *AddNetworkReply) XXX_Size() int

func (*AddNetworkReply) XXX_Unmarshal added in v1.6.1 

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

type AddNetworkRequest 

type AddNetworkRequest struct {
	ClientVersion              string   `protobuf:"bytes,8,opt,name=ClientVersion,proto3" json:"ClientVersion,omitempty"`
	K8S_POD_NAME               string   `protobuf:"bytes,1,opt,name=K8S_POD_NAME,json=K8SPODNAME,proto3" json:"K8S_POD_NAME,omitempty"`
	K8S_POD_NAMESPACE          string   `protobuf:"bytes,2,opt,name=K8S_POD_NAMESPACE,json=K8SPODNAMESPACE,proto3" json:"K8S_POD_NAMESPACE,omitempty"`
	K8S_POD_INFRA_CONTAINER_ID string   `` /* 133-byte string literal not displayed */
	ContainerID                string   `protobuf:"bytes,7,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	IfName                     string   `protobuf:"bytes,5,opt,name=IfName,proto3" json:"IfName,omitempty"`
	NetworkName                string   `protobuf:"bytes,6,opt,name=NetworkName,proto3" json:"NetworkName,omitempty"`
	Netns                      string   `protobuf:"bytes,4,opt,name=Netns,proto3" json:"Netns,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*AddNetworkRequest) Descriptor 

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

func (*AddNetworkRequest) GetClientVersion added in v1.7.0 

func (m *AddNetworkRequest) GetClientVersion() string

func (*AddNetworkRequest) GetContainerID added in v1.6.4 

func (m *AddNetworkRequest) GetContainerID() string

func (*AddNetworkRequest) GetIfName 

func (m *AddNetworkRequest) GetIfName() string

func (*AddNetworkRequest) GetK8S_POD_INFRA_CONTAINER_ID 

func (m *AddNetworkRequest) GetK8S_POD_INFRA_CONTAINER_ID() string

func (*AddNetworkRequest) GetK8S_POD_NAME 

func (m *AddNetworkRequest) GetK8S_POD_NAME() string

func (*AddNetworkRequest) GetK8S_POD_NAMESPACE 

func (m *AddNetworkRequest) GetK8S_POD_NAMESPACE() string

func (*AddNetworkRequest) GetNetns 

func (m *AddNetworkRequest) GetNetns() string

func (*AddNetworkRequest) GetNetworkName added in v1.6.4 

func (m *AddNetworkRequest) GetNetworkName() string

func (*AddNetworkRequest) ProtoMessage 

func (*AddNetworkRequest) ProtoMessage()

func (*AddNetworkRequest) Reset 

func (m *AddNetworkRequest) Reset()

func (*AddNetworkRequest) String 

func (m *AddNetworkRequest) String() string

func (*AddNetworkRequest) XXX_DiscardUnknown added in v1.6.1 

func (m *AddNetworkRequest) XXX_DiscardUnknown()

func (*AddNetworkRequest) XXX_Marshal added in v1.6.1 

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

func (*AddNetworkRequest) XXX_Merge added in v1.6.1 

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

func (*AddNetworkRequest) XXX_Size added in v1.6.1 

func (m *AddNetworkRequest) XXX_Size() int

func (*AddNetworkRequest) XXX_Unmarshal added in v1.6.1 

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

type CNIBackendClient 

type CNIBackendClient interface {
	AddNetwork(ctx context.Context, in *AddNetworkRequest, opts ...grpc.CallOption) (*AddNetworkReply, error)
	DelNetwork(ctx context.Context, in *DelNetworkRequest, opts ...grpc.CallOption) (*DelNetworkReply, error)
}

CNIBackendClient is the client API for CNIBackend service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCNIBackendClient 

func NewCNIBackendClient(cc *grpc.ClientConn) CNIBackendClient

type CNIBackendServer 

type CNIBackendServer interface {
	AddNetwork(context.Context, *AddNetworkRequest) (*AddNetworkReply, error)
	DelNetwork(context.Context, *DelNetworkRequest) (*DelNetworkReply, error)
}

CNIBackendServer is the server API for CNIBackend service.

type DelNetworkReply 

type DelNetworkReply struct {
	Success      bool   `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	IPv4Addr     string `protobuf:"bytes,2,opt,name=IPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	DeviceNumber int32  `protobuf:"varint,3,opt,name=DeviceNumber,proto3" json:"DeviceNumber,omitempty"`
	// start of pod-eni parameters
	PodVlanId            int32    `protobuf:"varint,4,opt,name=PodVlanId,proto3" json:"PodVlanId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelNetworkReply) Descriptor 

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

func (*DelNetworkReply) GetDeviceNumber 

func (m *DelNetworkReply) GetDeviceNumber() int32

func (*DelNetworkReply) GetIPv4Addr 

func (m *DelNetworkReply) GetIPv4Addr() string

func (*DelNetworkReply) GetPodVlanId added in v1.6.4 

func (m *DelNetworkReply) GetPodVlanId() int32

func (*DelNetworkReply) GetSuccess 

func (m *DelNetworkReply) GetSuccess() bool

func (*DelNetworkReply) ProtoMessage 

func (*DelNetworkReply) ProtoMessage()

func (*DelNetworkReply) Reset 

func (m *DelNetworkReply) Reset()

func (*DelNetworkReply) String 

func (m *DelNetworkReply) String() string

func (*DelNetworkReply) XXX_DiscardUnknown added in v1.6.1 

func (m *DelNetworkReply) XXX_DiscardUnknown()

func (*DelNetworkReply) XXX_Marshal added in v1.6.1 

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

func (*DelNetworkReply) XXX_Merge added in v1.6.1 

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

func (*DelNetworkReply) XXX_Size added in v1.6.1 

func (m *DelNetworkReply) XXX_Size() int

func (*DelNetworkReply) XXX_Unmarshal added in v1.6.1 

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

type DelNetworkRequest 

type DelNetworkRequest struct {
	ClientVersion              string   `protobuf:"bytes,9,opt,name=ClientVersion,proto3" json:"ClientVersion,omitempty"`
	K8S_POD_NAME               string   `protobuf:"bytes,1,opt,name=K8S_POD_NAME,json=K8SPODNAME,proto3" json:"K8S_POD_NAME,omitempty"`
	K8S_POD_NAMESPACE          string   `protobuf:"bytes,2,opt,name=K8S_POD_NAMESPACE,json=K8SPODNAMESPACE,proto3" json:"K8S_POD_NAMESPACE,omitempty"`
	K8S_POD_INFRA_CONTAINER_ID string   `` /* 133-byte string literal not displayed */
	Reason                     string   `protobuf:"bytes,5,opt,name=Reason,proto3" json:"Reason,omitempty"`
	ContainerID                string   `protobuf:"bytes,8,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	IfName                     string   `protobuf:"bytes,6,opt,name=IfName,proto3" json:"IfName,omitempty"`
	NetworkName                string   `protobuf:"bytes,7,opt,name=NetworkName,proto3" json:"NetworkName,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*DelNetworkRequest) Descriptor 

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

func (*DelNetworkRequest) GetClientVersion added in v1.7.0 

func (m *DelNetworkRequest) GetClientVersion() string

func (*DelNetworkRequest) GetContainerID added in v1.6.4 

func (m *DelNetworkRequest) GetContainerID() string

func (*DelNetworkRequest) GetIfName added in v1.6.4 

func (m *DelNetworkRequest) GetIfName() string

func (*DelNetworkRequest) GetK8S_POD_INFRA_CONTAINER_ID 

func (m *DelNetworkRequest) GetK8S_POD_INFRA_CONTAINER_ID() string

func (*DelNetworkRequest) GetK8S_POD_NAME 

func (m *DelNetworkRequest) GetK8S_POD_NAME() string

func (*DelNetworkRequest) GetK8S_POD_NAMESPACE 

func (m *DelNetworkRequest) GetK8S_POD_NAMESPACE() string

func (*DelNetworkRequest) GetNetworkName added in v1.6.4 

func (m *DelNetworkRequest) GetNetworkName() string

func (*DelNetworkRequest) GetReason added in v1.1.0 

func (m *DelNetworkRequest) GetReason() string

func (*DelNetworkRequest) ProtoMessage 

func (*DelNetworkRequest) ProtoMessage()

func (*DelNetworkRequest) Reset 

func (m *DelNetworkRequest) Reset()

func (*DelNetworkRequest) String 

func (m *DelNetworkRequest) String() string

func (*DelNetworkRequest) XXX_DiscardUnknown added in v1.6.1 

func (m *DelNetworkRequest) XXX_DiscardUnknown()

func (*DelNetworkRequest) XXX_Marshal added in v1.6.1 

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

func (*DelNetworkRequest) XXX_Merge added in v1.6.1 

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

func (*DelNetworkRequest) XXX_Size added in v1.6.1 

func (m *DelNetworkRequest) XXX_Size() int

func (*DelNetworkRequest) XXX_Unmarshal added in v1.6.1 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock_rpc is a generated GoMock package.
 Package mock_rpc is a generated GoMock package.

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.