system

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSystem        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSystem          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSystem = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterSystemServiceServer 

func RegisterSystemServiceServer(s *grpc.Server, srv SystemServiceServer)

Types

type DiskBackendProxyRequest 

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

func (*DiskBackendProxyRequest) Descriptor 

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

func (*DiskBackendProxyRequest) GetName 

func (m *DiskBackendProxyRequest) GetName() string

func (*DiskBackendProxyRequest) Marshal 

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

func (*DiskBackendProxyRequest) MarshalTo 

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

func (*DiskBackendProxyRequest) MarshalToSizedBuffer 

func (m *DiskBackendProxyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DiskBackendProxyRequest) ProtoMessage 

func (*DiskBackendProxyRequest) ProtoMessage()

func (*DiskBackendProxyRequest) Reset 

func (m *DiskBackendProxyRequest) Reset()

func (*DiskBackendProxyRequest) Size 

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

func (*DiskBackendProxyRequest) String 

func (m *DiskBackendProxyRequest) String() string

func (*DiskBackendProxyRequest) Unmarshal 

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

func (*DiskBackendProxyRequest) XXX_DiscardUnknown 

func (m *DiskBackendProxyRequest) XXX_DiscardUnknown()

func (*DiskBackendProxyRequest) XXX_Marshal 

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

func (*DiskBackendProxyRequest) XXX_Merge 

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

func (*DiskBackendProxyRequest) XXX_Size 

func (m *DiskBackendProxyRequest) XXX_Size() int

func (*DiskBackendProxyRequest) XXX_Unmarshal 

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

type RegisterQemuInstanceRequest 

type RegisterQemuInstanceRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MemActual            int64    `protobuf:"varint,2,opt,name=mem_actual,json=memActual,proto3" json:"mem_actual,omitempty"`
	PID                  int32    `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterQemuInstanceRequest) Descriptor 

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

func (*RegisterQemuInstanceRequest) GetMemActual 

func (m *RegisterQemuInstanceRequest) GetMemActual() int64

func (*RegisterQemuInstanceRequest) GetName 

func (m *RegisterQemuInstanceRequest) GetName() string

func (*RegisterQemuInstanceRequest) GetPID 

func (m *RegisterQemuInstanceRequest) GetPID() int32

func (*RegisterQemuInstanceRequest) Marshal 

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

func (*RegisterQemuInstanceRequest) MarshalTo 

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

func (*RegisterQemuInstanceRequest) MarshalToSizedBuffer 

func (m *RegisterQemuInstanceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterQemuInstanceRequest) ProtoMessage 

func (*RegisterQemuInstanceRequest) ProtoMessage()

func (*RegisterQemuInstanceRequest) Reset 

func (m *RegisterQemuInstanceRequest) Reset()

func (*RegisterQemuInstanceRequest) Size 

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

func (*RegisterQemuInstanceRequest) String 

func (m *RegisterQemuInstanceRequest) String() string

func (*RegisterQemuInstanceRequest) Unmarshal 

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

func (*RegisterQemuInstanceRequest) XXX_DiscardUnknown 

func (m *RegisterQemuInstanceRequest) XXX_DiscardUnknown()

func (*RegisterQemuInstanceRequest) XXX_Marshal 

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

func (*RegisterQemuInstanceRequest) XXX_Merge 

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

func (*RegisterQemuInstanceRequest) XXX_Size 

func (m *RegisterQemuInstanceRequest) XXX_Size() int

func (*RegisterQemuInstanceRequest) XXX_Unmarshal 

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

type RegisterQemuInstanceResponse 

type RegisterQemuInstanceResponse struct {
	TaskKey              string   `protobuf:"bytes,1,opt,name=task_key,json=taskKey,proto3" json:"task_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterQemuInstanceResponse) Descriptor 

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

func (*RegisterQemuInstanceResponse) GetTaskKey 

func (m *RegisterQemuInstanceResponse) GetTaskKey() string

func (*RegisterQemuInstanceResponse) Marshal 

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

func (*RegisterQemuInstanceResponse) MarshalTo 

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

func (*RegisterQemuInstanceResponse) MarshalToSizedBuffer 

