serverrpc

package
v0.0.0-...-282e76a Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2017 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GRPC_API_VERSION = "0.1.0"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ServerRPC 

type ServerRPC struct {
	// contains filtered or unexported fields
}

ServerRPC is the main server for gRPC

func NewServerRPC 

func NewServerRPC(d *daemon.Daemon) *ServerRPC

NewServerRPC creates a new ServerRPC

func (*ServerRPC) Attach 

func (s *ServerRPC) Attach(stream types.PublicAPI_AttachServer) error

func (*ServerRPC) ContainerCreate 

func (s *ServerRPC) ContainerCreate(ctx context.Context, req *types.ContainerCreateRequest) (*types.ContainerCreateResponse, error)

ContainerCreate creates a container by UserContainer spec

func (*ServerRPC) ContainerInfo 

func (s *ServerRPC) ContainerInfo(c context.Context, req *types.ContainerInfoRequest) (*types.ContainerInfoResponse, error)

ContainerInfo gets ContainerInfo by ID or name of container

func (*ServerRPC) ContainerList 

func (s *ServerRPC) ContainerList(ctx context.Context, req *types.ContainerListRequest) (*types.ContainerListResponse, error)

ContainerList implements GET /list?item=container

func (*ServerRPC) ContainerLogs 

func (s *ServerRPC) ContainerLogs(req *types.ContainerLogsRequest, stream types.PublicAPI_ContainerLogsServer) error

func (*ServerRPC) ContainerRemove 

func (s *ServerRPC) ContainerRemove(ctx context.Context, req *types.ContainerRemoveRequest) (*types.ContainerRemoveResponse, error)

func (*ServerRPC) ContainerRename 

func (s *ServerRPC) ContainerRename(c context.Context, req *types.ContainerRenameRequest) (*types.ContainerRenameResponse, error)

ContainerRename rename a container

func (*ServerRPC) ContainerSignal 

func (s *ServerRPC) ContainerSignal(ctx context.Context, req *types.ContainerSignalRequest) (*types.ContainerSignalResponse, error)

ContainerSignal sends a singal to specified container of specified pod

func (*ServerRPC) ContainerStart 

func (s *ServerRPC) ContainerStart(ctx context.Context, req *types.ContainerStartRequest) (*types.ContainerStartResponse, error)

func (*ServerRPC) ContainerStop 

func (s *ServerRPC) ContainerStop(c context.Context, req *types.ContainerStopRequest) (*types.ContainerStopResponse, error)

ContainerStop implements POST /container/stop

func (*ServerRPC) ExecCreate 

func (s *ServerRPC) ExecCreate(ctx context.Context, req *types.ExecCreateRequest) (*types.ExecCreateResponse, error)

func (*ServerRPC) ExecSignal 

func (s *ServerRPC) ExecSignal(ctx context.Context, req *types.ExecSignalRequest) (*types.ExecSignalResponse, error)

ExecSignal sends a singal to specified exec of specified container

func (*ServerRPC) ExecStart 

func (s *ServerRPC) ExecStart(stream types.PublicAPI_ExecStartServer) error

func (*ServerRPC) ExecVM 

func (s *ServerRPC) ExecVM(stream types.PublicAPI_ExecVMServer) error

func (*ServerRPC) ImageList 

func (s *ServerRPC) ImageList(ctx context.Context, req *types.ImageListRequest) (*types.ImageListResponse, error)

ImageList implements GET /images/get

func (*ServerRPC) ImagePull 

func (s *ServerRPC) ImagePull(req *types.ImagePullRequest, stream types.PublicAPI_ImagePullServer) error

ImagePull pulls a image from registry

func (*ServerRPC) ImagePush 

func (s *ServerRPC) ImagePush(req *types.ImagePushRequest, stream types.PublicAPI_ImagePushServer) error

ImagePush pushes a local image to registry

func (*ServerRPC) ImageRemove 

func (s *ServerRPC) ImageRemove(ctx context.Context, req *types.ImageRemoveRequest) (*types.ImageRemoveResponse, error)

ImageRemove deletes a image from hyperd

func (*ServerRPC) Info 

func (s *ServerRPC) Info(c context.Context, req *types.InfoRequest) (*types.InfoResponse, error)

Info gets CmdSystemInfo

func (*ServerRPC) Ping 

func (s *ServerRPC) Ping(c context.Context, req *types.PingRequest) (*types.PingResponse, error)

