computeagent

package
v0.9.8 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthComputeagent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowComputeagent   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterComputeAgentService 

func RegisterComputeAgentService(srv *github_com_containerd_ttrpc.Server, svc ComputeAgentService)

Types

type AddNICInternalRequest 

type AddNICInternalRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	NicID                string   `protobuf:"bytes,2,opt,name=nic_id,json=nicId,proto3" json:"nic_id,omitempty"`
	EndpointName         string   `protobuf:"bytes,3,opt,name=endpoint_name,json=endpointName,proto3" json:"endpoint_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddNICInternalRequest) Descriptor 

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

func (*AddNICInternalRequest) Marshal 

func (m *AddNICInternalRequest) Marshal() (dAtA []byte, err error)

func (*AddNICInternalRequest) MarshalTo 

func (m *AddNICInternalRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddNICInternalRequest) ProtoMessage 

func (*AddNICInternalRequest) ProtoMessage()

func (*AddNICInternalRequest) Reset 

func (m *AddNICInternalRequest) Reset()

func (*AddNICInternalRequest) Size 

func (m *AddNICInternalRequest) Size() (n int)

func (*AddNICInternalRequest) String 

func (this *AddNICInternalRequest) String() string

func (*AddNICInternalRequest) Unmarshal 

func (m *AddNICInternalRequest) Unmarshal(dAtA []byte) error

func (*AddNICInternalRequest) XXX_DiscardUnknown 

func (m *AddNICInternalRequest) XXX_DiscardUnknown()

func (*AddNICInternalRequest) XXX_Marshal 

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

func (*AddNICInternalRequest) XXX_Merge 

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

func (*AddNICInternalRequest) XXX_Size 

func (m *AddNICInternalRequest) XXX_Size() int

func (*AddNICInternalRequest) XXX_Unmarshal 

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

type AddNICInternalResponse 

type AddNICInternalResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddNICInternalResponse) Descriptor 

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

func (*AddNICInternalResponse) Marshal 

func (m *AddNICInternalResponse) Marshal() (dAtA []byte, err error)

func (*AddNICInternalResponse) MarshalTo 

func (m *AddNICInternalResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddNICInternalResponse) ProtoMessage 

func (*AddNICInternalResponse) ProtoMessage()

func (*AddNICInternalResponse) Reset 

func (m *AddNICInternalResponse) Reset()

func (*AddNICInternalResponse) Size 

func (m *AddNICInternalResponse) Size() (n int)

func (*AddNICInternalResponse) String 

func (this *AddNICInternalResponse) String() string

func (*AddNICInternalResponse) Unmarshal 

func (m *AddNICInternalResponse) Unmarshal(dAtA []byte) error

func (*AddNICInternalResponse) XXX_DiscardUnknown 

func (m *AddNICInternalResponse) XXX_DiscardUnknown()

func (*AddNICInternalResponse) XXX_Marshal 

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

func (*AddNICInternalResponse) XXX_Merge 

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

func (*AddNICInternalResponse) XXX_Size 

func (m *AddNICInternalResponse) XXX_Size() int

func (*AddNICInternalResponse) XXX_Unmarshal 

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

type ComputeAgentService 

type ComputeAgentService interface {
	AddNIC(ctx context.Context, req *AddNICInternalRequest) (*AddNICInternalResponse, error)
	ModifyNIC(ctx context.Context, req *ModifyNICInternalRequest) (*ModifyNICInternalResponse, error)
	DeleteNIC(ctx context.Context, req *DeleteNICInternalRequest) (*DeleteNICInternalResponse, error)
}

func NewComputeAgentClient 

func NewComputeAgentClient(client *github_com_containerd_ttrpc.Client) ComputeAgentService

type DeleteNICInternalRequest 

type DeleteNICInternalRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	NicID                string   `protobuf:"bytes,2,opt,name=nic_id,json=nicId,proto3" json:"nic_id,omitempty"`
	EndpointName         string   `protobuf:"bytes,3,opt,name=endpoint_name,json=endpointName,proto3" json:"endpoint_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteNICInternalRequest) Descriptor 

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

