rpc

package

Go to main page

Versions in this module

v0

v0.1.2

Sep 25, 2025

Changes in this version

type Server

+ func (rpc *Server) EnumDrivers(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) FFmpeg(ctx context.Context, req *implantpb.FFmpegRequest) (*clientpb.Task, error)

+ func (rpc *Server) GenericInternal(ctx context.Context, req proto.Message, expect types.MsgName, ...) (*clientpb.Task, error)

+ func (rpc *Server) GetAudit(ctx context.Context, req *clientpb.SessionRequest) (*clientpb.Audits, error)

+ func (rpc *Server) GetProfileByName(ctx context.Context, req *clientpb.Profile) (*clientpb.Profile, error)

+ func (rpc *Server) ListDevice(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) PtyRequest(ctx context.Context, req *implantpb.PtyRequest) (*clientpb.Task, error)

v0.1.1

Jul 8, 2025

Changes in this version

+ func Handler(ctx context.Context, rpc *Server, req proto.Message, expect types.MsgName, ...) (*clientpb.Task, error)

+ func ObjcopyPulse(builder *models.Artifact, platform, arch string) ([]byte, error)

+ func SRDIArtifact(artifactModel *models.Artifact, platform, arch string) ([]byte, error)

type GenericRequest

+ func (r *GenericRequest) HandlerSpite(spite *implantpb.Spite) error

+ type LicenseResponse struct

+ License struct{ ... }

+ Success bool

type Server

+ func (rpc *Server) CheckSource(ctx context.Context, req *clientpb.BuildConfig) (*clientpb.BuildConfig, error)

+ func (rpc *Server) DeleteCertificate(ctx context.Context, req *clientpb.Cert) (*clientpb.Empty, error)

+ func (rpc *Server) DownloadCertificate(ctx context.Context, req *clientpb.Cert) (*clientpb.TLS, error)

+ func (rpc *Server) GenerateAcmeCert(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) GenerateSelfCert(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) GetAllCertificates(ctx context.Context, req *clientpb.Empty) (*clientpb.Certs, error)

+ func (rpc *Server) GetLicenseInfo(ctx context.Context, req *clientpb.Empty) (*clientpb.LicenseInfo, error)

+ func (rpc *Server) GetTasksByIDs(ctx context.Context, req *clientpb.Tasks) (*clientpb.TasksContext, error)

+ func (rpc *Server) Rev2Self(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) SaveAcmeCert(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) Switch(ctx context.Context, req *implantpb.Switch) (*clientpb.Task, error)

+ func (rpc *Server) SyncBuild(ctx context.Context, req *clientpb.BuildConfig) (*clientpb.Artifact, error)

+ func (rpc *Server) UpdateCertificate(ctx context.Context, req *clientpb.Cert) (*clientpb.Empty, error)

v0.1.0

Apr 13, 2025

Changes in this version

+ func ContextCallback(task *core.Task, ctx context.Context) func(*implantpb.Spite)

+ func MapContents(webpipe *clientpb.Pipeline) error

type GenericRequest

+ func (r *GenericRequest) TaskContext(spite *implantpb.Spite) *clientpb.TaskContext

type Server

+ func (rpc *Server) AddContext(ctx context.Context, req *clientpb.Context) (*clientpb.Empty, error)

+ func (rpc *Server) AddCredential(ctx context.Context, req *clientpb.Context) (*clientpb.Empty, error)

+ func (rpc *Server) AddDownload(ctx context.Context, req *clientpb.Context) (*clientpb.Empty, error)

+ func (rpc *Server) AddPort(ctx context.Context, req *clientpb.Context) (*clientpb.Empty, error)

+ func (rpc *Server) AddScreenShot(ctx context.Context, req *clientpb.Context) (*clientpb.Empty, error)

+ func (rpc *Server) AddWebsiteContent(ctx context.Context, req *clientpb.Website) (*clientpb.WebContent, error)

+ func (rpc *Server) BuildModules(ctx context.Context, req *clientpb.Generate) (*clientpb.Artifact, error)

+ func (rpc *Server) DeleteArtifact(ctx context.Context, req *clientpb.Artifact) (*clientpb.Empty, error)

