proto

package
v0.0.0-...-9853328 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProcessSpawnType_name = map[int32]string{
		0: "Invalid",
		1: "Cron",
		2: "FS",
		3: "Script",
	}
	ProcessSpawnType_value = map[string]int32{
		"Invalid": 0,
		"Cron":    1,
		"FS":      2,
		"Script":  3,
	}
)

Enum value maps for ProcessSpawnType.

View Source 
var (
	ProtocalType_name = map[int32]string{
		0: "Unknown",
		1: "Establish",
		2: "Heartbeat",
		3: "MethodCall",
		4: "MethodReturn",
	}
	ProtocalType_value = map[string]int32{
		"Unknown":      0,
		"Establish":    1,
		"Heartbeat":    2,
		"MethodCall":   3,
		"MethodReturn": 4,
	}
)

Enum value maps for ProtocalType.

View Source 
var File_yockd_proto protoreflect.FileDescriptor

Functions

func RegisterYockDaemonServer 

func RegisterYockDaemonServer(s *grpc.Server, srv YockDaemonServer)

Types

type CallRequest 

type CallRequest struct {
	Node   string   `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Method string   `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Args   []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*CallRequest) Descriptor deprecated 

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

Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.

func (*CallRequest) GetArgs 

func (x *CallRequest) GetArgs() []string

func (*CallRequest) GetMethod 

func (x *CallRequest) GetMethod() string

func (*CallRequest) GetNode 

func (x *CallRequest) GetNode() string

func (*CallRequest) ProtoMessage 

func (*CallRequest) ProtoMessage()

func (*CallRequest) ProtoReflect 

func (x *CallRequest) ProtoReflect() protoreflect.Message

func (*CallRequest) Reset 

func (x *CallRequest) Reset()

func (*CallRequest) String 

func (x *CallRequest) String() string

type CallResponse 

