api

func (*YockDaemon) Call ¶

func (yockd *YockDaemon) Call(ctx context.Context, req *proto.CallRequest) (*proto.CallResponse, error)

func (*YockDaemon) Close ¶

func (yockd *YockDaemon) Close()

func (*YockDaemon) Dial ¶

func (yockd *YockDaemon) Dial(ctx context.Context, req *proto.DialRequest) (*proto.DialResponse, error)

func (*YockDaemon) FileSystemDownload ¶

func (yockd *YockDaemon) FileSystemDownload(stream pb.YockDaemon_FileSystemDownloadServer) error

Download file in other peer

func (*YockDaemon) FileSystemGet ¶

func (yockd *YockDaemon) FileSystemGet(ctx context.Context, req *pb.FileSystemGetRequest) (*pb.FileSystemGetResponse, error)

func (*YockDaemon) FileSystemPut ¶

func (yockd *YockDaemon) FileSystemPut(ctx context.Context, req *pb.FileSystemPutRequest) (*pb.FileSystemPutResponse, error)

func (*YockDaemon) Info ¶

func (yockd *YockDaemon) Info(ctx context.Context, req *pb.InfoRequest) (*pb.InfoResponse, error)

Info can obtain the meta information of the target node, including CPU, DISK, MEM and so on. You can specify it by InfoRequest, and by default only basic parameters (the name of the node, the file uploaded, and the connection information) are returned.

func (*YockDaemon) Mark ¶

func (yockd *YockDaemon) Mark(ctx context.Context, req *proto.MarkRequest) (*proto.MarkResponse, error)

func (*YockDaemon) MemFree ¶

func (yockd *YockDaemon) MemFree()

func (*YockDaemon) Ping ¶

func (yockd *YockDaemon) Ping(ctx context.Context, req *pb.PingRequest) (*pb.PingResponse, error)

Ping is used to detect whether the connection is available

func (*YockDaemon) ProcessFind ¶

func (daemon *YockDaemon) ProcessFind(ctx context.Context, req *pb.ProcessFindRequest) (*pb.ProcessFindResponse, error)

func (*YockDaemon) ProcessKill ¶

func (daemon *YockDaemon) ProcessKill(ctx context.Context, req *pb.ProcessKillRequest) (*pb.ProcessKillResponse, error)

func (*YockDaemon) ProcessList ¶

func (daemon *YockDaemon) ProcessList(ctx context.Context, req *pb.ProcessListRequest) (*pb.ProcessListResponse, error)

func (*YockDaemon) ProcessSpawn ¶

func (daemon *YockDaemon) ProcessSpawn(ctx context.Context, req *pb.ProcessSpawnRequest) (*pb.ProcessSpawnResponse, error)

func (*YockDaemon) Run ¶

func (yockd *YockDaemon) Run()

func (*YockDaemon) SignalList ¶

func (yockd *YockDaemon) SignalList(context.Context, *pb.SignalListRequest) (*pb.SignalListResponse, error)

func (*YockDaemon) SignalNotify ¶

func (yockd *YockDaemon) SignalNotify(ctx context.Context, req *pb.NotifyRequest) (*pb.NotifyResponse, error)

Notify pushes signal to Daemon

func (*YockDaemon) SignalWait ¶

func (yockd *YockDaemon) SignalWait(ctx context.Context, req *pb.WaitRequest) (*pb.WaitResponse, error)

Wait is used to request signal from the daemon

func (*YockDaemon) SingalClear ¶

func (yockd *YockDaemon) SingalClear(ctx context.Context, req *pb.SignalClearRequest) (*pb.SignalClearResponse, error)

func (*YockDaemon) SingalInfo ¶

func (yockd *YockDaemon) SingalInfo(ctx context.Context, req *pb.SignalInfoRequest) (*pb.SignalInfoResponse, error)

func (*YockDaemon) Tunnel ¶

func (yockd *YockDaemon) Tunnel(stream proto.YockDaemon_TunnelServer) error

func (*YockDaemon) Upload ¶

func (yockd *YockDaemon) Upload(ctx context.Context, req *pb.UploadRequest) (*pb.UploadResponse, error)

Upload pushes file information to peers so that peers can download files