core

package

Go to main page

Versions in this module

v0

v0.1.2

Sep 25, 2025

v0.1.1

Jul 8, 2025

Changes in this version

+ var ErrLuaVMDead = fmt.Errorf("lua vm is dead")

type ServerStatus

+ EventCallback map[string]func(*clientpb.Event)

+ func (s *ServerStatus) GetOrUpdateSession(sid string) (*Session, error)

type Session

+ Locker *sync.Mutex

v0.1.0

Apr 13, 2025

Changes in this version

+ var Stdout = NewStdoutWrapper(os.Stdout)

+ func HandlerTask(sess *Session, ctx *clientpb.TaskContext, message []byte, callee string, ...)

+ func NewLog(level logs.Level) *logs.Logger

+ func RemoveANSI(s string) string

+ type LogEntry struct

+ Data []byte

+ Timestamp time.Time

type Logger

+ func NewLogger(filename string) *Logger

+ func (l *Logger) FileLog(s string)

type ServerStatus

+ Pipelines map[string]*clientpb.Pipeline

+ func (s *ServerStatus) GetLocalSession(sid string) (*Session, bool)

+ func (s *ServerStatus) Update() error

+ func (s *ServerStatus) UpdatePipeline() error

type Session

+ Data *types.SessionContext

+ LastTask *clientpb.Task

+ Log *Logger

+ func (s *Session) Value(key string) (string, error)

+ func (s *Session) WithValue(kv ...string) (*Session, error)

+ type StdoutWrapper struct

+ func NewStdoutWrapper(stdout io.Writer) *StdoutWrapper

+ func (w *StdoutWrapper) GetBuffer() []LogEntry

+ func (w *StdoutWrapper) Range(start, end time.Time) string

+ func (w *StdoutWrapper) RemoveOldestEntries(count int)

+ func (w *StdoutWrapper) Write(p []byte) (n int, err error)

v0.0.4

Nov 20, 2024

v0.0.3

Nov 21, 2024

Changes in this version

+ var Debug logs.Level = 10

+ var DefaultLogStyle = map[logs.Level]string

+ var Error logs.Level = 40

+ var GroupStyle = lipgloss.NewStyle().Foreground(lipgloss.Color("#8BE9FD"))

+ var Important logs.Level = 50

+ var Info logs.Level = 30

+ var NameStyle = lipgloss.NewStyle().Foreground(lipgloss.Color("#FF79C6"))

+ var NewLine = "\x1b[1E"

+ var Warn logs.Level = 20

+ func HandleTaskContext(log *Logger, context *clientpb.TaskContext, fn *intermediate.InternalFunc, ...) error

+ type Rpc struct

type ServerStatus

+ EventHook map[intermediate.EventCondition][]intermediate.OnEventFunc

+ EventStatus bool

+ func (s *ServerStatus) AddEventHook(event intermediate.EventCondition, callback intermediate.OnEventFunc)

+ func (s *ServerStatus) AddSession(sess *clientpb.Session)

+ func (s *ServerStatus) UpdateListener() error

type Session

+ Callee string

+ func (s *Session) Clone(callee string) *Session

+ func (s *Session) GetHistory()

v0.0.2

Sep 17, 2024

Changes in this version

+ var ErrDisableOutput = errors.New("output disabled")

+ var ErrNotFoundTask = errors.New("task not found")

+ var Log = &Logger

+ var LogLevel = logs.Warn

+ var MuteLog = &Logger

+ type ActiveTarget struct

+ Observer *Observer

+ Session *Session

+ func (s *ActiveTarget) Background()

+ func (s *ActiveTarget) Context() context.Context

+ func (s *ActiveTarget) Get() *Session

+ func (s *ActiveTarget) GetInteractive() *Session

+ func (s *ActiveTarget) Set(session *Session)

+ type Logger struct

+ type Observer struct

+ Log *Logger

+ func NewObserver(session *Session) *Observer

+ func (o *Observer) SessionId() string

+ type ServerStatus struct

+ Client *clientpb.Client

+ Clients []*clientpb.Client

+ Info *clientpb.Basic

+ Listeners []*clientpb.Listener

+ Observers map[string]*Observer

+ Rpc clientrpc.MaliceRPCClient

+ Sessions map[string]*Session

+ func InitServerStatus(conn *grpc.ClientConn, config *mtls.ClientConfig) (*ServerStatus, error)

+ func (s *ServerStatus) AddCallback(task *clientpb.Task, callback TaskCallback)

+ func (s *ServerStatus) AddDoneCallback(task *clientpb.Task, callback TaskCallback)

+ func (s *ServerStatus) AddObserver(session *Session) string

+ func (s *ServerStatus) AlivedSessions() []*clientpb.Session

+ func (s *ServerStatus) CallbackOutput(event *clientpb.Event, finish bool)

+ func (s *ServerStatus) EventHandler()

+ func (s *ServerStatus) ObserverLog(sessionId string) *Logger

+ func (s *ServerStatus) RemoveObserver(observerID string)

+ func (s *ServerStatus) UpdateSession(sid string) (*clientpb.Session, error)

+ func (s *ServerStatus) UpdateSessions(all bool) error

+ func (s *ServerStatus) UpdateTasks(session *Session) error

+ type Session struct

+ Server *ServerStatus

+ func NewSession(sess *clientpb.Session, server *ServerStatus) *Session

+ func (s *Session) Console(task *clientpb.Task, msg string)

+ func (s *Session) Context() context.Context

+ func (s *Session) Error(task *clientpb.Task, err error)

+ func (s *Session) GetAddon(name string) *implantpb.Addon

+ func (s *Session) HasAddon(addon string) bool

+ func (s *Session) HasDepend(module string) bool

+ func (s *Session) HasTask(taskId uint32) bool

+ type TaskCallback func(resp *implantpb.Spite)

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