type CallResponse struct {
	Ret string `protobuf:"bytes,1,opt,name=ret,proto3" json:"ret,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor deprecated 

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetRet 

func (x *CallResponse) GetRet() string

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect 

func (x *CallResponse) ProtoReflect() protoreflect.Message

func (*CallResponse) Reset 

func (x *CallResponse) Reset()

func (*CallResponse) String 

func (x *CallResponse) String() string

type DialRequest 

type DialRequest struct {
	From *NodeInfo `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To   *NodeInfo `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*DialRequest) Descriptor deprecated 

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

Deprecated: Use DialRequest.ProtoReflect.Descriptor instead.

func (*DialRequest) GetFrom 

func (x *DialRequest) GetFrom() *NodeInfo

func (*DialRequest) GetTo 

func (x *DialRequest) GetTo() *NodeInfo

func (*DialRequest) ProtoMessage 

func (*DialRequest) ProtoMessage()

func (*DialRequest) ProtoReflect 

func (x *DialRequest) ProtoReflect() protoreflect.Message

func (*DialRequest) Reset 

func (x *DialRequest) Reset()

func (*DialRequest) String 

func (x *DialRequest) String() string

type DialResponse 

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

func (*DialResponse) Descriptor deprecated 

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

Deprecated: Use DialResponse.ProtoReflect.Descriptor instead.

func (*DialResponse) ProtoMessage 

func (*DialResponse) ProtoMessage()

func (*DialResponse) ProtoReflect 

func (x *DialResponse) ProtoReflect() protoreflect.Message

func (*DialResponse) Reset 

func (x *DialResponse) Reset()

func (*DialResponse) String 

func (x *DialResponse) String() string

type FileSystemDownloadRequest 

type FileSystemDownloadRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Sender   string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSystemDownloadRequest) Descriptor deprecated 

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

Deprecated: Use FileSystemDownloadRequest.ProtoReflect.Descriptor instead.

func (*FileSystemDownloadRequest) GetFilename 

func (x *FileSystemDownloadRequest) GetFilename() string

func (*FileSystemDownloadRequest) GetSender 

func (x *FileSystemDownloadRequest) GetSender() string

func (*FileSystemDownloadRequest) ProtoMessage 

func (*FileSystemDownloadRequest) ProtoMessage()

func (*FileSystemDownloadRequest) ProtoReflect 

func (x *FileSystemDownloadRequest) ProtoReflect() protoreflect.Message

func (*FileSystemDownloadRequest) Reset 

func (x *FileSystemDownloadRequest) Reset()

func (*FileSystemDownloadRequest) String 

func (x *FileSystemDownloadRequest) String() string

type FileSystemDownloadResponse 

type FileSystemDownloadResponse struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSystemDownloadResponse) Descriptor deprecated 

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

Deprecated: Use FileSystemDownloadResponse.ProtoReflect.Descriptor instead.

func (*FileSystemDownloadResponse) GetData 

func (x *FileSystemDownloadResponse) GetData() []byte

func (*FileSystemDownloadResponse) ProtoMessage 

func (*FileSystemDownloadResponse) ProtoMessage()

func (*FileSystemDownloadResponse) ProtoReflect 

func (x *FileSystemDownloadResponse) ProtoReflect() protoreflect.Message

func (*FileSystemDownloadResponse) Reset 

func (x *FileSystemDownloadResponse) Reset()

func (*FileSystemDownloadResponse) String 

func (x *FileSystemDownloadResponse) String() string

type FileSystemGetRequest 

type FileSystemGetRequest struct {
	Src string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSystemGetRequest) Descriptor deprecated 

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

Deprecated: Use FileSystemGetRequest.ProtoReflect.Descriptor instead.

func (*FileSystemGetRequest) GetDst 

func (x *FileSystemGetRequest) GetDst() string

func (*FileSystemGetRequest) GetSrc 

func (x *FileSystemGetRequest) GetSrc() string

func (*FileSystemGetRequest) ProtoMessage 

func (*FileSystemGetRequest) ProtoMessage()

func (*FileSystemGetRequest) ProtoReflect 

func (x *FileSystemGetRequest) ProtoReflect() protoreflect.Message

func (*FileSystemGetRequest) Reset 

func (x *FileSystemGetRequest) Reset()

func (*FileSystemGetRequest) String 

func (x *FileSystemGetRequest) String() string

type FileSystemGetResponse 

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

func (*FileSystemGetResponse) Descriptor deprecated 

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

Deprecated: Use FileSystemGetResponse.ProtoReflect.Descriptor instead.

func (*FileSystemGetResponse) ProtoMessage 

func (*FileSystemGetResponse) ProtoMessage()

func (*FileSystemGetResponse) ProtoReflect 

func (x *FileSystemGetResponse) ProtoReflect() protoreflect.Message

func (*FileSystemGetResponse) Reset 

func (x *FileSystemGetResponse) Reset()

func (*FileSystemGetResponse) String 

func (x *FileSystemGetResponse) String() string

type FileSystemPutRequest 

type FileSystemPutRequest struct {
	Src  string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst  string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Copy bool   `protobuf:"varint,3,opt,name=copy,proto3" json:"copy,omitempty"`
	// contains filtered or unexported fields
}

func (*FileSystemPutRequest) Descriptor deprecated 

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

Deprecated: Use FileSystemPutRequest.ProtoReflect.Descriptor instead.

func (*FileSystemPutRequest) GetCopy 

func (x *FileSystemPutRequest) GetCopy() bool

func (*FileSystemPutRequest) GetDst 

func (x *FileSystemPutRequest) GetDst() string

func (*FileSystemPutRequest) GetSrc 

func (x *FileSystemPutRequest) GetSrc() string

func (*FileSystemPutRequest) ProtoMessage 

func (*FileSystemPutRequest) ProtoMessage()

func (*FileSystemPutRequest) ProtoReflect 

func (x *FileSystemPutRequest) ProtoReflect() protoreflect.Message

func (*FileSystemPutRequest) Reset 

func (x *FileSystemPutRequest) Reset()

func (*FileSystemPutRequest) String 

func (x *FileSystemPutRequest) String() string

type FileSystemPutResponse 

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

func (*FileSystemPutResponse) Descriptor deprecated 

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

Deprecated: Use FileSystemPutResponse.ProtoReflect.Descriptor instead.

func (*FileSystemPutResponse) ProtoMessage 

func (*FileSystemPutResponse) ProtoMessage()

func (*FileSystemPutResponse) ProtoReflect 

func (x *FileSystemPutResponse) ProtoReflect() protoreflect.Message

func (*FileSystemPutResponse) Reset 

func (x *FileSystemPutResponse) Reset()

func (*FileSystemPutResponse) String 

func (x *FileSystemPutResponse) String() string

type InfoRequest 

type InfoRequest struct {
	All  bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	Cpu  bool `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Mem  bool `protobuf:"varint,3,opt,name=mem,proto3" json:"mem,omitempty"`
	Disk bool `protobuf:"varint,4,opt,name=disk,proto3" json:"disk,omitempty"`
	Net  bool `protobuf:"varint,5,opt,name=net,proto3" json:"net,omitempty"`
	Host bool `protobuf:"varint,6,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) GetAll 

func (x *InfoRequest) GetAll() bool

func (*InfoRequest) GetCpu 

func (x *InfoRequest) GetCpu() bool

func (*InfoRequest) GetDisk 

func (x *InfoRequest) GetDisk() bool

func (*InfoRequest) GetHost 

func (x *InfoRequest) GetHost() bool

func (*InfoRequest) GetMem 

func (x *InfoRequest) GetMem() bool

func (*InfoRequest) GetNet 

func (x *InfoRequest) GetNet() bool

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

func (x *InfoRequest) ProtoReflect() protoreflect.Message

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetName 

func (x *InfoResponse) GetName() string

func (*InfoResponse) GetPayload 

func (x *InfoResponse) GetPayload() string

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

func (x *InfoResponse) ProtoReflect() protoreflect.Message

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type MarkRequest 

type MarkRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*MarkRequest) Descriptor deprecated 

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

Deprecated: Use MarkRequest.ProtoReflect.Descriptor instead.

func (*MarkRequest) GetAddr 

func (x *MarkRequest) GetAddr() string

func (*MarkRequest) GetName 

func (x *MarkRequest) GetName() string

func (*MarkRequest) ProtoMessage 

func (*MarkRequest) ProtoMessage()

func (*MarkRequest) ProtoReflect 

func (x *MarkRequest) ProtoReflect() protoreflect.Message

func (*MarkRequest) Reset 

func (x *MarkRequest) Reset()

func (*MarkRequest) String 

func (x *MarkRequest) String() string

type MarkResponse 

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

func (*MarkResponse) Descriptor deprecated 

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

Deprecated: Use MarkResponse.ProtoReflect.Descriptor instead.

func (*MarkResponse) ProtoMessage 

func (*MarkResponse) ProtoMessage()

func (*MarkResponse) ProtoReflect 

func (x *MarkResponse) ProtoReflect() protoreflect.Message

func (*MarkResponse) Reset 

func (x *MarkResponse) Reset()

func (*MarkResponse) String 

func (x *MarkResponse) String() string

type NodeInfo 

type NodeInfo struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip     string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port   int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Public bool   `protobuf:"varint,4,opt,name=public,proto3" json:"public,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetIp 

func (x *NodeInfo) GetIp() string

func (*NodeInfo) GetName 

func (x *NodeInfo) GetName() string

func (*NodeInfo) GetPort 

func (x *NodeInfo) GetPort() int32

func (*NodeInfo) GetPublic 

func (x *NodeInfo) GetPublic() bool

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type NotifyRequest 

type NotifyRequest struct {
	Sig string `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyRequest) Descriptor deprecated 

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

Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.

func (*NotifyRequest) GetSig 

func (x *NotifyRequest) GetSig() string

func (*NotifyRequest) ProtoMessage 

func (*NotifyRequest) ProtoMessage()

func (*NotifyRequest) ProtoReflect 

func (x *NotifyRequest) ProtoReflect() protoreflect.Message

func (*NotifyRequest) Reset 

func (x *NotifyRequest) Reset()

func (*NotifyRequest) String 

func (x *NotifyRequest) String() string

type NotifyResponse 

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

func (*NotifyResponse) Descriptor deprecated 

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

Deprecated: Use NotifyResponse.ProtoReflect.Descriptor instead.

func (*NotifyResponse) ProtoMessage 

func (*NotifyResponse) ProtoMessage()

func (*NotifyResponse) ProtoReflect 

func (x *NotifyResponse) ProtoReflect() protoreflect.Message

func (*NotifyResponse) Reset 

func (x *NotifyResponse) Reset()

func (*NotifyResponse) String 

func (x *NotifyResponse) String() string

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

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

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type Process 

type Process struct {
	Pid   int64  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	State int32  `protobuf:"varint,2,opt,name=state,proto3" json:"state,omitempty"`
	Spec  string `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	Cmd   string `protobuf:"bytes,4,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetCmd 

func (x *Process) GetCmd() string

func (*Process) GetPid 

func (x *Process) GetPid() int64

func (*Process) GetSpec 

func (x *Process) GetSpec() string

func (*Process) GetState 

func (x *Process) GetState() int32

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

func (x *Process) ProtoReflect() protoreflect.Message

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type ProcessFindRequest 

type ProcessFindRequest struct {
	Pid int64  `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessFindRequest) Descriptor deprecated 

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

Deprecated: Use ProcessFindRequest.ProtoReflect.Descriptor instead.

func (*ProcessFindRequest) GetCmd 

func (x *ProcessFindRequest) GetCmd() string

func (*ProcessFindRequest) GetPid 

func (x *ProcessFindRequest) GetPid() int64

func (*ProcessFindRequest) ProtoMessage 

func (*ProcessFindRequest) ProtoMessage()

func (*ProcessFindRequest) ProtoReflect 

func (x *ProcessFindRequest) ProtoReflect() protoreflect.Message

func (*ProcessFindRequest) Reset 

func (x *ProcessFindRequest) Reset()

func (*ProcessFindRequest) String 

func (x *ProcessFindRequest) String() string

type ProcessFindResponse 

type ProcessFindResponse struct {
	Res []*Process `protobuf:"bytes,1,rep,name=res,proto3" json:"res,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessFindResponse) Descriptor deprecated 

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

Deprecated: Use ProcessFindResponse.ProtoReflect.Descriptor instead.

func (*ProcessFindResponse) GetRes 

func (x *ProcessFindResponse) GetRes() []*Process

func (*ProcessFindResponse) ProtoMessage 

func (*ProcessFindResponse) ProtoMessage()

func (*ProcessFindResponse) ProtoReflect 

func (x *ProcessFindResponse) ProtoReflect() protoreflect.Message

func (*ProcessFindResponse) Reset 

func (x *ProcessFindResponse) Reset()

func (*ProcessFindResponse) String 

func (x *ProcessFindResponse) String() string

type ProcessKillRequest 

type ProcessKillRequest struct {
	Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessKillRequest) Descriptor deprecated 

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

Deprecated: Use ProcessKillRequest.ProtoReflect.Descriptor instead.

func (*ProcessKillRequest) GetPid 

func (x *ProcessKillRequest) GetPid() int64

func (*ProcessKillRequest) ProtoMessage 

func (*ProcessKillRequest) ProtoMessage()

func (*ProcessKillRequest) ProtoReflect 

func (x *ProcessKillRequest) ProtoReflect() protoreflect.Message

func (*ProcessKillRequest) Reset 

func (x *ProcessKillRequest) Reset()

func (*ProcessKillRequest) String 

func (x *ProcessKillRequest) String() string

type ProcessKillResponse 

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

func (*ProcessKillResponse) Descriptor deprecated 

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

Deprecated: Use ProcessKillResponse.ProtoReflect.Descriptor instead.

func (*ProcessKillResponse) ProtoMessage 

func (*ProcessKillResponse) ProtoMessage()

func (*ProcessKillResponse) ProtoReflect 

func (x *ProcessKillResponse) ProtoReflect() protoreflect.Message

func (*ProcessKillResponse) Reset 

func (x *ProcessKillResponse) Reset()

func (*ProcessKillResponse) String 

func (x *ProcessKillResponse) String() string

type ProcessListRequest 

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

func (*ProcessListRequest) Descriptor deprecated 

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

Deprecated: Use ProcessListRequest.ProtoReflect.Descriptor instead.

func (*ProcessListRequest) ProtoMessage 

func (*ProcessListRequest) ProtoMessage()

func (*ProcessListRequest) ProtoReflect 

func (x *ProcessListRequest) ProtoReflect() protoreflect.Message

func (*ProcessListRequest) Reset 

func (x *ProcessListRequest) Reset()

func (*ProcessListRequest) String 

func (x *ProcessListRequest) String() string

type ProcessListResponse 

type ProcessListResponse struct {
	Res []*Process `protobuf:"bytes,1,rep,name=res,proto3" json:"res,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessListResponse) Descriptor deprecated 

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

Deprecated: Use ProcessListResponse.ProtoReflect.Descriptor instead.

func (*ProcessListResponse) GetRes 

func (x *ProcessListResponse) GetRes() []*Process

func (*ProcessListResponse) ProtoMessage 

func (*ProcessListResponse) ProtoMessage()

func (*ProcessListResponse) ProtoReflect 

func (x *ProcessListResponse) ProtoReflect() protoreflect.Message

func (*ProcessListResponse) Reset 

func (x *ProcessListResponse) Reset()

func (*ProcessListResponse) String 

func (x *ProcessListResponse) String() string

type ProcessSpawnRequest 

type ProcessSpawnRequest struct {
	Type ProcessSpawnType `protobuf:"varint,1,opt,name=type,proto3,enum=Yockd.ProcessSpawnType" json:"type,omitempty"`
	Spec string           `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Cmd  string           `protobuf:"bytes,3,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessSpawnRequest) Descriptor deprecated 

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

Deprecated: Use ProcessSpawnRequest.ProtoReflect.Descriptor instead.

func (*ProcessSpawnRequest) GetCmd 

func (x *ProcessSpawnRequest) GetCmd() string

func (*ProcessSpawnRequest) GetSpec 

func (x *ProcessSpawnRequest) GetSpec() string

func (*ProcessSpawnRequest) GetType 

func (x *ProcessSpawnRequest) GetType() ProcessSpawnType

func (*ProcessSpawnRequest) ProtoMessage 

func (*ProcessSpawnRequest) ProtoMessage()

func (*ProcessSpawnRequest) ProtoReflect 

func (x *ProcessSpawnRequest) ProtoReflect() protoreflect.Message

func (*ProcessSpawnRequest) Reset 

func (x *ProcessSpawnRequest) Reset()

func (*ProcessSpawnRequest) String 

func (x *ProcessSpawnRequest) String() string

type ProcessSpawnResponse 

type ProcessSpawnResponse struct {
	Pid int64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessSpawnResponse) Descriptor deprecated 

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

Deprecated: Use ProcessSpawnResponse.ProtoReflect.Descriptor instead.

func (*ProcessSpawnResponse) GetPid 

func (x *ProcessSpawnResponse) GetPid() int64

func (*ProcessSpawnResponse) ProtoMessage 

func (*ProcessSpawnResponse) ProtoMessage()

func (*ProcessSpawnResponse) ProtoReflect 

func (x *ProcessSpawnResponse) ProtoReflect() protoreflect.Message

func (*ProcessSpawnResponse) Reset 

func (x *ProcessSpawnResponse) Reset()

func (*ProcessSpawnResponse) String 

func (x *ProcessSpawnResponse) String() string

type ProcessSpawnType 

type ProcessSpawnType int32
const (
	ProcessSpawnType_Invalid ProcessSpawnType = 0
	ProcessSpawnType_Cron    ProcessSpawnType = 1
	ProcessSpawnType_FS      ProcessSpawnType = 2
	ProcessSpawnType_Script  ProcessSpawnType = 3
)

func (ProcessSpawnType) Descriptor 

func (ProcessSpawnType) Descriptor() protoreflect.EnumDescriptor

func (ProcessSpawnType) Enum 

func (x ProcessSpawnType) Enum() *ProcessSpawnType

func (ProcessSpawnType) EnumDescriptor deprecated 

func (ProcessSpawnType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProcessSpawnType.Descriptor instead.

func (ProcessSpawnType) Number 

func (x ProcessSpawnType) Number() protoreflect.EnumNumber

func (ProcessSpawnType) String 

func (x ProcessSpawnType) String() string

func (ProcessSpawnType) Type 

func (ProcessSpawnType) Type() protoreflect.EnumType

type ProtocalType 

type ProtocalType int32
const (
	ProtocalType_Unknown      ProtocalType = 0
	ProtocalType_Establish    ProtocalType = 1
	ProtocalType_Heartbeat    ProtocalType = 2
	ProtocalType_MethodCall   ProtocalType = 3
	ProtocalType_MethodReturn ProtocalType = 4
)

func (ProtocalType) Descriptor 

func (ProtocalType) Descriptor() protoreflect.EnumDescriptor

func (ProtocalType) Enum 

func (x ProtocalType) Enum() *ProtocalType

func (ProtocalType) EnumDescriptor deprecated 

func (ProtocalType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProtocalType.Descriptor instead.

func (ProtocalType) Number 

func (x ProtocalType) Number() protoreflect.EnumNumber

func (ProtocalType) String 

func (x ProtocalType) String() string

func (ProtocalType) Type 

func (ProtocalType) Type() protoreflect.EnumType

type RegisterRequest 

type RegisterRequest struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetAddrs 

func (x *RegisterRequest) GetAddrs() []string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

func (x *RegisterRequest) ProtoReflect() protoreflect.Message

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetAddrs 

func (x *RegisterResponse) GetAddrs() []string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

func (x *RegisterResponse) ProtoReflect() protoreflect.Message

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type SignalClearRequest 

type SignalClearRequest struct {
	Sigs []string `protobuf:"bytes,1,rep,name=sigs,proto3" json:"sigs,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalClearRequest) Descriptor deprecated 

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

Deprecated: Use SignalClearRequest.ProtoReflect.Descriptor instead.

func (*SignalClearRequest) GetSigs 

func (x *SignalClearRequest) GetSigs() []string

func (*SignalClearRequest) ProtoMessage 

func (*SignalClearRequest) ProtoMessage()

func (*SignalClearRequest) ProtoReflect 

func (x *SignalClearRequest) ProtoReflect() protoreflect.Message

func (*SignalClearRequest) Reset 

func (x *SignalClearRequest) Reset()

func (*SignalClearRequest) String 

func (x *SignalClearRequest) String() string

type SignalClearResponse 

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

func (*SignalClearResponse) Descriptor deprecated 

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

Deprecated: Use SignalClearResponse.ProtoReflect.Descriptor instead.

func (*SignalClearResponse) ProtoMessage 

func (*SignalClearResponse) ProtoMessage()

func (*SignalClearResponse) ProtoReflect 

func (x *SignalClearResponse) ProtoReflect() protoreflect.Message

func (*SignalClearResponse) Reset 

func (x *SignalClearResponse) Reset()

func (*SignalClearResponse) String 

func (x *SignalClearResponse) String() string

type SignalInfoRequest 

type SignalInfoRequest struct {
	Sig string `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalInfoRequest) Descriptor deprecated 

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

Deprecated: Use SignalInfoRequest.ProtoReflect.Descriptor instead.

func (*SignalInfoRequest) GetSig 

func (x *SignalInfoRequest) GetSig() string

func (*SignalInfoRequest) ProtoMessage 

func (*SignalInfoRequest) ProtoMessage()

func (*SignalInfoRequest) ProtoReflect 

func (x *SignalInfoRequest) ProtoReflect() protoreflect.Message

func (*SignalInfoRequest) Reset 

func (x *SignalInfoRequest) Reset()

func (*SignalInfoRequest) String 

func (x *SignalInfoRequest) String() string

type SignalInfoResponse 

type SignalInfoResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Exist  bool `protobuf:"varint,2,opt,name=exist,proto3" json:"exist,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalInfoResponse) Descriptor deprecated 

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

Deprecated: Use SignalInfoResponse.ProtoReflect.Descriptor instead.

func (*SignalInfoResponse) GetExist 

func (x *SignalInfoResponse) GetExist() bool

func (*SignalInfoResponse) GetStatus 

func (x *SignalInfoResponse) GetStatus() bool

func (*SignalInfoResponse) ProtoMessage 

func (*SignalInfoResponse) ProtoMessage()

func (*SignalInfoResponse) ProtoReflect 

func (x *SignalInfoResponse) ProtoReflect() protoreflect.Message

func (*SignalInfoResponse) Reset 

func (x *SignalInfoResponse) Reset()

func (*SignalInfoResponse) String 

func (x *SignalInfoResponse) String() string

type SignalListRequest 

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

func (*SignalListRequest) Descriptor deprecated 

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

Deprecated: Use SignalListRequest.ProtoReflect.Descriptor instead.

func (*SignalListRequest) ProtoMessage 

func (*SignalListRequest) ProtoMessage()

func (*SignalListRequest) ProtoReflect 

func (x *SignalListRequest) ProtoReflect() protoreflect.Message

func (*SignalListRequest) Reset 

func (x *SignalListRequest) Reset()

func (*SignalListRequest) String 

func (x *SignalListRequest) String() string

type SignalListResponse 

type SignalListResponse struct {
	Sigs []string `protobuf:"bytes,1,rep,name=sigs,proto3" json:"sigs,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalListResponse) Descriptor deprecated 

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

Deprecated: Use SignalListResponse.ProtoReflect.Descriptor instead.

func (*SignalListResponse) GetSigs 

func (x *SignalListResponse) GetSigs() []string

func (*SignalListResponse) ProtoMessage 

func (*SignalListResponse) ProtoMessage()

func (*SignalListResponse) ProtoReflect 

func (x *SignalListResponse) ProtoReflect() protoreflect.Message

func (*SignalListResponse) Reset 

func (x *SignalListResponse) Reset()

func (*SignalListResponse) String 

func (x *SignalListResponse) String() string

type TunnelRequest 

type TunnelRequest struct {
	Type ProtocalType `protobuf:"varint,1,opt,name=type,proto3,enum=Yockd.ProtocalType" json:"type,omitempty"`
	Body string       `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Id   int64        `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelRequest) Descriptor deprecated 

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

Deprecated: Use TunnelRequest.ProtoReflect.Descriptor instead.

func (*TunnelRequest) GetBody 

func (x *TunnelRequest) GetBody() string

func (*TunnelRequest) GetId 

func (x *TunnelRequest) GetId() int64

func (*TunnelRequest) GetType 

func (x *TunnelRequest) GetType() ProtocalType

func (*TunnelRequest) ProtoMessage 

func (*TunnelRequest) ProtoMessage()

func (*TunnelRequest) ProtoReflect 

func (x *TunnelRequest) ProtoReflect() protoreflect.Message

func (*TunnelRequest) Reset 

func (x *TunnelRequest) Reset()

func (*TunnelRequest) String 

func (x *TunnelRequest) String() string

type TunnelResponse 

type TunnelResponse struct {
	Type ProtocalType `protobuf:"varint,1,opt,name=type,proto3,enum=Yockd.ProtocalType" json:"type,omitempty"`
	Body string       `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	Id   int64        `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TunnelResponse) Descriptor deprecated 

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

Deprecated: Use TunnelResponse.ProtoReflect.Descriptor instead.

func (*TunnelResponse) GetBody 

func (x *TunnelResponse) GetBody() string

func (*TunnelResponse) GetId 

func (x *TunnelResponse) GetId() int64

func (*TunnelResponse) GetType 

func (x *TunnelResponse) GetType() ProtocalType

func (*TunnelResponse) ProtoMessage 

func (*TunnelResponse) ProtoMessage()

func (*TunnelResponse) ProtoReflect 

func (x *TunnelResponse) ProtoReflect() protoreflect.Message

func (*TunnelResponse) Reset 

func (x *TunnelResponse) Reset()

func (*TunnelResponse) String 

func (x *TunnelResponse) String() string

type UnimplementedYockDaemonServer 

type UnimplementedYockDaemonServer struct {
}

UnimplementedYockDaemonServer must be embedded to have forward compatible implementations.

func (*UnimplementedYockDaemonServer) Call 

func (*UnimplementedYockDaemonServer) Call(context.Context, *CallRequest) (*CallResponse, error)

func (*UnimplementedYockDaemonServer) Dial 

func (*UnimplementedYockDaemonServer) Dial(context.Context, *DialRequest) (*DialResponse, error)

func (*UnimplementedYockDaemonServer) FileSystemDownload 

func (*UnimplementedYockDaemonServer) FileSystemDownload(YockDaemon_FileSystemDownloadServer) error

func (*UnimplementedYockDaemonServer) FileSystemGet 

func (*UnimplementedYockDaemonServer) FileSystemGet(context.Context, *FileSystemGetRequest) (*FileSystemGetResponse, error)

func (*UnimplementedYockDaemonServer) FileSystemPut 

func (*UnimplementedYockDaemonServer) FileSystemPut(context.Context, *FileSystemPutRequest) (*FileSystemPutResponse, error)

func (*UnimplementedYockDaemonServer) Info 

func (*UnimplementedYockDaemonServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (*UnimplementedYockDaemonServer) Mark 

func (*UnimplementedYockDaemonServer) Mark(context.Context, *MarkRequest) (*MarkResponse, error)

func (*UnimplementedYockDaemonServer) Ping 

func (*UnimplementedYockDaemonServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (*UnimplementedYockDaemonServer) ProcessFind 

func (*UnimplementedYockDaemonServer) ProcessFind(context.Context, *ProcessFindRequest) (*ProcessFindResponse, error)

func (*UnimplementedYockDaemonServer) ProcessKill 

func (*UnimplementedYockDaemonServer) ProcessKill(context.Context, *ProcessKillRequest) (*ProcessKillResponse, error)

func (*UnimplementedYockDaemonServer) ProcessList 

func (*UnimplementedYockDaemonServer) ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)

func (*UnimplementedYockDaemonServer) ProcessSpawn 

func (*UnimplementedYockDaemonServer) ProcessSpawn(context.Context, *ProcessSpawnRequest) (*ProcessSpawnResponse, error)

func (*UnimplementedYockDaemonServer) Register 

func (*UnimplementedYockDaemonServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (*UnimplementedYockDaemonServer) SignalClear 

func (*UnimplementedYockDaemonServer) SignalClear(context.Context, *SignalClearRequest) (*SignalClearResponse, error)

func (*UnimplementedYockDaemonServer) SignalInfo 

func (*UnimplementedYockDaemonServer) SignalInfo(context.Context, *SignalInfoRequest) (*SignalInfoResponse, error)

func (*UnimplementedYockDaemonServer) SignalList 

func (*UnimplementedYockDaemonServer) SignalList(context.Context, *SignalListRequest) (*SignalListResponse, error)

func (*UnimplementedYockDaemonServer) SignalNotify 

func (*UnimplementedYockDaemonServer) SignalNotify(context.Context, *NotifyRequest) (*NotifyResponse, error)

func (*UnimplementedYockDaemonServer) SignalWait 

func (*UnimplementedYockDaemonServer) SignalWait(context.Context, *WaitRequest) (*WaitResponse, error)

func (*UnimplementedYockDaemonServer) Tunnel 

func (*UnimplementedYockDaemonServer) Tunnel(YockDaemon_TunnelServer) error

func (*UnimplementedYockDaemonServer) Unregister 

func (*UnimplementedYockDaemonServer) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)

func (*UnimplementedYockDaemonServer) Upload 

func (*UnimplementedYockDaemonServer) Upload(context.Context, *UploadRequest) (*UploadResponse, error)

type UnregisterRequest 

type UnregisterRequest struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterRequest.ProtoReflect.Descriptor instead.

func (*UnregisterRequest) GetAddrs 

func (x *UnregisterRequest) GetAddrs() []string

func (*UnregisterRequest) ProtoMessage 

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) ProtoReflect 

func (x *UnregisterRequest) ProtoReflect() protoreflect.Message

func (*UnregisterRequest) Reset 

func (x *UnregisterRequest) Reset()

func (*UnregisterRequest) String 

func (x *UnregisterRequest) String() string

type UnregisterResponse 

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

func (*UnregisterResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterResponse.ProtoReflect.Descriptor instead.

func (*UnregisterResponse) ProtoMessage 

func (*UnregisterResponse) ProtoMessage()

func (*UnregisterResponse) ProtoReflect 

func (x *UnregisterResponse) ProtoReflect() protoreflect.Message

func (*UnregisterResponse) Reset 

func (x *UnregisterResponse) Reset()

func (*UnregisterResponse) String 

func (x *UnregisterResponse) String() string

type UploadRequest 

type UploadRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Owner    string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Size     int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Hash     string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	CreateAt string `protobuf:"bytes,5,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadRequest) Descriptor deprecated 

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

Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.

func (*UploadRequest) GetCreateAt 

func (x *UploadRequest) GetCreateAt() string

func (*UploadRequest) GetFilename 

func (x *UploadRequest) GetFilename() string

func (*UploadRequest) GetHash 

func (x *UploadRequest) GetHash() string

func (*UploadRequest) GetOwner 

func (x *UploadRequest) GetOwner() string

func (*UploadRequest) GetSize 

func (x *UploadRequest) GetSize() int64

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) ProtoReflect 

func (x *UploadRequest) ProtoReflect() protoreflect.Message

func (*UploadRequest) Reset 

func (x *UploadRequest) Reset()

func (*UploadRequest) String 

func (x *UploadRequest) String() string

type UploadResponse 

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

func (*UploadResponse) Descriptor deprecated 

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

Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) ProtoReflect 

func (x *UploadResponse) ProtoReflect() protoreflect.Message

func (*UploadResponse) Reset 

func (x *UploadResponse) Reset()

func (*UploadResponse) String 

func (x *UploadResponse) String() string

type WaitRequest 

type WaitRequest struct {
	Sig string `protobuf:"bytes,1,opt,name=sig,proto3" json:"sig,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitRequest) Descriptor deprecated 

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

Deprecated: Use WaitRequest.ProtoReflect.Descriptor instead.

func (*WaitRequest) GetSig 

func (x *WaitRequest) GetSig() string

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) ProtoReflect 

func (x *WaitRequest) ProtoReflect() protoreflect.Message

func (*WaitRequest) Reset 

func (x *WaitRequest) Reset()

func (*WaitRequest) String 

func (x *WaitRequest) String() string

type WaitResponse 

type WaitResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitResponse) Descriptor deprecated 

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

Deprecated: Use WaitResponse.ProtoReflect.Descriptor instead.

func (*WaitResponse) GetOk 

func (x *WaitResponse) GetOk() bool

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) ProtoReflect 

func (x *WaitResponse) ProtoReflect() protoreflect.Message

func (*WaitResponse) Reset 

func (x *WaitResponse) Reset()

func (*WaitResponse) String 

func (x *WaitResponse) String() string

type YockDaemonClient 

type YockDaemonClient interface {
	// Ping is used to detect whether the connection is available
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Wait is used to request signal from the daemon
	SignalWait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
	// Notify pushes signal to Daemon
	SignalNotify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyResponse, error)
	SignalList(ctx context.Context, in *SignalListRequest, opts ...grpc.CallOption) (*SignalListResponse, error)
	SignalClear(ctx context.Context, in *SignalClearRequest, opts ...grpc.CallOption) (*SignalClearResponse, error)
	// SignalInfo returns signal's stauts to be specified.
	SignalInfo(ctx context.Context, in *SignalInfoRequest, opts ...grpc.CallOption) (*SignalInfoResponse, error)
	// Upload pushes file information to peers so that peers can download files
	Upload(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error)
	// Register tells the daemon the address of the peer.
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Unregister tells the daemon to remove the peer according to addrs.
	Unregister(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterResponse, 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.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	FileSystemPut(ctx context.Context, in *FileSystemPutRequest, opts ...grpc.CallOption) (*FileSystemPutResponse, error)
	FileSystemGet(ctx context.Context, in *FileSystemGetRequest, opts ...grpc.CallOption) (*FileSystemGetResponse, error)
	// FileSystemDownload file in other peer
	FileSystemDownload(ctx context.Context, opts ...grpc.CallOption) (YockDaemon_FileSystemDownloadClient, error)
	Dial(ctx context.Context, in *DialRequest, opts ...grpc.CallOption) (*DialResponse, error)
	Call(ctx context.Context, in *CallRequest, opts ...grpc.CallOption) (*CallResponse, error)
	Tunnel(ctx context.Context, opts ...grpc.CallOption) (YockDaemon_TunnelClient, error)
	Mark(ctx context.Context, in *MarkRequest, opts ...grpc.CallOption) (*MarkResponse, error)
	ProcessSpawn(ctx context.Context, in *ProcessSpawnRequest, opts ...grpc.CallOption) (*ProcessSpawnResponse, error)
	ProcessFind(ctx context.Context, in *ProcessFindRequest, opts ...grpc.CallOption) (*ProcessFindResponse, error)
	ProcessList(ctx context.Context, in *ProcessListRequest, opts ...grpc.CallOption) (*ProcessListResponse, error)
	ProcessKill(ctx context.Context, in *ProcessKillRequest, opts ...grpc.CallOption) (*ProcessKillResponse, error)
}

YockDaemonClient is the client API for YockDaemon service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewYockDaemonClient 

func NewYockDaemonClient(cc grpc.ClientConnInterface) YockDaemonClient

type YockDaemonServer 

type YockDaemonServer interface {
	// Ping is used to detect whether the connection is available
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Wait is used to request signal from the daemon
	SignalWait(context.Context, *WaitRequest) (*WaitResponse, error)
	// Notify pushes signal to Daemon
	SignalNotify(context.Context, *NotifyRequest) (*NotifyResponse, error)
	SignalList(context.Context, *SignalListRequest) (*SignalListResponse, error)
	SignalClear(context.Context, *SignalClearRequest) (*SignalClearResponse, error)
	// SignalInfo returns signal's stauts to be specified.
	SignalInfo(context.Context, *SignalInfoRequest) (*SignalInfoResponse, error)
	// Upload pushes file information to peers so that peers can download files
	Upload(context.Context, *UploadRequest) (*UploadResponse, error)
	// Register tells the daemon the address of the peer.
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Unregister tells the daemon to remove the peer according to addrs.
	Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, 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.
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	FileSystemPut(context.Context, *FileSystemPutRequest) (*FileSystemPutResponse, error)
	FileSystemGet(context.Context, *FileSystemGetRequest) (*FileSystemGetResponse, error)
	// FileSystemDownload file in other peer
	FileSystemDownload(YockDaemon_FileSystemDownloadServer) error
	Dial(context.Context, *DialRequest) (*DialResponse, error)
	Call(context.Context, *CallRequest) (*CallResponse, error)
	Tunnel(YockDaemon_TunnelServer) error
	Mark(context.Context, *MarkRequest) (*MarkResponse, error)
	ProcessSpawn(context.Context, *ProcessSpawnRequest) (*ProcessSpawnResponse, error)
	ProcessFind(context.Context, *ProcessFindRequest) (*ProcessFindResponse, error)
	ProcessList(context.Context, *ProcessListRequest) (*ProcessListResponse, error)
	ProcessKill(context.Context, *ProcessKillRequest) (*ProcessKillResponse, error)
	// contains filtered or unexported methods
}

YockDaemonServer is the server API for YockDaemon service. All implementations must embed UnimplementedYockDaemonServer for forward compatibility

type YockDaemon_FileSystemDownloadClient 

type YockDaemon_FileSystemDownloadClient interface {
	Send(*FileSystemDownloadRequest) error
	Recv() (*FileSystemDownloadResponse, error)
	grpc.ClientStream
}

type YockDaemon_FileSystemDownloadServer 

type YockDaemon_FileSystemDownloadServer interface {
	Send(*FileSystemDownloadResponse) error
	Recv() (*FileSystemDownloadRequest, error)
	grpc.ServerStream
}

type YockDaemon_TunnelClient 

type YockDaemon_TunnelClient interface {
	Send(*TunnelRequest) error
	Recv() (*TunnelResponse, error)
	grpc.ClientStream
}

type YockDaemon_TunnelServer 

type YockDaemon_TunnelServer interface {
	Send(*TunnelResponse) error
	Recv() (*TunnelRequest, error)
	grpc.ServerStream
}

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.