api

Documentation

Index

• type YockDaemon
  • func New() *YockDaemon
  • func (yockd *YockDaemon) Call(ctx context.Context, req *proto.CallRequest) (*proto.CallResponse, error)
  • func (yockd *YockDaemon) Close()
  • func (yockd *YockDaemon) Dial(ctx context.Context, req *proto.DialRequest) (*proto.DialResponse, error)
  • func (yockd *YockDaemon) FileSystemDownload(stream pb.YockDaemon_FileSystemDownloadServer) error
  • func (yockd *YockDaemon) FileSystemGet(ctx context.Context, req *pb.FileSystemGetRequest) (*pb.FileSystemGetResponse, error)
  • func (yockd *YockDaemon) FileSystemPut(ctx context.Context, req *pb.FileSystemPutRequest) (*pb.FileSystemPutResponse, error)
  • func (yockd *YockDaemon) Info(ctx context.Context, req *pb.InfoRequest) (*pb.InfoResponse, error)
  • func (yockd *YockDaemon) Mark(ctx context.Context, req *proto.MarkRequest) (*proto.MarkResponse, error)
  • func (yockd *YockDaemon) MemFree()
  • func (yockd *YockDaemon) Ping(ctx context.Context, req *pb.PingRequest) (*pb.PingResponse, error)
  • func (daemon *YockDaemon) ProcessFind(ctx context.Context, req *pb.ProcessFindRequest) (*pb.ProcessFindResponse, error)
  • func (daemon *YockDaemon) ProcessKill(ctx context.Context, req *pb.ProcessKillRequest) (*pb.ProcessKillResponse, error)
  • func (daemon *YockDaemon) ProcessList(ctx context.Context, req *pb.ProcessListRequest) (*pb.ProcessListResponse, error)
  • func (daemon *YockDaemon) ProcessSpawn(ctx context.Context, req *pb.ProcessSpawnRequest) (*pb.ProcessSpawnResponse, error)
  • func (yockd *YockDaemon) Run()
  • func (yockd *YockDaemon) SignalList(context.Context, *pb.SignalListRequest) (*pb.SignalListResponse, error)
  • func (yockd *YockDaemon) SignalNotify(ctx context.Context, req *pb.NotifyRequest) (*pb.NotifyResponse, error)
  • func (yockd *YockDaemon) SignalWait(ctx context.Context, req *pb.WaitRequest) (*pb.WaitResponse, error)
  • func (yockd *YockDaemon) SingalClear(ctx context.Context, req *pb.SignalClearRequest) (*pb.SignalClearResponse, error)
  • func (yockd *YockDaemon) SingalInfo(ctx context.Context, req *pb.SignalInfoRequest) (*pb.SignalInfoResponse, error)
  • func (yockd *YockDaemon) Tunnel(stream proto.YockDaemon_TunnelServer) error
  • func (yockd *YockDaemon) Upload(ctx context.Context, req *pb.UploadRequest) (*pb.UploadResponse, error)

Types

type YockDaemon

type YockDaemon struct {
	pb.UnimplementedYockDaemonServer

	*kernel.YockKernel
	// contains filtered or unexported fields
}

func New

func New() *YockDaemon

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