rpc

package
v1.6.2-rc1 Latest Latest
Warning

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

 Go to latest Published: May 19, 2020 License: Apache-2.0 Imports: 5 Imported by: 72

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,json=success,proto3" json:"Success,omitempty"`
	IPv4Addr             string   `protobuf:"bytes,2,opt,name=IPv4Addr,json=iPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	IPv4Subnet           string   `protobuf:"bytes,3,opt,name=IPv4Subnet,json=iPv4Subnet,proto3" json:"IPv4Subnet,omitempty"`
	DeviceNumber         int32    `protobuf:"varint,4,opt,name=DeviceNumber,json=deviceNumber,proto3" json:"DeviceNumber,omitempty"`
	UseExternalSNAT      bool     `protobuf:"varint,5,opt,name=UseExternalSNAT,json=useExternalSNAT,proto3" json:"UseExternalSNAT,omitempty"`
	VPCcidrs             []string `protobuf:"bytes,6,rep,name=VPCcidrs,json=vPCcidrs,proto3" json:"VPCcidrs,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) GetIPv4Subnet 

func (m *AddNetworkReply) GetIPv4Subnet() string

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 (dst *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 {
	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 */
	Netns                      string   `protobuf:"bytes,4,opt,name=Netns,json=netns,proto3" json:"Netns,omitempty"`
	IfName                     string   `protobuf:"bytes,5,opt,name=IfName,json=ifName,proto3" json:"IfName,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*AddNetworkRequest) Descriptor 

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

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) 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 (dst *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,json=success,proto3" json:"Success,omitempty"`
	IPv4Addr             string   `protobuf:"bytes,2,opt,name=IPv4Addr,json=iPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	DeviceNumber         int32    `protobuf:"varint,3,opt,name=DeviceNumber,json=deviceNumber,proto3" json:"DeviceNumber,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) 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 (dst *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 {
	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 */
	IPv4Addr                   string   `protobuf:"bytes,4,opt,name=IPv4Addr,json=iPv4Addr,proto3" json:"IPv4Addr,omitempty"`
	Reason                     string   `protobuf:"bytes,5,opt,name=Reason,json=reason,proto3" json:"Reason,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*DelNetworkRequest) Descriptor 

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

func (*DelNetworkRequest) GetIPv4Addr 

func (m *DelNetworkRequest) GetIPv4Addr() 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) 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 (dst *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.