protos

package
v10.322.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CNIContainerEventRequest_Type_name = map[int32]string{
		0: "ADD",
		1: "DELETE",
	}
	CNIContainerEventRequest_Type_value = map[string]int32{
		"ADD":    0,
		"DELETE": 1,
	}
)

Enum value maps for CNIContainerEventRequest_Type.

View Source 
var File_monitor_proto protoreflect.FileDescriptor

Functions

func RegisterCNIServer 

func RegisterCNIServer(s *grpc.Server, srv CNIServer)

func RegisterRunCServer 

func RegisterRunCServer(s *grpc.Server, srv RunCServer)

Types

type CNIClient 

type CNIClient interface {
	// ContainerEvent will be invoked by the CNI plugin on the following events at this point:
	// - ‘cmdADD start’
	// - 'cmdDEL delete'
	CNIContainerEvent(ctx context.Context, in *CNIContainerEventRequest, opts ...grpc.CallOption) (*ContainerEventResponse, error)
}

CNIClient is the client API for CNI service.

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

func NewCNIClient 

func NewCNIClient(cc grpc.ClientConnInterface) CNIClient

type CNIContainerEventRequest 

type CNIContainerEventRequest struct {
	Type         CNIContainerEventRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=protos.CNIContainerEventRequest_Type" json:"type,omitempty"`
	ContainerID  string                        `protobuf:"bytes,2,opt,name=containerID,proto3" json:"containerID,omitempty"`
	NetnsPath    string                        `protobuf:"bytes,3,opt,name=netnsPath,proto3" json:"netnsPath,omitempty"`
	PodName      string                        `protobuf:"bytes,4,opt,name=podName,proto3" json:"podName,omitempty"`
	PodNamespace string                        `protobuf:"bytes,5,opt,name=podNamespace,proto3" json:"podNamespace,omitempty"`
	// contains filtered or unexported fields
}

func (*CNIContainerEventRequest) Descriptor deprecated 

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

Deprecated: Use CNIContainerEventRequest.ProtoReflect.Descriptor instead.

func (*CNIContainerEventRequest) GetContainerID 

func (x *CNIContainerEventRequest) GetContainerID() string

func (*CNIContainerEventRequest) GetNetnsPath 

func (x *CNIContainerEventRequest) GetNetnsPath() string

func (*CNIContainerEventRequest) GetPodName 

func (x *CNIContainerEventRequest) GetPodName() string

func (*CNIContainerEventRequest) GetPodNamespace 

func (x *CNIContainerEventRequest) GetPodNamespace() string

func (*CNIContainerEventRequest) GetType 

func (x *CNIContainerEventRequest) GetType() CNIContainerEventRequest_Type

func (*CNIContainerEventRequest) ProtoMessage 

func (*CNIContainerEventRequest) ProtoMessage()

func (*CNIContainerEventRequest) ProtoReflect 

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

func (*CNIContainerEventRequest) Reset 

func (x *CNIContainerEventRequest) Reset()

func (*CNIContainerEventRequest) String 

func (x *CNIContainerEventRequest) String() string

type CNIContainerEventRequest_Type 

type CNIContainerEventRequest_Type int32
const (
	CNIContainerEventRequest_ADD    CNIContainerEventRequest_Type = 0
	CNIContainerEventRequest_DELETE CNIContainerEventRequest_Type = 1
)

func (CNIContainerEventRequest_Type) Descriptor 

