ncproxyttrpc

package
v0.9.9 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 (
	ErrInvalidLengthNetworkconfigproxy = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNetworkconfigproxy   = fmt.Errorf("proto: integer overflow")
)
View Source 
var RequestTypeInternal_name = map[int32]string{
	0: "Setup",
	1: "Teardown",
}
View Source 
var RequestTypeInternal_value = map[string]int32{
	"Setup":    0,
	"Teardown": 1,
}

Functions

func RegisterNetworkConfigProxyService 

func RegisterNetworkConfigProxyService(srv *github_com_containerd_ttrpc.Server, svc NetworkConfigProxyService)

Types

type ConfigureNetworkingInternalRequest 

type ConfigureNetworkingInternalRequest struct {
	ContainerID          string              `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	RequestType          RequestTypeInternal `protobuf:"varint,2,opt,name=request_type,json=requestType,proto3,enum=RequestTypeInternal" json:"request_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ConfigureNetworkingInternalRequest) Descriptor 

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

func (*ConfigureNetworkingInternalRequest) Marshal 

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

func (*ConfigureNetworkingInternalRequest) MarshalTo 

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

func (*ConfigureNetworkingInternalRequest) ProtoMessage 

func (*ConfigureNetworkingInternalRequest) ProtoMessage()

func (*ConfigureNetworkingInternalRequest) Reset 

func (m *ConfigureNetworkingInternalRequest) Reset()

func (*ConfigureNetworkingInternalRequest) Size 

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

func (*ConfigureNetworkingInternalRequest) String 

func (this *ConfigureNetworkingInternalRequest) String() string

func (*ConfigureNetworkingInternalRequest) Unmarshal 

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

func (*ConfigureNetworkingInternalRequest) XXX_DiscardUnknown 

func (m *ConfigureNetworkingInternalRequest) XXX_DiscardUnknown()

func (*ConfigureNetworkingInternalRequest) XXX_Marshal 

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

func (*ConfigureNetworkingInternalRequest) XXX_Merge 

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

func (*ConfigureNetworkingInternalRequest) XXX_Size 

func (m *ConfigureNetworkingInternalRequest) XXX_Size() int

func (*ConfigureNetworkingInternalRequest) XXX_Unmarshal 

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

type ConfigureNetworkingInternalResponse 

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

func (*ConfigureNetworkingInternalResponse) Descriptor 

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

func (*ConfigureNetworkingInternalResponse) Marshal 

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

func (*ConfigureNetworkingInternalResponse) MarshalTo 

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

func (*ConfigureNetworkingInternalResponse) ProtoMessage 

func (*ConfigureNetworkingInternalResponse) ProtoMessage()

func (*ConfigureNetworkingInternalResponse) Reset 

func (m *ConfigureNetworkingInternalResponse) Reset()

func (*ConfigureNetworkingInternalResponse) Size 

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

func (*ConfigureNetworkingInternalResponse) String 

func (this *ConfigureNetworkingInternalResponse) String() string

func (*ConfigureNetworkingInternalResponse) Unmarshal 

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

func (*ConfigureNetworkingInternalResponse) XXX_DiscardUnknown 

func (m *ConfigureNetworkingInternalResponse) XXX_DiscardUnknown()

func (*ConfigureNetworkingInternalResponse) XXX_Marshal 

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

func (*ConfigureNetworkingInternalResponse) XXX_Merge 

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

func (*ConfigureNetworkingInternalResponse) XXX_Size 

func (m *ConfigureNetworkingInternalResponse) XXX_Size() int

func (*ConfigureNetworkingInternalResponse) XXX_Unmarshal 

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

type NetworkConfigProxyService 

type NetworkConfigProxyService interface {
	RegisterComputeAgent(ctx context.Context, req *RegisterComputeAgentRequest) (*RegisterComputeAgentResponse, error)
	UnregisterComputeAgent(ctx context.Context, req *UnregisterComputeAgentRequest) (*UnregisterComputeAgentResponse, error)
	ConfigureNetworking(ctx context.Context, req *ConfigureNetworkingInternalRequest) (*ConfigureNetworkingInternalResponse, error)
}

func NewNetworkConfigProxyClient 

func NewNetworkConfigProxyClient(client *github_com_containerd_ttrpc.Client) NetworkConfigProxyService

type RegisterComputeAgentRequest 

type RegisterComputeAgentRequest struct {
	AgentAddress         string   `protobuf:"bytes,1,opt,name=agent_address,json=agentAddress,proto3" json:"agent_address,omitempty"`
	ContainerID          string   `protobuf:"bytes,2,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterComputeAgentRequest) Descriptor 

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

func (*RegisterComputeAgentRequest) Marshal 

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

func (*RegisterComputeAgentRequest) MarshalTo 

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

func (*RegisterComputeAgentRequest) ProtoMessage 

func (*RegisterComputeAgentRequest) ProtoMessage()

func (*RegisterComputeAgentRequest) Reset 

func (m *RegisterComputeAgentRequest) Reset()

func (*RegisterComputeAgentRequest) Size 

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

func (*RegisterComputeAgentRequest) String 

func (this *RegisterComputeAgentRequest) String() string

func (*RegisterComputeAgentRequest) Unmarshal 

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

func (*RegisterComputeAgentRequest) XXX_DiscardUnknown 

func (m *RegisterComputeAgentRequest) XXX_DiscardUnknown()

func (*RegisterComputeAgentRequest) XXX_Marshal 

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

func (*RegisterComputeAgentRequest) XXX_Merge 

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

func (*RegisterComputeAgentRequest) XXX_Size 

func (m *RegisterComputeAgentRequest) XXX_Size() int

func (*RegisterComputeAgentRequest) XXX_Unmarshal 

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

type RegisterComputeAgentResponse 

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

func (*RegisterComputeAgentResponse) Descriptor 

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

func (*RegisterComputeAgentResponse) Marshal 

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

func (*RegisterComputeAgentResponse) MarshalTo 

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

func (*RegisterComputeAgentResponse) ProtoMessage 

func (*RegisterComputeAgentResponse) ProtoMessage()

func (*RegisterComputeAgentResponse) Reset 

func (m *RegisterComputeAgentResponse) Reset()

func (*RegisterComputeAgentResponse) Size 

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

func (*RegisterComputeAgentResponse) String 

func (this *RegisterComputeAgentResponse) String() string

func (*RegisterComputeAgentResponse) Unmarshal 

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

func (*RegisterComputeAgentResponse) XXX_DiscardUnknown 

func (m *RegisterComputeAgentResponse) XXX_DiscardUnknown()

func (*RegisterComputeAgentResponse) XXX_Marshal 

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

func (*RegisterComputeAgentResponse) XXX_Merge 

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

func (*RegisterComputeAgentResponse) XXX_Size 

func (m *RegisterComputeAgentResponse) XXX_Size() int

func (*RegisterComputeAgentResponse) XXX_Unmarshal 

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

type RequestTypeInternal 

type RequestTypeInternal int32
const (
	RequestTypeInternal_Setup    RequestTypeInternal = 0
	RequestTypeInternal_Teardown RequestTypeInternal = 1
)

func (RequestTypeInternal) EnumDescriptor 

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

func (RequestTypeInternal) String 

func (x RequestTypeInternal) String() string

type UnregisterComputeAgentRequest added in v0.9.0 

type UnregisterComputeAgentRequest struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterComputeAgentRequest) Descriptor added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) Marshal added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) MarshalTo added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) ProtoMessage added in v0.9.0 

func (*UnregisterComputeAgentRequest) ProtoMessage()

func (*UnregisterComputeAgentRequest) Reset added in v0.9.0 

func (m *UnregisterComputeAgentRequest) Reset()

func (*UnregisterComputeAgentRequest) Size added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) String added in v0.9.0 

func (this *UnregisterComputeAgentRequest) String() string

func (*UnregisterComputeAgentRequest) Unmarshal added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *UnregisterComputeAgentRequest) XXX_DiscardUnknown()

func (*UnregisterComputeAgentRequest) XXX_Marshal added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) XXX_Merge added in v0.9.0 

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

func (*UnregisterComputeAgentRequest) XXX_Size added in v0.9.0 

func (m *UnregisterComputeAgentRequest) XXX_Size() int

func (*UnregisterComputeAgentRequest) XXX_Unmarshal added in v0.9.0 

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

type UnregisterComputeAgentResponse added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) Descriptor added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) Marshal added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) MarshalTo added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) ProtoMessage added in v0.9.0 

func (*UnregisterComputeAgentResponse) ProtoMessage()

func (*UnregisterComputeAgentResponse) Reset added in v0.9.0 

func (m *UnregisterComputeAgentResponse) Reset()

func (*UnregisterComputeAgentResponse) Size added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) String added in v0.9.0 

func (this *UnregisterComputeAgentResponse) String() string

func (*UnregisterComputeAgentResponse) Unmarshal added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *UnregisterComputeAgentResponse) XXX_DiscardUnknown()

func (*UnregisterComputeAgentResponse) XXX_Marshal added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) XXX_Merge added in v0.9.0 

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

func (*UnregisterComputeAgentResponse) XXX_Size added in v0.9.0 

func (m *UnregisterComputeAgentResponse) XXX_Size() int

func (*UnregisterComputeAgentResponse) XXX_Unmarshal added in v0.9.0 

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