rpc

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2026 License: Apache-2.0 Imports: 63 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Transport contextKey = iota
)

Variables

View Source 
var (
	Ver        = "latest"
	Commit     = ""
	Buildstamp = ""
)
View Source 
var ErrTaskContextCancelled = fmt.Errorf("task context cancelled")

Functions

func CloseLogs added in v0.3.0 

func CloseLogs()

func ContextCallback added in v0.1.0 

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

func InitLogs 

func InitLogs(debug bool)

func MapContents added in v0.1.0 

func MapContents(webpipe *clientpb.Pipeline) error

func NewClientGRPCServer added in v0.3.0 

func NewClientGRPCServer(serverIP string, debug bool) (*grpc.Server, error)

func ObjcopyPulse added in v0.1.1 

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

ObjcopyPulse extracts shellcode from compiled artifact using objcopy

func ReInitLogs added in v0.3.0 

func ReInitLogs()

ReInitLogs closes current loggers and reopens fresh log files. Called by log rotation after renaming the old files.

func RegisterRPCServices added in v0.3.0 

func RegisterRPCServices(grpcServer *grpc.Server)

func ResetTransientRPCState added in v0.3.0 

func ResetTransientRPCState()

ResetTransientRPCState clears process-global RPC stream state that should not leak across isolated in-process test harnesses.

func StartClientListener 

func StartClientListener(address string) (*grpc.Server, net.Listener, error)

StartClientListener - Start a mutual TLS listener

Types

type GenericRequest 

type GenericRequest struct {
	proto.Message
	Task    *core.Task
	Count   int
	Session *core.Session
	Callee  string
}

func (*GenericRequest) HandlerResponse added in v0.0.2 

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

func (*GenericRequest) HandlerSpite added in v0.1.1 

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

func (*GenericRequest) InitSpite added in v0.0.2 

func (r *GenericRequest) InitSpite(ctx context.Context) (*implantpb.Spite, error)

func (*GenericRequest) NewSpite 

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

func (*GenericRequest) SetCallback 

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

func (*GenericRequest) TaskContext added in v0.1.0 

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

type PeerIdentity added in v0.3.0 

type PeerIdentity struct {
	CommonName  string // cert Subject.CommonName (typically the operator name)
	Fingerprint string // SHA-256 hex of DER cert bytes
	RemoteAddr  string // peer IP:port
	RemoteIP    string // peer IP only
	IsLoopback  bool   // whether RemoteIP is 127.0.0.1 or ::1
}

PeerIdentity holds all identity information extracted from the mTLS connection. It is computed once per RPC call and stored in the context for downstream handlers.

type Server 

type Server struct {
	// Magical methods to break backwards compatibility
	// Here be dragons: https://github.com/grpc/grpc-go/issues/3794
	clientrpc.UnimplementedMaliceRPCServer
	listenerrpc.UnimplementedListenerRPCServer
	clientrpc.UnimplementedRootRPCServer
}

func NewServer 

func NewServer() *Server

NewServer - Create new server instance

func (*Server) AddAuthzRule added in v0.3.0 

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

AddAuthzRule creates a new authorization rule. Usage: args=[role, method_pattern], params["allow"] = "true"|"false" (default "true")

func (*Server) AddClient 

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

func (*Server) AddContext added in v0.1.0 

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

func (*Server) AddCredential added in v0.1.0 

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

func (*Server) AddDownload added in v0.1.0 

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

func (*Server) AddKeylogger added in v0.3.0 

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

func (*Server) AddListener 

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

func (*Server) AddPort added in v0.1.0 

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

func (*Server) AddScreenShot added in v0.1.0 

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

func (*Server) AddUpload added in v0.3.0 

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

func (*Server) AddWebsiteContent added in v0.1.0 

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

WebsiteAddContent - Add content to a website, the website is created if `name` does not exist

func (*Server) AssertAndHandle added in v0.3.0 

func (rpc *Server) AssertAndHandle(ctx context.Context, req *implantpb.Request, module types.MsgName, expect types.MsgName, callbacks ...func(*implantpb.Spite)) (*clientpb.Task, error)

AssertAndHandle covers the common pattern for *implantpb.Request handlers: assert request name → newGenericRequest → GenericHandler → HandlerResponse.

func (*Server) AssertAndHandleWithSession added in v0.3.0 

func (rpc *Server) AssertAndHandleWithSession(ctx context.Context, req *implantpb.Request, module types.MsgName, expect types.MsgName, callback func(*GenericRequest, *implantpb.Spite)) (*clientpb.Task, error)

