deviceplugin

Sep 28, 2017

Changes in this version

+ const DevicePluginPath

+ const Healthy

+ const KubeletSocket

+ const Unhealthy

+ const Version

+ var ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterDevicePluginServer(s *grpc.Server, srv DevicePluginServer)

+ func RegisterRegistrationServer(s *grpc.Server, srv RegistrationServer)

+ type AllocateRequest struct

+ DevicesIDs []string

+ func (*AllocateRequest) Descriptor() ([]byte, []int)

+ func (*AllocateRequest) ProtoMessage()

+ func (m *AllocateRequest) GetDevicesIDs() []string

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

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

+ func (m *AllocateRequest) Reset()

+ func (m *AllocateRequest) Size() (n int)

+ func (m *AllocateRequest) Unmarshal(dAtA []byte) error

+ func (this *AllocateRequest) String() string

+ type AllocateResponse struct

+ Spec []*DeviceRuntimeSpec

+ func (*AllocateResponse) Descriptor() ([]byte, []int)

+ func (*AllocateResponse) ProtoMessage()

+ func (m *AllocateResponse) GetSpec() []*DeviceRuntimeSpec

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

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

+ func (m *AllocateResponse) Reset()

+ func (m *AllocateResponse) Size() (n int)

+ func (m *AllocateResponse) Unmarshal(dAtA []byte) error

+ func (this *AllocateResponse) String() string

+ type Device struct

+ Health string

+ ID string

+ func (*Device) Descriptor() ([]byte, []int)

+ func (*Device) ProtoMessage()

+ func (m *Device) GetHealth() string

+ func (m *Device) GetID() string

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

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

+ func (m *Device) Reset()

+ func (m *Device) Size() (n int)

+ func (m *Device) Unmarshal(dAtA []byte) error

+ func (this *Device) String() string

+ type DevicePluginClient interface

+ Allocate func(ctx context.Context, in *AllocateRequest, opts ...grpc.CallOption) (*AllocateResponse, error)

+ ListAndWatch func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (DevicePlugin_ListAndWatchClient, error)

+ func NewDevicePluginClient(cc *grpc.ClientConn) DevicePluginClient

+ type DevicePluginServer interface

+ Allocate func(context.Context, *AllocateRequest) (*AllocateResponse, error)

+ ListAndWatch func(*Empty, DevicePlugin_ListAndWatchServer) error

+ type DevicePlugin_ListAndWatchClient interface

+ Recv func() (*ListAndWatchResponse, error)

+ type DevicePlugin_ListAndWatchServer interface

+ Send func(*ListAndWatchResponse) error

+ type DeviceRuntimeSpec struct

+ Devices []*DeviceSpec

+ Envs map[string]string

+ ID string

+ Mounts []*Mount

+ func (*DeviceRuntimeSpec) Descriptor() ([]byte, []int)

+ func (*DeviceRuntimeSpec) ProtoMessage()

+ func (m *DeviceRuntimeSpec) GetDevices() []*DeviceSpec

+ func (m *DeviceRuntimeSpec) GetEnvs() map[string]string

+ func (m *DeviceRuntimeSpec) GetID() string

+ func (m *DeviceRuntimeSpec) GetMounts() []*Mount

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

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

+ func (m *DeviceRuntimeSpec) Reset()

+ func (m *DeviceRuntimeSpec) Size() (n int)

+ func (m *DeviceRuntimeSpec) Unmarshal(dAtA []byte) error

+ func (this *DeviceRuntimeSpec) String() string

+ type DeviceSpec struct

+ ContainerPath string

+ HostPath string

+ Permissions string

+ func (*DeviceSpec) Descriptor() ([]byte, []int)

+ func (*DeviceSpec) ProtoMessage()

+ func (m *DeviceSpec) GetContainerPath() string

+ func (m *DeviceSpec) GetHostPath() string

+ func (m *DeviceSpec) GetPermissions() string

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

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

+ func (m *DeviceSpec) Reset()

+ func (m *DeviceSpec) Size() (n int)

+ func (m *DeviceSpec) Unmarshal(dAtA []byte) error

+ func (this *DeviceSpec) String() string

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

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

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

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ func (this *Empty) String() string

+ type ListAndWatchResponse struct

+ Devices []*Device

+ func (*ListAndWatchResponse) Descriptor() ([]byte, []int)

+ func (*ListAndWatchResponse) ProtoMessage()

+ func (m *ListAndWatchResponse) GetDevices() []*Device

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

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

+ func (m *ListAndWatchResponse) Reset()

+ func (m *ListAndWatchResponse) Size() (n int)

+ func (m *ListAndWatchResponse) Unmarshal(dAtA []byte) error

+ func (this *ListAndWatchResponse) String() string

+ type Mount struct

+ ContainerPath string

+ HostPath string

+ ReadOnly bool

+ func (*Mount) Descriptor() ([]byte, []int)

+ func (*Mount) ProtoMessage()

+ func (m *Mount) GetContainerPath() string

+ func (m *Mount) GetHostPath() string

+ func (m *Mount) GetReadOnly() bool

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

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

+ func (m *Mount) Reset()

+ func (m *Mount) Size() (n int)

+ func (m *Mount) Unmarshal(dAtA []byte) error

+ func (this *Mount) String() string

+ type RegisterRequest struct

+ Endpoint string

+ ResourceName string

+ Version string

+ func (*RegisterRequest) Descriptor() ([]byte, []int)

+ func (*RegisterRequest) ProtoMessage()

+ func (m *RegisterRequest) GetEndpoint() string

+ func (m *RegisterRequest) GetResourceName() string

+ func (m *RegisterRequest) GetVersion() string

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

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

+ func (m *RegisterRequest) Reset()

+ func (m *RegisterRequest) Size() (n int)

+ func (m *RegisterRequest) Unmarshal(dAtA []byte) error

+ func (this *RegisterRequest) String() string

+ type RegistrationClient interface

+ Register func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*Empty, error)

+ func NewRegistrationClient(cc *grpc.ClientConn) RegistrationClient

+ type RegistrationServer interface

+ Register func(context.Context, *RegisterRequest) (*Empty, error)