func (CNIContainerEventRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (CNIContainerEventRequest_Type) Enum 

func (x CNIContainerEventRequest_Type) Enum() *CNIContainerEventRequest_Type

func (CNIContainerEventRequest_Type) EnumDescriptor deprecated 

func (CNIContainerEventRequest_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use CNIContainerEventRequest_Type.Descriptor instead.

func (CNIContainerEventRequest_Type) Number 

func (x CNIContainerEventRequest_Type) Number() protoreflect.EnumNumber

func (CNIContainerEventRequest_Type) String 

func (x CNIContainerEventRequest_Type) String() string

func (CNIContainerEventRequest_Type) Type 

func (CNIContainerEventRequest_Type) Type() protoreflect.EnumType

type CNIServer 

type CNIServer interface {
	// ContainerEvent will be invoked by the CNI plugin on the following events at this point:
	// - ‘cmdADD start’
	// - 'cmdDEL delete'
	CNIContainerEvent(context.Context, *CNIContainerEventRequest) (*ContainerEventResponse, error)
}

CNIServer is the server API for CNI service.

type ContainerEventResponse 

type ContainerEventResponse struct {
	ErrorMessage string `protobuf:"bytes,1,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` // errorMessage will be empty on success, and have an error message set only on an error
	// contains filtered or unexported fields
}

func (*ContainerEventResponse) Descriptor deprecated 

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

Deprecated: Use ContainerEventResponse.ProtoReflect.Descriptor instead.

func (*ContainerEventResponse) GetErrorMessage 

func (x *ContainerEventResponse) GetErrorMessage() string

func (*ContainerEventResponse) ProtoMessage 

func (*ContainerEventResponse) ProtoMessage()

func (*ContainerEventResponse) ProtoReflect 

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

func (*ContainerEventResponse) Reset 

func (x *ContainerEventResponse) Reset()

func (*ContainerEventResponse) String 

func (x *ContainerEventResponse) String() string

type RunCClient 

type RunCClient interface {
	// RuncProxyStarted is called by the PCC agent once the runc proxy has been started
	RuncProxyStarted(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// ContainerEvent will be invoked by the runc proxy on the following events at this point:
	// - ‘runc start’
	// - 'runc delete'
	RunCContainerEvent(ctx context.Context, in *RunCContainerEventRequest, opts ...grpc.CallOption) (*ContainerEventResponse, error)
}

RunCClient is the client API for RunC service.

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

func NewRunCClient 

func NewRunCClient(cc grpc.ClientConnInterface) RunCClient

type RunCContainerEventRequest 

type RunCContainerEventRequest struct {
	CommandLine []string `protobuf:"bytes,1,rep,name=commandLine,proto3" json:"commandLine,omitempty"` // the full commandline of the runc command incl. flags, etc. - this is expected to come from `os.Args`
	// contains filtered or unexported fields
}

func (*RunCContainerEventRequest) Descriptor deprecated 

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

Deprecated: Use RunCContainerEventRequest.ProtoReflect.Descriptor instead.

func (*RunCContainerEventRequest) GetCommandLine 

func (x *RunCContainerEventRequest) GetCommandLine() []string

func (*RunCContainerEventRequest) ProtoMessage 

func (*RunCContainerEventRequest) ProtoMessage()

func (*RunCContainerEventRequest) ProtoReflect 

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

func (*RunCContainerEventRequest) Reset 

func (x *RunCContainerEventRequest) Reset()

func (*RunCContainerEventRequest) String 

func (x *RunCContainerEventRequest) String() string

type RunCServer 

type RunCServer interface {
	// RuncProxyStarted is called by the PCC agent once the runc proxy has been started
	RuncProxyStarted(context.Context, *empty.Empty) (*empty.Empty, error)
	// ContainerEvent will be invoked by the runc proxy on the following events at this point:
	// - ‘runc start’
	// - 'runc delete'
	RunCContainerEvent(context.Context, *RunCContainerEventRequest) (*ContainerEventResponse, error)
}

RunCServer is the server API for RunC service.

type UnimplementedCNIServer 

type UnimplementedCNIServer struct {
}

UnimplementedCNIServer can be embedded to have forward compatible implementations.

func (*UnimplementedCNIServer) CNIContainerEvent 

func (*UnimplementedCNIServer) CNIContainerEvent(context.Context, *CNIContainerEventRequest) (*ContainerEventResponse, error)

type UnimplementedRunCServer 

type UnimplementedRunCServer struct {
}

UnimplementedRunCServer can be embedded to have forward compatible implementations.

func (*UnimplementedRunCServer) RunCContainerEvent 

func (*UnimplementedRunCServer) RunCContainerEvent(context.Context, *RunCContainerEventRequest) (*ContainerEventResponse, error)

func (*UnimplementedRunCServer) RuncProxyStarted 

func (*UnimplementedRunCServer) RuncProxyStarted(context.Context, *empty.Empty) (*empty.Empty, 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.