func (m *RegisterQemuInstanceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterQemuInstanceResponse) ProtoMessage 

func (*RegisterQemuInstanceResponse) ProtoMessage()

func (*RegisterQemuInstanceResponse) Reset 

func (m *RegisterQemuInstanceResponse) Reset()

func (*RegisterQemuInstanceResponse) Size 

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

func (*RegisterQemuInstanceResponse) String 

func (m *RegisterQemuInstanceResponse) String() string

func (*RegisterQemuInstanceResponse) Unmarshal 

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

func (*RegisterQemuInstanceResponse) XXX_DiscardUnknown 

func (m *RegisterQemuInstanceResponse) XXX_DiscardUnknown()

func (*RegisterQemuInstanceResponse) XXX_Marshal 

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

func (*RegisterQemuInstanceResponse) XXX_Merge 

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

func (*RegisterQemuInstanceResponse) XXX_Size 

func (m *RegisterQemuInstanceResponse) XXX_Size() int

func (*RegisterQemuInstanceResponse) XXX_Unmarshal 

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

type StartIncomingMachineRequest 

type StartIncomingMachineRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Manifest             []byte            `protobuf:"bytes,2,opt,name=manifest,proto3" json:"manifest,omitempty"`
	Disks                map[string]uint64 `` /* 152-byte string literal not displayed */
	ExtraFiles           map[string][]byte `` /* 179-byte string literal not displayed */
	CreateDisks          bool              `protobuf:"varint,5,opt,name=create_disks,json=createDisks,proto3" json:"create_disks,omitempty"`
	ListenAddr           string            `protobuf:"bytes,6,opt,name=listen_addr,json=listenAddr,proto3" json:"listen_addr,omitempty"`
	TurnOffAfter         bool              `protobuf:"varint,7,opt,name=turn_off_after,json=turnOffAfter,proto3" json:"turn_off_after,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StartIncomingMachineRequest) Descriptor 

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

func (*StartIncomingMachineRequest) GetCreateDisks 

func (m *StartIncomingMachineRequest) GetCreateDisks() bool

func (*StartIncomingMachineRequest) GetDisks 

func (m *StartIncomingMachineRequest) GetDisks() map[string]uint64

func (*StartIncomingMachineRequest) GetExtraFiles 

func (m *StartIncomingMachineRequest) GetExtraFiles() map[string][]byte

func (*StartIncomingMachineRequest) GetListenAddr 

func (m *StartIncomingMachineRequest) GetListenAddr() string

func (*StartIncomingMachineRequest) GetManifest 

func (m *StartIncomingMachineRequest) GetManifest() []byte

func (*StartIncomingMachineRequest) GetName 

func (m *StartIncomingMachineRequest) GetName() string

func (*StartIncomingMachineRequest) GetTurnOffAfter 

func (m *StartIncomingMachineRequest) GetTurnOffAfter() bool

func (*StartIncomingMachineRequest) Marshal 

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

func (*StartIncomingMachineRequest) MarshalTo 

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

func (*StartIncomingMachineRequest) MarshalToSizedBuffer 

func (m *StartIncomingMachineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartIncomingMachineRequest) ProtoMessage 

func (*StartIncomingMachineRequest) ProtoMessage()

func (*StartIncomingMachineRequest) Reset 

func (m *StartIncomingMachineRequest) Reset()

func (*StartIncomingMachineRequest) Size 

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

func (*StartIncomingMachineRequest) String 

func (m *StartIncomingMachineRequest) String() string

func (*StartIncomingMachineRequest) Unmarshal 

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

func (*StartIncomingMachineRequest) XXX_DiscardUnknown 

func (m *StartIncomingMachineRequest) XXX_DiscardUnknown()

func (*StartIncomingMachineRequest) XXX_Marshal 

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

func (*StartIncomingMachineRequest) XXX_Merge 

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

func (*StartIncomingMachineRequest) XXX_Size 

func (m *StartIncomingMachineRequest) XXX_Size() int

func (*StartIncomingMachineRequest) XXX_Unmarshal 

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

type StartIncomingMachineResponse 

type StartIncomingMachineResponse struct {
	Requisites           *types.IncomingMachineRequisites `protobuf:"bytes,1,opt,name=requisites,proto3" json:"requisites,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*StartIncomingMachineResponse) Descriptor 

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

func (*StartIncomingMachineResponse) GetRequisites 

func (m *StartIncomingMachineResponse) GetRequisites() *types.IncomingMachineRequisites

func (*StartIncomingMachineResponse) Marshal 

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

func (*StartIncomingMachineResponse) MarshalTo 

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

func (*StartIncomingMachineResponse) MarshalToSizedBuffer 

func (m *StartIncomingMachineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartIncomingMachineResponse) ProtoMessage 

func (*StartIncomingMachineResponse) ProtoMessage()

func (*StartIncomingMachineResponse) Reset 

func (m *StartIncomingMachineResponse) Reset()

func (*StartIncomingMachineResponse) Size 

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

func (*StartIncomingMachineResponse) String 

func (m *StartIncomingMachineResponse) String() string

func (*StartIncomingMachineResponse) Unmarshal 

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

func (*StartIncomingMachineResponse) XXX_DiscardUnknown 

func (m *StartIncomingMachineResponse) XXX_DiscardUnknown()

func (*StartIncomingMachineResponse) XXX_Marshal 

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

func (*StartIncomingMachineResponse) XXX_Merge 

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

func (*StartIncomingMachineResponse) XXX_Size 

func (m *StartIncomingMachineResponse) XXX_Size() int

func (*StartIncomingMachineResponse) XXX_Unmarshal 

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

type StopQemuInstanceRequest 

type StopQemuInstanceRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	GracefulTimeout      int32    `protobuf:"varint,2,opt,name=graceful_timeout,json=gracefulTimeout,proto3" json:"graceful_timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopQemuInstanceRequest) Descriptor 

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

func (*StopQemuInstanceRequest) GetGracefulTimeout 

func (m *StopQemuInstanceRequest) GetGracefulTimeout() int32

func (*StopQemuInstanceRequest) GetName 

func (m *StopQemuInstanceRequest) GetName() string

func (*StopQemuInstanceRequest) Marshal 

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

func (*StopQemuInstanceRequest) MarshalTo 

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

func (*StopQemuInstanceRequest) MarshalToSizedBuffer 

func (m *StopQemuInstanceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StopQemuInstanceRequest) ProtoMessage 

func (*StopQemuInstanceRequest) ProtoMessage()

func (*StopQemuInstanceRequest) Reset 

func (m *StopQemuInstanceRequest) Reset()

func (*StopQemuInstanceRequest) Size 

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

func (*StopQemuInstanceRequest) String 

func (m *StopQemuInstanceRequest) String() string

func (*StopQemuInstanceRequest) Unmarshal 

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

func (*StopQemuInstanceRequest) XXX_DiscardUnknown 

func (m *StopQemuInstanceRequest) XXX_DiscardUnknown()

func (*StopQemuInstanceRequest) XXX_Marshal 

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

func (*StopQemuInstanceRequest) XXX_Merge 

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

func (*StopQemuInstanceRequest) XXX_Size 

func (m *StopQemuInstanceRequest) XXX_Size() int

func (*StopQemuInstanceRequest) XXX_Unmarshal 

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

type SystemServiceClient 

type SystemServiceClient interface {
	RegisterQemuInstance(ctx context.Context, in *RegisterQemuInstanceRequest, opts ...grpc.CallOption) (*RegisterQemuInstanceResponse, error)
	UnregisterQemuInstance(ctx context.Context, in *UnregisterQemuInstanceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StopQemuInstance(ctx context.Context, in *StopQemuInstanceRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StartIncomingMachine(ctx context.Context, in *StartIncomingMachineRequest, opts ...grpc.CallOption) (*StartIncomingMachineResponse, error)
	StartDiskBackendProxy(ctx context.Context, in *DiskBackendProxyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StopDiskBackendProxy(ctx context.Context, in *DiskBackendProxyRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

SystemServiceClient is the client API for SystemService service.

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

func NewSystemServiceClient 

func NewSystemServiceClient(cc *grpc.ClientConn) SystemServiceClient

type SystemServiceServer 

type SystemServiceServer interface {
	RegisterQemuInstance(context.Context, *RegisterQemuInstanceRequest) (*RegisterQemuInstanceResponse, error)
	UnregisterQemuInstance(context.Context, *UnregisterQemuInstanceRequest) (*empty.Empty, error)
	StopQemuInstance(context.Context, *StopQemuInstanceRequest) (*empty.Empty, error)
	StartIncomingMachine(context.Context, *StartIncomingMachineRequest) (*StartIncomingMachineResponse, error)
	StartDiskBackendProxy(context.Context, *DiskBackendProxyRequest) (*empty.Empty, error)
	StopDiskBackendProxy(context.Context, *DiskBackendProxyRequest) (*empty.Empty, error)
}

SystemServiceServer is the server API for SystemService service.

type UnimplementedSystemServiceServer 

type UnimplementedSystemServiceServer struct {
}

UnimplementedSystemServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSystemServiceServer) RegisterQemuInstance 

func (*UnimplementedSystemServiceServer) RegisterQemuInstance(ctx context.Context, req *RegisterQemuInstanceRequest) (*RegisterQemuInstanceResponse, error)

func (*UnimplementedSystemServiceServer) StartDiskBackendProxy 

func (*UnimplementedSystemServiceServer) StartDiskBackendProxy(ctx context.Context, req *DiskBackendProxyRequest) (*empty.Empty, error)

func (*UnimplementedSystemServiceServer) StartIncomingMachine 

func (*UnimplementedSystemServiceServer) StartIncomingMachine(ctx context.Context, req *StartIncomingMachineRequest) (*StartIncomingMachineResponse, error)

func (*UnimplementedSystemServiceServer) StopDiskBackendProxy 

func (*UnimplementedSystemServiceServer) StopDiskBackendProxy(ctx context.Context, req *DiskBackendProxyRequest) (*empty.Empty, error)

func (*UnimplementedSystemServiceServer) StopQemuInstance 

func (*UnimplementedSystemServiceServer) StopQemuInstance(ctx context.Context, req *StopQemuInstanceRequest) (*empty.Empty, error)

func (*UnimplementedSystemServiceServer) UnregisterQemuInstance 

func (*UnimplementedSystemServiceServer) UnregisterQemuInstance(ctx context.Context, req *UnregisterQemuInstanceRequest) (*empty.Empty, error)

type UnregisterQemuInstanceRequest 

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

func (*UnregisterQemuInstanceRequest) Descriptor 

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

func (*UnregisterQemuInstanceRequest) GetName 

func (m *UnregisterQemuInstanceRequest) GetName() string

func (*UnregisterQemuInstanceRequest) Marshal 

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

func (*UnregisterQemuInstanceRequest) MarshalTo 

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

func (*UnregisterQemuInstanceRequest) MarshalToSizedBuffer 

func (m *UnregisterQemuInstanceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnregisterQemuInstanceRequest) ProtoMessage 

func (*UnregisterQemuInstanceRequest) ProtoMessage()

func (*UnregisterQemuInstanceRequest) Reset 

func (m *UnregisterQemuInstanceRequest) Reset()

func (*UnregisterQemuInstanceRequest) Size 

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

func (*UnregisterQemuInstanceRequest) String 

func (m *UnregisterQemuInstanceRequest) String() string

func (*UnregisterQemuInstanceRequest) Unmarshal 

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

func (*UnregisterQemuInstanceRequest) XXX_DiscardUnknown 

func (m *UnregisterQemuInstanceRequest) XXX_DiscardUnknown()

func (*UnregisterQemuInstanceRequest) XXX_Marshal 

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

func (*UnregisterQemuInstanceRequest) XXX_Merge 

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

func (*UnregisterQemuInstanceRequest) XXX_Size 

func (m *UnregisterQemuInstanceRequest) XXX_Size() int

func (*UnregisterQemuInstanceRequest) XXX_Unmarshal 

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