AssertAndHandleWithSession combines AssertRequestName with GenericInternalWithSession.

func (*Server) BridgeAgentChat added in v0.3.0 

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

BridgeAgentChat handles the bridge agent RPC: operator -> implant -> [agent loop with LLM proxy] -> result. The client selects provider/model; endpoint/api key/proxy are resolved server-side.

func (*Server) Broadcast 

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

func (*Server) Build added in v0.0.3 

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

func (*Server) BuildLog added in v0.0.3 

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

func (*Server) Bypass added in v0.0.2 

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

func (*Server) CancelTask added in v0.0.2 

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

func (*Server) Cat 

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

func (*Server) Cd 

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

func (*Server) CheckSource added in v0.1.1 

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

func (*Server) Checkin added in v0.0.3 

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

func (*Server) Chmod 

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

func (*Server) Chown 

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

func (*Server) Clear added in v0.0.2 

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

func (*Server) Cp 

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

func (*Server) Curl 

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

func (*Server) DLL2Shellcode added in v0.0.3 

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

func (*Server) DeleteArtifact added in v0.1.0 

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

func (*Server) DeleteCertificate added in v0.1.1 

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

func (*Server) DeleteContext added in v0.3.0 

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

func (*Server) DeletePipeline added in v0.1.0 

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

func (*Server) DeleteProfile added in v0.1.0 

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

func (*Server) DeleteRem added in v0.1.0 

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

func (*Server) DeleteWebsite added in v0.1.0 

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

func (*Server) Download 

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

Download - Download a file from implant

func (*Server) DownloadArtifact added in v0.0.3 

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

func (*Server) DownloadCertificate added in v0.1.1 

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

func (*Server) EXE2Shellcode added in v0.0.3 

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

func (*Server) EnumDrivers added in v0.1.2 

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

func (*Server) Env 

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

func (*Server) Events 

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

func (*Server) Execute 

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

func (*Server) ExecuteAddon added in v0.0.2 

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

func (*Server) ExecuteArmory added in v0.0.2 

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

func (*Server) ExecuteAssembly 

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

func (*Server) ExecuteBof 

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

func (*Server) ExecuteDLL added in v0.3.0 

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

func (*Server) ExecuteDll 

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

func (*Server) ExecuteEXE added in v0.0.2 

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

func (*Server) ExecuteLocal added in v0.0.3 

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

func (*Server) ExecuteModule added in v0.3.0 

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

ExecuteModule passthrough for fully dynamic module execution. For streaming modules (e.g. tapping/llm.observe), it uses a continuous loop that keeps the task alive instead of finishing after one response.

func (*Server) ExecutePowerpick added in v0.0.3 

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

func (*Server) ExecuteShellcode 

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

func (*Server) FFmpeg added in v0.1.2 

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

func (*Server) FindArtifact added in v0.1.0 

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

func (*Server) GenerateAcmeCert added in v0.1.1 

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

func (*Server) GenerateSelfCert added in v0.1.1 

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

func (*Server) GenericHandler added in v0.0.2 

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

func (*Server) GenericInternal added in v0.1.2 

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

func (*Server) GenericInternalWithSession added in v0.3.0 

func (rpc *Server) GenericInternalWithSession(ctx context.Context, req proto.Message, expect types.MsgName, callback func(*GenericRequest, *implantpb.Spite)) (*clientpb.Task, error)

GenericInternalWithSession is like GenericInternal but passes the GenericRequest to the callback so it can access Session, Task, and other request context.

func (*Server) GetAcmeConfig added in v0.3.0 

func (rpc *Server) GetAcmeConfig(ctx context.Context, req *clientpb.Empty) (*clientpb.AcmeConfig, error)

func (*Server) GetAllCertificates added in v0.1.1 

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

func (*Server) GetAllTaskContent 

func (rpc *Server) GetAllTaskContent(ctx context.Context, req *clientpb.Task) (*clientpb.TaskContexts, error)

func (*Server) GetArtifact added in v0.0.3 

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

for listener

func (*Server) GetAudit added in v0.1.2 

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

func (*Server) GetBasic 

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

func (*Server) GetClients 

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

func (*Server) GetContexts added in v0.1.0 

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

func (*Server) GetEvent added in v0.1.0 

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

func (*Server) GetFiles added in v0.1.0 

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

func (*Server) GetGithubConfig added in v0.1.0 

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

func (*Server) GetLicenseInfo added in v0.1.1 

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

func (*Server) GetListeners 

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

