Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterListenerServiceServer(s grpc.ServiceRegistrar, srv ListenerServiceServer)
- type GetTaskRequest
- type GetTaskResponse
- func (*GetTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskResponse) GetBody() isGetTaskResponse_Body
- func (x *GetTaskResponse) GetCap() uint32
- func (x *GetTaskResponse) GetCat() *v1.CapCat
- func (x *GetTaskResponse) GetCd() *v1.CapCd
- func (x *GetTaskResponse) GetCp() *v1.CapCp
- func (x *GetTaskResponse) GetDestroy() *v1.CapDestroy
- func (x *GetTaskResponse) GetDownload() *v1.CapDownload
- func (x *GetTaskResponse) GetExec() *v1.CapExec
- func (x *GetTaskResponse) GetExecAssembly() *v1.CapExecAssembly
- func (x *GetTaskResponse) GetExecDetach() *v1.CapExecDetach
- func (x *GetTaskResponse) GetExit() *v1.CapExit
- func (x *GetTaskResponse) GetId() int64
- func (x *GetTaskResponse) GetJobkill() *v1.CapJobkill
- func (x *GetTaskResponse) GetJobs() *v1.CapJobs
- func (x *GetTaskResponse) GetKill() *v1.CapKill
- func (x *GetTaskResponse) GetLs() *v1.CapLs
- func (x *GetTaskResponse) GetMkdir() *v1.CapMkdir
- func (x *GetTaskResponse) GetMv() *v1.CapMv
- func (x *GetTaskResponse) GetPause() *v1.CapPause
- func (x *GetTaskResponse) GetPpid() *v1.CapPpid
- func (x *GetTaskResponse) GetPs() *v1.CapPs
- func (x *GetTaskResponse) GetPwd() *v1.CapPwd
- func (x *GetTaskResponse) GetRm() *v1.CapRm
- func (x *GetTaskResponse) GetShell() *v1.CapShell
- func (x *GetTaskResponse) GetShellcodeInjection() *v1.CapShellcodeInjection
- func (x *GetTaskResponse) GetSleep() *v1.CapSleep
- func (x *GetTaskResponse) GetUpload() *v1.CapUpload
- func (x *GetTaskResponse) GetWhoami() *v1.CapWhoami
- func (*GetTaskResponse) ProtoMessage()
- func (x *GetTaskResponse) ProtoReflect() protoreflect.Message
- func (x *GetTaskResponse) Reset()
- func (x *GetTaskResponse) String() string
- type GetTaskResponse_Cat
- type GetTaskResponse_Cd
- type GetTaskResponse_Cp
- type GetTaskResponse_Destroy
- type GetTaskResponse_Download
- type GetTaskResponse_Exec
- type GetTaskResponse_ExecAssembly
- type GetTaskResponse_ExecDetach
- type GetTaskResponse_Exit
- type GetTaskResponse_Jobkill
- type GetTaskResponse_Jobs
- type GetTaskResponse_Kill
- type GetTaskResponse_Ls
- type GetTaskResponse_Mkdir
- type GetTaskResponse_Mv
- type GetTaskResponse_Pause
- type GetTaskResponse_Ppid
- type GetTaskResponse_Ps
- type GetTaskResponse_Pwd
- type GetTaskResponse_Rm
- type GetTaskResponse_Shell
- type GetTaskResponse_ShellcodeInjection
- type GetTaskResponse_Sleep
- type GetTaskResponse_Upload
- type GetTaskResponse_Whoami
- type ListenerServiceClient
- type ListenerServiceServer
- type PutResultRequest
- func (*PutResultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PutResultRequest) GetId() uint32
- func (x *PutResultRequest) GetOutput() *wrapperspb.BytesValue
- func (x *PutResultRequest) GetStatus() uint32
- func (x *PutResultRequest) GetTid() int64
- func (*PutResultRequest) ProtoMessage()
- func (x *PutResultRequest) ProtoReflect() protoreflect.Message
- func (x *PutResultRequest) Reset()
- func (x *PutResultRequest) String() string
- type PutResultResponse
- type RegisterAgentRequest
- func (*RegisterAgentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAgentRequest) GetArch() uint32
- func (x *RegisterAgentRequest) GetCaps() uint32
- func (x *RegisterAgentRequest) GetDomain() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetExtIp() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetHostname() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetId() uint32
- func (x *RegisterAgentRequest) GetIntIp() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetJitter() uint32
- func (x *RegisterAgentRequest) GetOs() uint32
- func (x *RegisterAgentRequest) GetOsMeta() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetPid() *wrapperspb.UInt64Value
- func (x *RegisterAgentRequest) GetPrivileged() *wrapperspb.BoolValue
- func (x *RegisterAgentRequest) GetProcName() *wrapperspb.StringValue
- func (x *RegisterAgentRequest) GetSleep() uint32
- func (x *RegisterAgentRequest) GetUsername() *wrapperspb.StringValue
- func (*RegisterAgentRequest) ProtoMessage()
- func (x *RegisterAgentRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterAgentRequest) Reset()
- func (x *RegisterAgentRequest) String() string
- type RegisterAgentResponse
- type UnimplementedListenerServiceServer
- func (UnimplementedListenerServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
- func (UnimplementedListenerServiceServer) PutResult(context.Context, *PutResultRequest) (*PutResultResponse, error)
- func (UnimplementedListenerServiceServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
- func (UnimplementedListenerServiceServer) UpdateListener(context.Context, *UpdateListenerRequest) (*UpdateListenerResponse, error)
- type UnsafeListenerServiceServer
- type UpdateListenerRequest
- func (*UpdateListenerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateListenerRequest) GetIp() *wrapperspb.StringValue
- func (x *UpdateListenerRequest) GetName() *wrapperspb.StringValue
- func (x *UpdateListenerRequest) GetPort() *wrapperspb.UInt32Value
- func (*UpdateListenerRequest) ProtoMessage()
- func (x *UpdateListenerRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateListenerRequest) Reset()
- func (x *UpdateListenerRequest) String() string
- type UpdateListenerResponse
Constants ¶
const ( ListenerService_UpdateListener_FullMethodName = "/listener.v1.ListenerService/UpdateListener" ListenerService_RegisterAgent_FullMethodName = "/listener.v1.ListenerService/RegisterAgent" ListenerService_GetTask_FullMethodName = "/listener.v1.ListenerService/GetTask" ListenerService_PutResult_FullMethodName = "/listener.v1.ListenerService/PutResult" )
Variables ¶
var File_listener_v1_listener_proto protoreflect.FileDescriptor
var ListenerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "listener.v1.ListenerService", HandlerType: (*ListenerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateListener", Handler: _ListenerService_UpdateListener_Handler, }, { MethodName: "RegisterAgent", Handler: _ListenerService_RegisterAgent_Handler, }, { MethodName: "GetTask", Handler: _ListenerService_GetTask_Handler, }, { MethodName: "PutResult", Handler: _ListenerService_PutResult_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "listener/v1/listener.proto", }
ListenerService_ServiceDesc is the grpc.ServiceDesc for ListenerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterListenerServiceServer ¶
func RegisterListenerServiceServer(s grpc.ServiceRegistrar, srv ListenerServiceServer)
Types ¶
type GetTaskRequest ¶
type GetTaskRequest struct { // [MANDATORY] Agent's ID Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
--> GetTask
func (*GetTaskRequest) Descriptor
deprecated
func (*GetTaskRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.
func (*GetTaskRequest) GetId ¶
func (x *GetTaskRequest) GetId() uint32
func (*GetTaskRequest) ProtoMessage ¶
func (*GetTaskRequest) ProtoMessage()
func (*GetTaskRequest) ProtoReflect ¶
func (x *GetTaskRequest) ProtoReflect() protoreflect.Message
func (*GetTaskRequest) Reset ¶
func (x *GetTaskRequest) Reset()
func (*GetTaskRequest) String ¶
func (x *GetTaskRequest) String() string
type GetTaskResponse ¶
type GetTaskResponse struct { // [MANDATORY] Task ID. Generated by server and must be presents // to save task's output results Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // [MANDATORY] Capability value Cap uint32 `protobuf:"varint,2,opt,name=cap,proto3" json:"cap,omitempty"` // [MANDATORY] Capability's task body // // Types that are valid to be assigned to Body: // // *GetTaskResponse_Sleep // *GetTaskResponse_Ls // *GetTaskResponse_Pwd // *GetTaskResponse_Cd // *GetTaskResponse_Whoami // *GetTaskResponse_Ps // *GetTaskResponse_Cat // *GetTaskResponse_Exec // *GetTaskResponse_Cp // *GetTaskResponse_Jobs // *GetTaskResponse_Jobkill // *GetTaskResponse_Kill // *GetTaskResponse_Mv // *GetTaskResponse_Mkdir // *GetTaskResponse_Rm // *GetTaskResponse_ExecAssembly // *GetTaskResponse_ShellcodeInjection // *GetTaskResponse_Download // *GetTaskResponse_Upload // *GetTaskResponse_Pause // *GetTaskResponse_Destroy // *GetTaskResponse_ExecDetach // *GetTaskResponse_Shell // *GetTaskResponse_Ppid // *GetTaskResponse_Exit Body isGetTaskResponse_Body `protobuf_oneof:"body"` // contains filtered or unexported fields }
func (*GetTaskResponse) Descriptor
deprecated
func (*GetTaskResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTaskResponse.ProtoReflect.Descriptor instead.
func (*GetTaskResponse) GetBody ¶
func (x *GetTaskResponse) GetBody() isGetTaskResponse_Body
func (*GetTaskResponse) GetCap ¶
func (x *GetTaskResponse) GetCap() uint32
func (*GetTaskResponse) GetCat ¶
func (x *GetTaskResponse) GetCat() *v1.CapCat
func (*GetTaskResponse) GetCd ¶
func (x *GetTaskResponse) GetCd() *v1.CapCd
func (*GetTaskResponse) GetCp ¶
func (x *GetTaskResponse) GetCp() *v1.CapCp
func (*GetTaskResponse) GetDestroy ¶
func (x *GetTaskResponse) GetDestroy() *v1.CapDestroy
func (*GetTaskResponse) GetDownload ¶
func (x *GetTaskResponse) GetDownload() *v1.CapDownload
func (*GetTaskResponse) GetExec ¶
func (x *GetTaskResponse) GetExec() *v1.CapExec
func (*GetTaskResponse) GetExecAssembly ¶
func (x *GetTaskResponse) GetExecAssembly() *v1.CapExecAssembly
func (*GetTaskResponse) GetExecDetach ¶
func (x *GetTaskResponse) GetExecDetach() *v1.CapExecDetach
func (*GetTaskResponse) GetExit ¶
func (x *GetTaskResponse) GetExit() *v1.CapExit
func (*GetTaskResponse) GetId ¶
func (x *GetTaskResponse) GetId() int64
func (*GetTaskResponse) GetJobkill ¶
func (x *GetTaskResponse) GetJobkill() *v1.CapJobkill
func (*GetTaskResponse) GetJobs ¶
func (x *GetTaskResponse) GetJobs() *v1.CapJobs
func (*GetTaskResponse) GetKill ¶
func (x *GetTaskResponse) GetKill() *v1.CapKill
func (*GetTaskResponse) GetLs ¶
func (x *GetTaskResponse) GetLs() *v1.CapLs
func (*GetTaskResponse) GetMkdir ¶
func (x *GetTaskResponse) GetMkdir() *v1.CapMkdir
func (*GetTaskResponse) GetMv ¶
func (x *GetTaskResponse) GetMv() *v1.CapMv
func (*GetTaskResponse) GetPause ¶
func (x *GetTaskResponse) GetPause() *v1.CapPause
func (*GetTaskResponse) GetPpid ¶
func (x *GetTaskResponse) GetPpid() *v1.CapPpid
func (*GetTaskResponse) GetPs ¶
func (x *GetTaskResponse) GetPs() *v1.CapPs
func (*GetTaskResponse) GetPwd ¶
func (x *GetTaskResponse) GetPwd() *v1.CapPwd
func (*GetTaskResponse) GetRm ¶
func (x *GetTaskResponse) GetRm() *v1.CapRm
func (*GetTaskResponse) GetShell ¶
func (x *GetTaskResponse) GetShell() *v1.CapShell
func (*GetTaskResponse) GetShellcodeInjection ¶
func (x *GetTaskResponse) GetShellcodeInjection() *v1.CapShellcodeInjection
func (*GetTaskResponse) GetSleep ¶
func (x *GetTaskResponse) GetSleep() *v1.CapSleep
func (*GetTaskResponse) GetUpload ¶
func (x *GetTaskResponse) GetUpload() *v1.CapUpload
func (*GetTaskResponse) GetWhoami ¶
func (x *GetTaskResponse) GetWhoami() *v1.CapWhoami
func (*GetTaskResponse) ProtoMessage ¶
func (*GetTaskResponse) ProtoMessage()
func (*GetTaskResponse) ProtoReflect ¶
func (x *GetTaskResponse) ProtoReflect() protoreflect.Message
func (*GetTaskResponse) Reset ¶
func (x *GetTaskResponse) Reset()
func (*GetTaskResponse) String ¶
func (x *GetTaskResponse) String() string
type GetTaskResponse_Cat ¶
type GetTaskResponse_Cd ¶
type GetTaskResponse_Cp ¶
type GetTaskResponse_Destroy ¶
type GetTaskResponse_Destroy struct {
Destroy *v1.CapDestroy `protobuf:"bytes,23,opt,name=destroy,proto3,oneof"`
}
type GetTaskResponse_Download ¶
type GetTaskResponse_Download struct {
Download *v1.CapDownload `protobuf:"bytes,20,opt,name=download,proto3,oneof"`
}
type GetTaskResponse_Exec ¶
type GetTaskResponse_ExecAssembly ¶
type GetTaskResponse_ExecAssembly struct {
ExecAssembly *v1.CapExecAssembly `protobuf:"bytes,18,opt,name=exec_assembly,json=execAssembly,proto3,oneof"`
}
type GetTaskResponse_ExecDetach ¶
type GetTaskResponse_ExecDetach struct {
ExecDetach *v1.CapExecDetach `protobuf:"bytes,24,opt,name=exec_detach,json=execDetach,proto3,oneof"`
}
type GetTaskResponse_Exit ¶
type GetTaskResponse_Jobkill ¶
type GetTaskResponse_Jobkill struct {
Jobkill *v1.CapJobkill `protobuf:"bytes,13,opt,name=jobkill,proto3,oneof"`
}
type GetTaskResponse_Jobs ¶
type GetTaskResponse_Kill ¶
type GetTaskResponse_Ls ¶
type GetTaskResponse_Mkdir ¶
type GetTaskResponse_Mv ¶
type GetTaskResponse_Pause ¶
type GetTaskResponse_Ppid ¶
type GetTaskResponse_Ps ¶
type GetTaskResponse_Pwd ¶
type GetTaskResponse_Rm ¶
type GetTaskResponse_Shell ¶
type GetTaskResponse_ShellcodeInjection ¶
type GetTaskResponse_ShellcodeInjection struct {
ShellcodeInjection *v1.CapShellcodeInjection `protobuf:"bytes,19,opt,name=shellcode_injection,json=shellcodeInjection,proto3,oneof"`
}
type GetTaskResponse_Sleep ¶
type GetTaskResponse_Upload ¶
type GetTaskResponse_Whoami ¶
type ListenerServiceClient ¶
type ListenerServiceClient interface { // Update listener's information. Can be used to set location and meta infromation // of where listener works UpdateListener(ctx context.Context, in *UpdateListenerRequest, opts ...grpc.CallOption) (*UpdateListenerResponse, error) // Register new agent with collected information from compromised OS RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error) // Get task for agent from queue GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error) // Save task's results PutResult(ctx context.Context, in *PutResultRequest, opts ...grpc.CallOption) (*PutResultResponse, error) }
ListenerServiceClient is the client API for ListenerService 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 NewListenerServiceClient ¶
func NewListenerServiceClient(cc grpc.ClientConnInterface) ListenerServiceClient
type ListenerServiceServer ¶
type ListenerServiceServer interface { // Update listener's information. Can be used to set location and meta infromation // of where listener works UpdateListener(context.Context, *UpdateListenerRequest) (*UpdateListenerResponse, error) // Register new agent with collected information from compromised OS RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error) // Get task for agent from queue GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error) // Save task's results PutResult(context.Context, *PutResultRequest) (*PutResultResponse, error) // contains filtered or unexported methods }
ListenerServiceServer is the server API for ListenerService service. All implementations must embed UnimplementedListenerServiceServer for forward compatibility.
type PutResultRequest ¶
type PutResultRequest struct { // [MANDATORY] Agent's ID Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // [MANDATORY] Tasks's ID Tid int64 `protobuf:"varint,2,opt,name=tid,proto3" json:"tid,omitempty"` // Binary output of task's result Output *wrapperspb.BytesValue `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"` // [MANDATORY] Tasks's status. May be "IN PROGRESS" in case of long-living task Status uint32 `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
--> PutResult
func (*PutResultRequest) Descriptor
deprecated
func (*PutResultRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutResultRequest.ProtoReflect.Descriptor instead.
func (*PutResultRequest) GetId ¶
func (x *PutResultRequest) GetId() uint32
func (*PutResultRequest) GetOutput ¶
func (x *PutResultRequest) GetOutput() *wrapperspb.BytesValue
func (*PutResultRequest) GetStatus ¶
func (x *PutResultRequest) GetStatus() uint32
func (*PutResultRequest) GetTid ¶
func (x *PutResultRequest) GetTid() int64
func (*PutResultRequest) ProtoMessage ¶
func (*PutResultRequest) ProtoMessage()
func (*PutResultRequest) ProtoReflect ¶
func (x *PutResultRequest) ProtoReflect() protoreflect.Message
func (*PutResultRequest) Reset ¶
func (x *PutResultRequest) Reset()
func (*PutResultRequest) String ¶
func (x *PutResultRequest) String() string
type PutResultResponse ¶
type PutResultResponse struct {
// contains filtered or unexported fields
}
func (*PutResultResponse) Descriptor
deprecated
func (*PutResultResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutResultResponse.ProtoReflect.Descriptor instead.
func (*PutResultResponse) ProtoMessage ¶
func (*PutResultResponse) ProtoMessage()
func (*PutResultResponse) ProtoReflect ¶
func (x *PutResultResponse) ProtoReflect() protoreflect.Message
func (*PutResultResponse) Reset ¶
func (x *PutResultResponse) Reset()
func (*PutResultResponse) String ¶
func (x *PutResultResponse) String() string
type RegisterAgentRequest ¶
type RegisterAgentRequest struct { // [MANDATORY] Agent's id which must be generated by itself on start Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // External IP address of agent ExtIp *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=ext_ip,json=extIp,proto3" json:"ext_ip,omitempty"` // Internal IP address of agent IntIp *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=int_ip,json=intIp,proto3" json:"int_ip,omitempty"` // [MANDATORY] Operating system type Os uint32 `protobuf:"varint,4,opt,name=os,proto3" json:"os,omitempty"` // Operating system meta information (for example kernel version) OsMeta *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=os_meta,json=osMeta,proto3" json:"os_meta,omitempty"` // Hostname of compromised target Hostname *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"` // Username under which agent's process is working Username *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=username,proto3" json:"username,omitempty"` // Domain name of compromised target Domain *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=domain,proto3" json:"domain,omitempty"` // Is process privilged (root, high intergity, etc) Privileged *wrapperspb.BoolValue `protobuf:"bytes,9,opt,name=privileged,proto3" json:"privileged,omitempty"` // Name of agent's process ProcName *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=proc_name,json=procName,proto3" json:"proc_name,omitempty"` // agent's process ID Pid *wrapperspb.UInt64Value `protobuf:"bytes,11,opt,name=pid,proto3" json:"pid,omitempty"` // [MANDATORY] Process architecture Arch uint32 `protobuf:"varint,12,opt,name=arch,proto3" json:"arch,omitempty"` // [MANDATORY] Sleep value of agent's process (in seconds) Sleep uint32 `protobuf:"varint,13,opt,name=sleep,proto3" json:"sleep,omitempty"` // [MANDATORY] Jitter value of agent's process (in range 1-99) Jitter uint32 `protobuf:"varint,14,opt,name=jitter,proto3" json:"jitter,omitempty"` // [MANDATORY] Binary mask represented supported agent's capabilities Caps uint32 `protobuf:"varint,15,opt,name=caps,proto3" json:"caps,omitempty"` // contains filtered or unexported fields }
--> RegisterAgent
func (*RegisterAgentRequest) Descriptor
deprecated
func (*RegisterAgentRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAgentRequest.ProtoReflect.Descriptor instead.
func (*RegisterAgentRequest) GetArch ¶
func (x *RegisterAgentRequest) GetArch() uint32
func (*RegisterAgentRequest) GetCaps ¶
func (x *RegisterAgentRequest) GetCaps() uint32
func (*RegisterAgentRequest) GetDomain ¶
func (x *RegisterAgentRequest) GetDomain() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetExtIp ¶
func (x *RegisterAgentRequest) GetExtIp() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetHostname ¶
func (x *RegisterAgentRequest) GetHostname() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetId ¶
func (x *RegisterAgentRequest) GetId() uint32
func (*RegisterAgentRequest) GetIntIp ¶
func (x *RegisterAgentRequest) GetIntIp() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetJitter ¶
func (x *RegisterAgentRequest) GetJitter() uint32
func (*RegisterAgentRequest) GetOs ¶
func (x *RegisterAgentRequest) GetOs() uint32
func (*RegisterAgentRequest) GetOsMeta ¶
func (x *RegisterAgentRequest) GetOsMeta() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetPid ¶
func (x *RegisterAgentRequest) GetPid() *wrapperspb.UInt64Value
func (*RegisterAgentRequest) GetPrivileged ¶
func (x *RegisterAgentRequest) GetPrivileged() *wrapperspb.BoolValue
func (*RegisterAgentRequest) GetProcName ¶
func (x *RegisterAgentRequest) GetProcName() *wrapperspb.StringValue
func (*RegisterAgentRequest) GetSleep ¶
func (x *RegisterAgentRequest) GetSleep() uint32
func (*RegisterAgentRequest) GetUsername ¶
func (x *RegisterAgentRequest) GetUsername() *wrapperspb.StringValue
func (*RegisterAgentRequest) ProtoMessage ¶
func (*RegisterAgentRequest) ProtoMessage()
func (*RegisterAgentRequest) ProtoReflect ¶
func (x *RegisterAgentRequest) ProtoReflect() protoreflect.Message
func (*RegisterAgentRequest) Reset ¶
func (x *RegisterAgentRequest) Reset()
func (*RegisterAgentRequest) String ¶
func (x *RegisterAgentRequest) String() string
type RegisterAgentResponse ¶
type RegisterAgentResponse struct {
// contains filtered or unexported fields
}
func (*RegisterAgentResponse) Descriptor
deprecated
func (*RegisterAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAgentResponse.ProtoReflect.Descriptor instead.
func (*RegisterAgentResponse) ProtoMessage ¶
func (*RegisterAgentResponse) ProtoMessage()
func (*RegisterAgentResponse) ProtoReflect ¶
func (x *RegisterAgentResponse) ProtoReflect() protoreflect.Message
func (*RegisterAgentResponse) Reset ¶
func (x *RegisterAgentResponse) Reset()
func (*RegisterAgentResponse) String ¶
func (x *RegisterAgentResponse) String() string
type UnimplementedListenerServiceServer ¶
type UnimplementedListenerServiceServer struct{}
UnimplementedListenerServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedListenerServiceServer) GetTask ¶
func (UnimplementedListenerServiceServer) GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
func (UnimplementedListenerServiceServer) PutResult ¶
func (UnimplementedListenerServiceServer) PutResult(context.Context, *PutResultRequest) (*PutResultResponse, error)
func (UnimplementedListenerServiceServer) RegisterAgent ¶
func (UnimplementedListenerServiceServer) RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
func (UnimplementedListenerServiceServer) UpdateListener ¶
func (UnimplementedListenerServiceServer) UpdateListener(context.Context, *UpdateListenerRequest) (*UpdateListenerResponse, error)
type UnsafeListenerServiceServer ¶
type UnsafeListenerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeListenerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ListenerServiceServer will result in compilation errors.
type UpdateListenerRequest ¶
type UpdateListenerRequest struct { // Name of listener. Can be string with maximum length of 256 Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // IP address which used to serving agent's server Ip *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` // Port which used to serving agent's server Port *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
--> UpdateListener
func (*UpdateListenerRequest) Descriptor
deprecated
func (*UpdateListenerRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateListenerRequest.ProtoReflect.Descriptor instead.
func (*UpdateListenerRequest) GetIp ¶
func (x *UpdateListenerRequest) GetIp() *wrapperspb.StringValue
func (*UpdateListenerRequest) GetName ¶
func (x *UpdateListenerRequest) GetName() *wrapperspb.StringValue
func (*UpdateListenerRequest) GetPort ¶
func (x *UpdateListenerRequest) GetPort() *wrapperspb.UInt32Value
func (*UpdateListenerRequest) ProtoMessage ¶
func (*UpdateListenerRequest) ProtoMessage()
func (*UpdateListenerRequest) ProtoReflect ¶
func (x *UpdateListenerRequest) ProtoReflect() protoreflect.Message
func (*UpdateListenerRequest) Reset ¶
func (x *UpdateListenerRequest) Reset()
func (*UpdateListenerRequest) String ¶
func (x *UpdateListenerRequest) String() string
type UpdateListenerResponse ¶
type UpdateListenerResponse struct {
// contains filtered or unexported fields
}
func (*UpdateListenerResponse) Descriptor
deprecated
func (*UpdateListenerResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateListenerResponse.ProtoReflect.Descriptor instead.
func (*UpdateListenerResponse) ProtoMessage ¶
func (*UpdateListenerResponse) ProtoMessage()
func (*UpdateListenerResponse) ProtoReflect ¶
func (x *UpdateListenerResponse) ProtoReflect() protoreflect.Message
func (*UpdateListenerResponse) Reset ¶
func (x *UpdateListenerResponse) Reset()
func (*UpdateListenerResponse) String ¶
func (x *UpdateListenerResponse) String() string