func (*DeleteNICInternalRequest) Marshal 

func (m *DeleteNICInternalRequest) Marshal() (dAtA []byte, err error)

func (*DeleteNICInternalRequest) MarshalTo 

func (m *DeleteNICInternalRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteNICInternalRequest) ProtoMessage 

func (*DeleteNICInternalRequest) ProtoMessage()

func (*DeleteNICInternalRequest) Reset 

func (m *DeleteNICInternalRequest) Reset()

func (*DeleteNICInternalRequest) Size 

func (m *DeleteNICInternalRequest) Size() (n int)

func (*DeleteNICInternalRequest) String 

func (this *DeleteNICInternalRequest) String() string

func (*DeleteNICInternalRequest) Unmarshal 

func (m *DeleteNICInternalRequest) Unmarshal(dAtA []byte) error

func (*DeleteNICInternalRequest) XXX_DiscardUnknown 

func (m *DeleteNICInternalRequest) XXX_DiscardUnknown()

func (*DeleteNICInternalRequest) XXX_Marshal 

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

func (*DeleteNICInternalRequest) XXX_Merge 

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

func (*DeleteNICInternalRequest) XXX_Size 

func (m *DeleteNICInternalRequest) XXX_Size() int

func (*DeleteNICInternalRequest) XXX_Unmarshal 

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

type DeleteNICInternalResponse 

type DeleteNICInternalResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteNICInternalResponse) Descriptor 

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

func (*DeleteNICInternalResponse) Marshal 

func (m *DeleteNICInternalResponse) Marshal() (dAtA []byte, err error)

func (*DeleteNICInternalResponse) MarshalTo 

func (m *DeleteNICInternalResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteNICInternalResponse) ProtoMessage 

func (*DeleteNICInternalResponse) ProtoMessage()

func (*DeleteNICInternalResponse) Reset 

func (m *DeleteNICInternalResponse) Reset()

func (*DeleteNICInternalResponse) Size 

func (m *DeleteNICInternalResponse) Size() (n int)

func (*DeleteNICInternalResponse) String 

func (this *DeleteNICInternalResponse) String() string

func (*DeleteNICInternalResponse) Unmarshal 

func (m *DeleteNICInternalResponse) Unmarshal(dAtA []byte) error

func (*DeleteNICInternalResponse) XXX_DiscardUnknown 

func (m *DeleteNICInternalResponse) XXX_DiscardUnknown()

func (*DeleteNICInternalResponse) XXX_Marshal 

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

func (*DeleteNICInternalResponse) XXX_Merge 

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

func (*DeleteNICInternalResponse) XXX_Size 

func (m *DeleteNICInternalResponse) XXX_Size() int

func (*DeleteNICInternalResponse) XXX_Unmarshal 

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

type IovSettings 

type IovSettings struct {
	IovOffloadWeight     uint32   `protobuf:"varint,1,opt,name=IovOffloadWeight,proto3" json:"IovOffloadWeight,omitempty"`
	QueuePairsRequested  uint32   `protobuf:"varint,2,opt,name=QueuePairsRequested,proto3" json:"QueuePairsRequested,omitempty"`
	InterruptModeration  uint32   `protobuf:"varint,3,opt,name=InterruptModeration,proto3" json:"InterruptModeration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IovSettings) Descriptor 

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

func (*IovSettings) Marshal 

func (m *IovSettings) Marshal() (dAtA []byte, err error)

func (*IovSettings) MarshalTo 

func (m *IovSettings) MarshalTo(dAtA []byte) (int, error)

func (*IovSettings) ProtoMessage 

func (*IovSettings) ProtoMessage()

func (*IovSettings) Reset 

func (m *IovSettings) Reset()

func (*IovSettings) Size 

func (m *IovSettings) Size() (n int)

func (*IovSettings) String 

func (this *IovSettings) String() string

func (*IovSettings) Unmarshal 

func (m *IovSettings) Unmarshal(dAtA []byte) error

func (*IovSettings) XXX_DiscardUnknown 

func (m *IovSettings) XXX_DiscardUnknown()

func (*IovSettings) XXX_Marshal 

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

func (*IovSettings) XXX_Merge 

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

func (*IovSettings) XXX_Size 

func (m *IovSettings) XXX_Size() int

func (*IovSettings) XXX_Unmarshal 

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

type ModifyNICInternalRequest 

type ModifyNICInternalRequest struct {
	NicID                string       `protobuf:"bytes,1,opt,name=nic_id,json=nicId,proto3" json:"nic_id,omitempty"`
	EndpointName         string       `protobuf:"bytes,2,opt,name=endpoint_name,json=endpointName,proto3" json:"endpoint_name,omitempty"`
	IovPolicySettings    *IovSettings `protobuf:"bytes,3,opt,name=iov_policy_settings,json=iovPolicySettings,proto3" json:"iov_policy_settings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ModifyNICInternalRequest) Descriptor 

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

func (*ModifyNICInternalRequest) Marshal 

func (m *ModifyNICInternalRequest) Marshal() (dAtA []byte, err error)

func (*ModifyNICInternalRequest) MarshalTo 

func (m *ModifyNICInternalRequest) MarshalTo(dAtA []byte) (int, error)

func (*ModifyNICInternalRequest) ProtoMessage 

func (*ModifyNICInternalRequest) ProtoMessage()

func (*ModifyNICInternalRequest) Reset 

func (m *ModifyNICInternalRequest) Reset()

func (*ModifyNICInternalRequest) Size 

func (m *ModifyNICInternalRequest) Size() (n int)

func (*ModifyNICInternalRequest) String 

func (this *ModifyNICInternalRequest) String() string

func (*ModifyNICInternalRequest) Unmarshal 

func (m *ModifyNICInternalRequest) Unmarshal(dAtA []byte) error

func (*ModifyNICInternalRequest) XXX_DiscardUnknown 

func (m *ModifyNICInternalRequest) XXX_DiscardUnknown()

func (*ModifyNICInternalRequest) XXX_Marshal 

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

func (*ModifyNICInternalRequest) XXX_Merge 

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

func (*ModifyNICInternalRequest) XXX_Size 

func (m *ModifyNICInternalRequest) XXX_Size() int

func (*ModifyNICInternalRequest) XXX_Unmarshal 

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

type ModifyNICInternalResponse 

type ModifyNICInternalResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ModifyNICInternalResponse) Descriptor 

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

func (*ModifyNICInternalResponse) Marshal 

func (m *ModifyNICInternalResponse) Marshal() (dAtA []byte, err error)

func (*ModifyNICInternalResponse) MarshalTo 

func (m *ModifyNICInternalResponse) MarshalTo(dAtA []byte) (int, error)

func (*ModifyNICInternalResponse) ProtoMessage 

func (*ModifyNICInternalResponse) ProtoMessage()

func (*ModifyNICInternalResponse) Reset 

func (m *ModifyNICInternalResponse) Reset()

func (*ModifyNICInternalResponse) Size 

func (m *ModifyNICInternalResponse) Size() (n int)

func (*ModifyNICInternalResponse) String 

func (this *ModifyNICInternalResponse) String() string

func (*ModifyNICInternalResponse) Unmarshal 

func (m *ModifyNICInternalResponse) Unmarshal(dAtA []byte) error

func (*ModifyNICInternalResponse) XXX_DiscardUnknown 

func (m *ModifyNICInternalResponse) XXX_DiscardUnknown()

func (*ModifyNICInternalResponse) XXX_Marshal 

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

func (*ModifyNICInternalResponse) XXX_Merge 

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

func (*ModifyNICInternalResponse) XXX_Size 

func (m *ModifyNICInternalResponse) XXX_Size() int

func (*ModifyNICInternalResponse) XXX_Unmarshal 

func (m *ModifyNICInternalResponse) 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.