func (*Server) GetNotifyConfig added in v0.1.0 

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

func (*Server) GetProfileByName added in v0.1.2 

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

func (*Server) GetProfiles added in v0.0.3 

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

func (*Server) GetSession 

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

func (*Server) GetSessionCount added in v0.3.0 

func (rpc *Server) GetSessionCount(ctx context.Context, req *clientpb.Empty) (*clientpb.SessionCount, error)

func (*Server) GetSessionHistory added in v0.0.3 

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

func (*Server) GetSessions 

func (rpc *Server) GetSessions(ctx context.Context, req *clientpb.SessionRequest) (*clientpb.Sessions, error)

func (*Server) GetSystem added in v0.0.3 

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

func (*Server) GetTaskContent 

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

func (*Server) GetTasks 

func (rpc *Server) GetTasks(ctx context.Context, req *clientpb.TaskRequest) (*clientpb.Tasks, error)

func (*Server) HealthCheckRem added in v0.1.0 

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

func (*Server) Info 

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

func (*Server) InitBindSession added in v0.0.3 

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

func (*Server) InlineLocal added in v0.1.0 

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

func (*Server) JobStream 

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

func (*Server) Keepalive added in v0.3.0 

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

keepalive - enable/disable duplex mode

func (*Server) Kill 

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

func (*Server) ListAddon added in v0.0.2 

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

func (*Server) ListArtifact added in v0.0.3 

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

func (*Server) ListAuthzRules added in v0.3.0 

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

ListAuthzRules returns all authorization rules, optionally filtered by role. Usage: params["role"] = optional role filter

func (*Server) ListClients 

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

func (*Server) ListDevice added in v0.1.2 

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

func (*Server) ListJobs added in v0.0.2 

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

func (*Server) ListListeners 

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

func (*Server) ListModule added in v0.0.2 

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

func (*Server) ListPipelines 

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

func (*Server) ListRems added in v0.1.0 

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

func (*Server) ListTasks added in v0.1.0 

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

func (*Server) ListWebContent added in v0.1.0 

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

ListWebContent - 列出网站的所有内容

func (*Server) ListWebsites 

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

func (*Server) LoadAddon added in v0.0.2 

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

func (*Server) LoadModule 

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

func (*Server) LoginClient 

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

func (*Server) Ls 

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

func (*Server) Mkdir 

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

func (*Server) MutantSigforge added in v0.3.0 

func (rpc *Server) MutantSigforge(ctx context.Context, req *clientpb.MutantSigforgeRequest) (*clientpb.Bin, error)

MutantSigforge manipulates PE file signatures using malefic-mutant sigforge tool

func (*Server) MutantSrdi added in v0.3.0 

func (rpc *Server) MutantSrdi(ctx context.Context, req *clientpb.MutantSrdiRequest) (*clientpb.Bin, error)

MutantSrdi converts DLL to shellcode using malefic-mutant srdi tool

func (*Server) MutantStrip added in v0.3.0 

func (rpc *Server) MutantStrip(ctx context.Context, req *clientpb.MutantStripRequest) (*clientpb.Bin, error)

MutantStrip removes paths from binary files using malefic-mutant strip tool

func (*Server) Mv 

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

func (*Server) Netstat 

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

func (*Server) NewProfile added in v0.0.3 

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

func (*Server) Notify added in v0.0.2 

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

func (*Server) ObtainAcmeCert added in v0.3.0 

func (rpc *Server) ObtainAcmeCert(ctx context.Context, req *clientpb.AcmeRequest) (*clientpb.Empty, error)

func (*Server) Ping 

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

func (*Server) PipeClose added in v0.0.3 

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

func (*Server) PipeRead added in v0.0.3 

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

func (*Server) PipeServer added in v0.3.0 

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

func (*Server) PipeUpload added in v0.0.3 

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

func (*Server) Polling added in v0.0.3 

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

func (*Server) Privs added in v0.0.3 

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

func (*Server) Ps 

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

func (*Server) PtyRequest added in v0.1.2 

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

func (*Server) Pwd 

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

func (*Server) QueryTask added in v0.1.0 

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

func (*Server) RefreshConfig added in v0.1.0 

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

func (*Server) RefreshModule added in v0.0.2 

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

func (*Server) RegAdd added in v0.0.3 

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

func (*Server) RegDelete added in v0.0.3 

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

func (*Server) RegListKey added in v0.0.3 

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

func (*Server) RegListValue added in v0.0.3 

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

func (*Server) RegQuery added in v0.0.3 

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

func (*Server) Register 

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

func (*Server) RegisterListener 

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

func (*Server) RegisterPipeline 

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

func (*Server) RegisterRem added in v0.1.0 

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

func (*Server) RegisterWebsite 

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

func (*Server) RemAgentCtrl added in v0.1.0 

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

func (*Server) RemAgentLog added in v0.1.0 

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

func (*Server) RemAgentStop added in v0.1.0 

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

func (*Server) RemDial added in v0.1.0 

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

func (*Server) RemoveAuthzRule added in v0.3.0 

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

RemoveAuthzRule deletes an authorization rule by ID. Usage: args=[rule_id]

func (*Server) RemoveClient 

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

func (*Server) RemoveListener 

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

func (*Server) RemoveWebsiteContent added in v0.1.0 

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

WebsiteRemoveContent - Remove specific content from a website

func (*Server) Rev2Self added in v0.1.1 

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

func (*Server) RevokeOperator added in v0.3.0 

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

RevokeOperator sets the revoked flag on an operator, immediately blocking access. Usage: args=[name]

func (*Server) Rm 

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

func (*Server) Runas added in v0.0.3 

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

func (*Server) SaveAcmeCert added in v0.1.1 

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

func (*Server) ServiceCreate added in v0.0.3 

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

func (*Server) ServiceDelete added in v0.0.3 

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

func (*Server) ServiceList added in v0.0.3 

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

func (*Server) ServiceQuery added in v0.0.3 

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

func (*Server) ServiceStart added in v0.0.3 

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

func (*Server) ServiceStop added in v0.0.3 

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

func (*Server) SessionEvent added in v0.0.2 

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

func (*Server) SessionManage added in v0.0.3 

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

func (*Server) SetEnv added in v0.0.3 

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

func (*Server) SetOperatorRole added in v0.3.0 

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

SetOperatorRole changes the role of an existing operator. Usage: args=[name, role]

func (*Server) ShellcodeEncode added in v0.0.3 

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

func (*Server) Sleep added in v0.0.3 

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

sleep

func (*Server) SpiteStream 

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

func (*Server) StartPipeline added in v0.0.3 

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

func (*Server) StartRem added in v0.1.0 

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

func (*Server) StartWebsite 

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

func (*Server) StopPipeline added in v0.0.3 

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

func (*Server) StopRem added in v0.1.0 

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

func (*Server) StopWebsite 

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

func (*Server) StreamGenericHandler added in v0.0.2 

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

StreamGenericHandler - Generic handler for async request/response's for beacon tasks

func (*Server) Suicide added in v0.0.3 

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

func (*Server) Switch added in v0.1.1 

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

func (*Server) Sync 

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

func (*Server) SyncBuild added in v0.1.1 

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

func (*Server) SyncPipeline added in v0.1.0 

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

func (*Server) SysInfo 

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

func (*Server) TaskSchdCreate added in v0.0.3 

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

func (*Server) TaskSchdDelete added in v0.0.3 

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

func (*Server) TaskSchdList added in v0.0.3 

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

func (*Server) TaskSchdQuery added in v0.0.3 

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

func (*Server) TaskSchdRun added in v0.0.3 

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

func (*Server) TaskSchdStart added in v0.0.3 

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

func (*Server) TaskSchdStop added in v0.0.3 

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

func (*Server) Touch added in v0.3.0 

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

func (*Server) UnloadModule added in v0.3.0 

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

func (*Server) UnsetEnv added in v0.0.3 

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

func (*Server) UpdateAcmeConfig added in v0.3.0 

func (rpc *Server) UpdateAcmeConfig(ctx context.Context, req *clientpb.AcmeConfig) (*clientpb.Empty, error)

func (*Server) UpdateCertificate added in v0.1.1 

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

func (*Server) UpdateGithubConfig added in v0.1.0 

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

func (*Server) UpdateNotifyConfig added in v0.1.0 

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

func (*Server) UpdateProfile added in v0.1.0 

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

func (*Server) UpdateWebsiteContent added in v0.1.0 

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

WebsiteUpdateContent - Update specific content from a website

func (*Server) Upload 

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

Upload - Upload a file from the remote file system

func (*Server) UploadArtifact added in v0.0.3 

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

func (*Server) WaitTaskContent 

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

func (*Server) WaitTaskFinish added in v0.0.2 

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

func (*Server) Whoami 

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

func (*Server) WmiExecute added in v0.0.3 

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

func (*Server) WmiQuery added in v0.0.3 

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

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.