Ping checks if hyperd is running (returns 'OK' on success)

func (*ServerRPC) PodCreate 

func (s *ServerRPC) PodCreate(ctx context.Context, req *types.PodCreateRequest) (*types.PodCreateResponse, error)

PodCreate creates a pod by PodSpec

func (*ServerRPC) PodInfo 

func (s *ServerRPC) PodInfo(c context.Context, req *types.PodInfoRequest) (*types.PodInfoResponse, error)

PodInfo gets PodInfo by podID

func (*ServerRPC) PodList 

func (s *ServerRPC) PodList(ctx context.Context, req *types.PodListRequest) (*types.PodListResponse, error)

PodList implements GET /list?item=pod

func (*ServerRPC) PodPause 

func (s *ServerRPC) PodPause(ctx context.Context, req *types.PodPauseRequest) (*types.PodPauseResponse, error)

PodPause pauses a pod

func (*ServerRPC) PodRemove 

func (s *ServerRPC) PodRemove(ctx context.Context, req *types.PodRemoveRequest) (*types.PodRemoveResponse, error)

PodRemove removes a pod by podID

func (*ServerRPC) PodSignal 

func (s *ServerRPC) PodSignal(ctx context.Context, req *types.PodSignalRequest) (*types.PodSignalResponse, error)

PodSignal sends a singal to all containers of specified pod

func (*ServerRPC) PodStart 

func (s *ServerRPC) PodStart(ctx context.Context, req *types.PodStartRequest) (*types.PodStartResponse, error)

PodStart starts a pod by podID

func (*ServerRPC) PodStats 

func (s *ServerRPC) PodStats(c context.Context, req *types.PodStatsRequest) (*types.PodStatsResponse, error)

PodStats get stats (runvtypes.PodStats) of Pod

func (*ServerRPC) PodStop 

func (s *ServerRPC) PodStop(ctx context.Context, req *types.PodStopRequest) (*types.PodStopResponse, error)

PodStop stops a pod

func (*ServerRPC) PodUnpause 

func (s *ServerRPC) PodUnpause(ctx context.Context, req *types.PodUnpauseRequest) (*types.PodUnpauseResponse, error)

PodUnpause unpauses a pod

func (*ServerRPC) Serve 

func (s *ServerRPC) Serve(addr string) error

Serve serves gRPC request by goroutines

func (*ServerRPC) ServiceAdd 

func (s *ServerRPC) ServiceAdd(ctx context.Context, req *types.ServiceAddRequest) (*types.ServiceAddResponse, error)

ServiceAdd implements POST /service/list

func (*ServerRPC) ServiceDelete 

func (s *ServerRPC) ServiceDelete(ctx context.Context, req *types.ServiceDelRequest) (*types.ServiceDelResponse, error)

ServiceDelete implements DELETE /service

func (*ServerRPC) ServiceList 

func (s *ServerRPC) ServiceList(ctx context.Context, req *types.ServiceListRequest) (*types.ServiceListResponse, error)

ServiceList implements GET /service/list

func (*ServerRPC) ServiceUpdate 

func (s *ServerRPC) ServiceUpdate(ctx context.Context, req *types.ServiceUpdateRequest) (*types.ServiceUpdateResponse, error)

ServiceUpdate implements UPDATE /service

func (*ServerRPC) SetPodLabels 

func (s *ServerRPC) SetPodLabels(c context.Context, req *types.PodLabelsRequest) (*types.PodLabelsResponse, error)

PodLabels sets the labels of Pod

func (*ServerRPC) Stop 

func (s *ServerRPC) Stop()

Stop stops gRPC server

func (*ServerRPC) TTYResize 

func (s *ServerRPC) TTYResize(c context.Context, req *types.TTYResizeRequest) (*types.TTYResizeResponse, error)

TTYResize resizes the tty of the specified container

func (*ServerRPC) VMList 

func (s *ServerRPC) VMList(ctx context.Context, req *types.VMListRequest) (*types.VMListResponse, error)

VMList implements GET /list?item=vm

func (*ServerRPC) Version 

func (s *ServerRPC) Version(c context.Context, req *types.VersionRequest) (*types.VersionResponse, error)

Version gets the version and apiVersion of hyperd

func (*ServerRPC) Wait 

func (s *ServerRPC) Wait(c context.Context, req *types.WaitRequest) (*types.WaitResponse, error)

Wait gets exitcode by container and processId

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.