+ func (rpc *Server) DeletePipeline(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) DeleteProfile(ctx context.Context, req *clientpb.Profile) (*clientpb.Empty, error)

+ func (rpc *Server) DeleteRem(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) DeleteWebsite(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) DockerStatus(ctx context.Context, req *clientpb.Empty) (*clientpb.Empty, error)

+ func (rpc *Server) FindArtifact(ctx context.Context, req *clientpb.Artifact) (*clientpb.Artifact, error)

+ func (rpc *Server) GetArtifactsByProfile(ctx context.Context, req *clientpb.Profile) (*clientpb.Builders, error)

+ func (rpc *Server) GetContexts(ctx context.Context, req *clientpb.Context) (*clientpb.Contexts, error)

+ func (rpc *Server) GetEvent(ctx context.Context, req *clientpb.Int) (*clientpb.Events, error)

+ func (rpc *Server) GetFiles(ctx context.Context, req *clientpb.Session) (*clientpb.Files, error)

+ func (rpc *Server) GetGithubConfig(ctx context.Context, req *clientpb.Empty) (*clientpb.GithubWorkflowRequest, error)

+ func (rpc *Server) GetNotifyConfig(ctx context.Context, req *clientpb.Empty) (*clientpb.Notify, error)

+ func (rpc *Server) HealthCheckRem(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) InlineLocal(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ListBuilder(ctx context.Context, req *clientpb.Empty) (*clientpb.Builders, error)

+ func (rpc *Server) ListRems(ctx context.Context, req *clientpb.Listener) (*clientpb.Pipelines, error)

+ func (rpc *Server) ListTasks(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListWebContent(ctx context.Context, req *clientpb.Website) (*clientpb.WebContents, error)

+ func (rpc *Server) LoadRem(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) QueryTask(ctx context.Context, req *implantpb.TaskCtrl) (*clientpb.Task, error)

+ func (rpc *Server) RefreshConfig(ctx context.Context, req *clientpb.Empty) (*clientpb.Empty, error)

+ func (rpc *Server) RegisterRem(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) RemAgentCtrl(ctx context.Context, req *clientpb.REMAgent) (*clientpb.Empty, error)

+ func (rpc *Server) RemAgentLog(ctx context.Context, req *clientpb.REMAgent) (*clientpb.RemLog, error)

+ func (rpc *Server) RemAgentStop(ctx context.Context, req *clientpb.REMAgent) (*clientpb.Empty, error)

+ func (rpc *Server) RemDial(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) RemoveWebsiteContent(ctx context.Context, req *clientpb.WebContent) (*clientpb.Empty, error)

+ func (rpc *Server) StartRem(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) StopRem(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) SyncPipeline(ctx context.Context, req *clientpb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) TriggerWorkflowDispatch(ctx context.Context, req *clientpb.GithubWorkflowRequest) (*clientpb.Builder, error)

+ func (rpc *Server) UpdateGithubConfig(ctx context.Context, req *clientpb.GithubWorkflowRequest) (*clientpb.Empty, error)

+ func (rpc *Server) UpdateNotifyConfig(ctx context.Context, req *clientpb.Notify) (*clientpb.Empty, error)

+ func (rpc *Server) UpdateProfile(ctx context.Context, req *clientpb.Profile) (*clientpb.Empty, error)

+ func (rpc *Server) UpdateWebsiteContent(ctx context.Context, req *clientpb.WebContent) (*clientpb.WebContent, error)

+ func (rpc *Server) WorkflowStatus(ctx context.Context, req *clientpb.GithubWorkflowRequest) (*clientpb.Empty, error)

v0.0.4

Nov 20, 2024

v0.0.3

Nov 21, 2024

Changes in this version

type GenericRequest

+ Callee string

type Server

+ func (rpc *Server) Build(ctx context.Context, req *clientpb.Generate) (*clientpb.Builder, error)

+ func (rpc *Server) BuildLog(ctx context.Context, req *clientpb.Builder) (*clientpb.Builder, error)

+ func (rpc *Server) Checkin(ctx context.Context, req *implantpb.Ping) (*clientpb.Empty, error)

+ func (rpc *Server) DLL2Shellcode(ctx context.Context, req *clientpb.DLL2Shellcode) (*clientpb.Bin, error)

+ func (rpc *Server) DownloadArtifact(ctx context.Context, req *clientpb.Builder) (*clientpb.Builder, error)

+ func (rpc *Server) EXE2Shellcode(ctx context.Context, req *clientpb.EXE2Shellcode) (*clientpb.Bin, error)

+ func (rpc *Server) ExecuteLocal(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecutePowerpick(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) GetArtifact(ctx context.Context, req *clientpb.Builder) (*clientpb.Builder, error)

+ func (rpc *Server) GetProfiles(ctx context.Context, req *clientpb.Empty) (*clientpb.Profiles, error)

+ func (rpc *Server) GetSessionHistory(ctx context.Context, req *clientpb.SessionLog) (*clientpb.TasksContext, error)

+ func (rpc *Server) GetSystem(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) InitBindSession(ctx context.Context, req *implantpb.Request) (*clientpb.Empty, error)

+ func (rpc *Server) ListArtifact(ctx context.Context, req *clientpb.Empty) (*clientpb.Builders, error)

+ func (rpc *Server) MaleficSRDI(ctx context.Context, req *clientpb.Builder) (*clientpb.Builder, error)

+ func (rpc *Server) NewProfile(ctx context.Context, req *clientpb.Profile) (*clientpb.Empty, error)

+ func (rpc *Server) PipeClose(ctx context.Context, req *implantpb.PipeRequest) (*clientpb.Task, error)

+ func (rpc *Server) PipeRead(ctx context.Context, req *implantpb.PipeRequest) (*clientpb.Task, error)

+ func (rpc *Server) PipeUpload(ctx context.Context, pipe *implantpb.PipeRequest) (*clientpb.Task, error)

+ func (rpc *Server) Polling(ctx context.Context, req *clientpb.Polling) (*clientpb.Empty, error)

+ func (rpc *Server) Privs(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) RegAdd(ctx context.Context, req *implantpb.RegistryWriteRequest) (*clientpb.Task, error)

+ func (rpc *Server) RegDelete(ctx context.Context, req *implantpb.RegistryRequest) (*clientpb.Task, error)

+ func (rpc *Server) RegListKey(ctx context.Context, req *implantpb.RegistryRequest) (*clientpb.Task, error)

+ func (rpc *Server) RegListValue(ctx context.Context, req *implantpb.RegistryRequest) (*clientpb.Task, error)

+ func (rpc *Server) RegQuery(ctx context.Context, req *implantpb.RegistryRequest) (*clientpb.Task, error)

+ func (rpc *Server) Runas(ctx context.Context, req *implantpb.RunAsRequest) (*clientpb.Task, error)

+ func (rpc *Server) ServiceCreate(ctx context.Context, req *implantpb.ServiceRequest) (*clientpb.Task, error)

+ func (rpc *Server) ServiceDelete(ctx context.Context, req *implantpb.ServiceRequest) (*clientpb.Task, error)

+ func (rpc *Server) ServiceList(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ServiceQuery(ctx context.Context, req *implantpb.ServiceRequest) (*clientpb.Task, error)

+ func (rpc *Server) ServiceStart(ctx context.Context, req *implantpb.ServiceRequest) (*clientpb.Task, error)

+ func (rpc *Server) ServiceStop(ctx context.Context, req *implantpb.ServiceRequest) (*clientpb.Task, error)

+ func (rpc *Server) SessionManage(ctx context.Context, req *clientpb.BasicUpdateSession) (*clientpb.Empty, error)

+ func (rpc *Server) SetEnv(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ShellcodeEncode(ctx context.Context, req *clientpb.ShellcodeEncode) (*clientpb.Bin, error)

+ func (rpc *Server) Sleep(ctx context.Context, req *implantpb.Timer) (*clientpb.Task, error)

+ func (rpc *Server) StartPipeline(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) StopPipeline(ctx context.Context, req *clientpb.CtrlPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) Suicide(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdCreate(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdDelete(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdList(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdQuery(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdRun(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdStart(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) TaskSchdStop(ctx context.Context, req *implantpb.TaskScheduleRequest) (*clientpb.Task, error)

+ func (rpc *Server) UnsetEnv(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) UploadArtifact(ctx context.Context, req *clientpb.Builder) (*clientpb.Builder, error)

+ func (rpc *Server) WmiExecute(ctx context.Context, req *implantpb.WmiMethodRequest) (*clientpb.Task, error)

+ func (rpc *Server) WmiQuery(ctx context.Context, req *implantpb.WmiQueryRequest) (*clientpb.Task, error)

v0.0.2

Sep 17, 2024

Changes in this version

+ var ErrTaskIndexExceed = status.Error(codes.NotFound, "task index id exceed total")

type GenericRequest

+ Count int

+ func (r *GenericRequest) HandlerResponse(ch chan *implantpb.Spite, typ types.MsgName, ...)

+ func (r *GenericRequest) InitSpite() (*implantpb.Spite, error)

type Server

+ func (rpc *Server) Bypass(ctx context.Context, req *implantpb.BypassRequest) (*clientpb.Task, error)

+ func (rpc *Server) CancelTask(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Clear(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteAddon(ctx context.Context, req *implantpb.ExecuteAddon) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteArmory(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteEXE(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) GenericHandler(ctx context.Context, req *GenericRequest) (chan *implantpb.Spite, error)

+ func (rpc *Server) GetTaskFiles(ctx context.Context, req *clientpb.Session) (*clientpb.Files, error)

+ func (rpc *Server) ListAddon(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListClientsAuth(ctx context.Context, req *rootpb.Operator) (*clientpb.Clients, error)

+ func (rpc *Server) ListJobs(ctx context.Context, req *clientpb.Empty) (*lispb.Pipelines, error)

+ func (rpc *Server) ListListenersAuth(ctx context.Context, req *rootpb.Operator) (*clientpb.Listeners, error)

+ func (rpc *Server) ListModule(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListTcpPipelines(ctx context.Context, req *lispb.ListenerName) (*lispb.Pipelines, error)

+ func (rpc *Server) LoadAddon(ctx context.Context, req *implantpb.LoadAddon) (*clientpb.Task, error)

+ func (rpc *Server) NewPipeline(ctx context.Context, req *lispb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) NewWebsite(ctx context.Context, req *lispb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) Notify(ctx context.Context, req *clientpb.Event) (*clientpb.Empty, error)

+ func (rpc *Server) RefreshModule(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) SessionEvent(ctx context.Context, req *clientpb.Event) (*clientpb.Empty, error)

+ func (rpc *Server) StreamGenericHandler(ctx context.Context, req *GenericRequest) (chan *implantpb.Spite, chan *implantpb.Spite, error)

+ func (rpc *Server) UploadWebsite(ctx context.Context, req *lispb.WebsiteAssets) (*clientpb.Empty, error)

+ func (rpc *Server) WaitTaskFinish(ctx context.Context, req *clientpb.Task) (*clientpb.TaskContext, error)

v0.0.1

Aug 21, 2024

Changes in this version

+ const Operator

+ const Transport

+ var ErrAssertFailure = status.Error(codes.InvalidArgument, "Assert spite type failure")

+ var ErrAsyncNotSupported = status.Error(codes.Unavailable, "Async not supported for this command")

+ var ErrDatabaseFailure = status.Error(codes.Internal, "Database operation failed")

+ var ErrInvalidName = status.Error(codes.InvalidArgument, "Invalid session name, alphanumerics and _-. only")

+ var ErrInvalidSessionID = status.Error(codes.InvalidArgument, "Invalid session ID")

+ var ErrMissingRequestField = status.Error(codes.InvalidArgument, "Missing session request field")

+ var ErrNilResponseBody = status.Error(codes.InvalidArgument, "Must return spite body")

+ var ErrNilStatus = status.Error(codes.InvalidArgument, "Nil status or unknown error")

+ var ErrNotFoundClientName = status.Error(codes.NotFound, "Client name not found")

+ var ErrNotFoundListener = status.Error(codes.NotFound, "Listener not found")

+ var ErrNotFoundPipeline = status.Error(codes.NotFound, "Pipeline not found")

+ var ErrNotFoundSession = status.Error(codes.NotFound, "Session ID not found")

+ var ErrNotFoundTask = status.Error(codes.NotFound, "Task ID not found")

+ var ErrNotFoundTaskContent = status.Error(codes.NotFound, "Task content not found")

+ func AssertRequestName(req *implantpb.Request, expect types.MsgName) error

+ func AssertResponse(spite *implantpb.Spite, expect types.MsgName) error

+ func AssertStatus(spite *implantpb.Spite) error

+ func AssertStatusAndResponse(spite *implantpb.Spite, expect types.MsgName) error

+ func InitLogs(debug bool)

+ func StartClientListener(port uint16) (*grpc.Server, net.Listener, error)

+ type GenericRequest struct

+ Session *core.Session

+ Task *core.Task

+ func (r *GenericRequest) HandlerAsyncResponse(ch chan *implantpb.Spite, typ types.MsgName, ...)

+ func (r *GenericRequest) NewSpite(msg proto.Message) (*implantpb.Spite, error)

+ func (r *GenericRequest) NewTask(total int) *core.Task

+ func (r *GenericRequest) SetCallback(callback func())

+ type Server struct

+ func NewServer() *Server

+ func (rpc *Server) AddClient(ctx context.Context, req *rootpb.Operator) (*rootpb.Response, error)

+ func (rpc *Server) BasicSessionOP(ctx context.Context, req *clientpb.BasicUpdateSession) (*clientpb.Empty, error)

+ func (rpc *Server) Broadcast(ctx context.Context, req *clientpb.Event) (*clientpb.Empty, error)

+ func (rpc *Server) Cat(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Cd(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Chmod(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Chown(ctx context.Context, req *implantpb.ChownRequest) (*clientpb.Task, error)

+ func (rpc *Server) Cp(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Curl(ctx context.Context, req *implantpb.CurlRequest) (*clientpb.Task, error)

+ func (rpc *Server) Download(ctx context.Context, req *implantpb.DownloadRequest) (*clientpb.Task, error)

+ func (rpc *Server) Env(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Events(_ *clientpb.Empty, stream clientrpc.MaliceRPC_EventsServer) error

+ func (rpc *Server) Execute(ctx context.Context, req *implantpb.ExecRequest) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteAssembly(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteBof(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteDll(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteExtension(ctx context.Context, req *implantpb.ExecuteExtension) (*clientpb.Task, error)

+ func (rpc *Server) ExecutePE(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecutePowershell(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) ExecuteShellcode(ctx context.Context, req *implantpb.ExecuteBinary) (*clientpb.Task, error)

+ func (rpc *Server) GetAlivedSessions(ctx context.Context, _ *clientpb.Empty) (*clientpb.Sessions, error)

+ func (rpc *Server) GetAllTaskContent(ctx context.Context, req *clientpb.Task) ([]*implantpb.Spite, error)

+ func (rpc *Server) GetBasic(ctx context.Context, _ *clientpb.Empty) (*clientpb.Basic, error)

+ func (rpc *Server) GetClients(ctx context.Context, req *clientpb.Empty) (*clientpb.Clients, error)

+ func (rpc *Server) GetListeners(ctx context.Context, req *clientpb.Empty) (*clientpb.Listeners, error)

+ func (rpc *Server) GetSession(ctx context.Context, req *clientpb.SessionRequest) (*clientpb.Session, error)

+ func (rpc *Server) GetSessions(ctx context.Context, _ *clientpb.Empty) (*clientpb.Sessions, error)

+ func (rpc *Server) GetTaskContent(ctx context.Context, req *clientpb.Task) (*implantpb.Spite, error)

+ func (rpc *Server) GetTaskDescs(ctx context.Context, req *clientpb.Session) (*clientpb.TaskDescs, error)

+ func (rpc *Server) GetTasks(ctx context.Context, session *clientpb.Session) (*clientpb.Tasks, error)

+ func (rpc *Server) Info(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) JobStream(stream listenerrpc.ListenerRPC_JobStreamServer) error

+ func (rpc *Server) Kill(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListClients(ctx context.Context, req *rootpb.Operator) (*clientpb.Clients, error)

+ func (rpc *Server) ListExtensions(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListModules(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) ListPipelines(ctx context.Context, req *lispb.ListenerName) (*lispb.Pipelines, error)

+ func (rpc *Server) ListWebsites(ctx context.Context, req *lispb.ListenerName) (*lispb.Websites, error)

+ func (rpc *Server) LoadExtension(ctx context.Context, req *implantpb.LoadExtension) (*clientpb.Task, error)

+ func (rpc *Server) LoadModule(ctx context.Context, req *implantpb.LoadModule) (*clientpb.Task, error)

+ func (rpc *Server) LoginClient(ctx context.Context, req *clientpb.LoginReq) (*clientpb.LoginResp, error)

+ func (rpc *Server) Ls(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Mkdir(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Mv(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Netstat(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Ping(ctx context.Context, req *implantpb.Ping) (*implantpb.Empty, error)

+ func (rpc *Server) Ps(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Pwd(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Register(ctx context.Context, req *lispb.RegisterSession) (*implantpb.Empty, error)

+ func (rpc *Server) RegisterListener(ctx context.Context, req *lispb.RegisterListener) (*implantpb.Empty, error)

+ func (rpc *Server) RegisterPipeline(ctx context.Context, req *lispb.Pipeline) (*implantpb.Empty, error)

+ func (rpc *Server) RegisterWebsite(ctx context.Context, req *lispb.Website) (*implantpb.Empty, error)

+ func (rpc *Server) RemoveClient(ctx context.Context, req *rootpb.Operator) (*rootpb.Response, error)

+ func (rpc *Server) Rm(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Setenv(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) SpiteStream(stream listenerrpc.ListenerRPC_SpiteStreamServer) error

+ func (rpc *Server) StartTcpPipeline(ctx context.Context, req *lispb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) StartWebsite(ctx context.Context, req *lispb.Pipeline) (*clientpb.Empty, error)

+ func (rpc *Server) StopTcpPipeline(ctx context.Context, req *lispb.TCPPipeline) (*clientpb.Empty, error)

+ func (rpc *Server) StopWebsite(ctx context.Context, req *lispb.Website) (*clientpb.Empty, error)

+ func (rpc *Server) Sync(ctx context.Context, req *clientpb.Sync) (*clientpb.SyncResp, error)

+ func (rpc *Server) SysInfo(ctx context.Context, req *implantpb.SysInfo) (*implantpb.Empty, error)

+ func (rpc *Server) Unsetenv(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (rpc *Server) Upload(ctx context.Context, req *implantpb.UploadRequest) (*clientpb.Task, error)

+ func (rpc *Server) WaitTaskContent(ctx context.Context, req *clientpb.Task) (*implantpb.Spite, error)

+ func (rpc *Server) Website(ctx context.Context, req *lispb.Website) (*lispb.Website, error)

+ func (rpc *Server) WebsiteAddContent(ctx context.Context, req *lispb.WebsiteAddContent) (*lispb.Website, error)

+ func (rpc *Server) WebsiteRemove(ctx context.Context, req *lispb.Website) (*clientpb.Empty, error)

+ func (rpc *Server) WebsiteRemoveContent(ctx context.Context, req *lispb.WebsiteRemoveContent) (*lispb.Website, error)

+ func (rpc *Server) WebsiteUpdateContent(ctx context.Context, req *lispb.WebsiteAddContent) (*lispb.Website, error)

+ func (rpc *Server) Websites(ctx context.Context, _ *clientpb.Empty) (*lispb.Websites, error)

+ func (rpc *Server) Whoami(ctx context.Context, req *implantpb.Request) (*clientpb.Task, error)

+ func (s *Server) AddListener(ctx context.Context, req *rootpb.Operator) (*rootpb.Response, error)

+ func (s *Server) ListListeners(ctx context.Context, req *rootpb.Operator) (*clientpb.Listeners, error)

+ func (s *Server) RemoveListener(ctx context.Context, req *rootpb.Operator) (*rootpb.Response, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL