core

package

Go to main page

Versions in this module

v0

v0.1.2

Sep 25, 2025

Changes in this version

+ var ListenerSessions = &listenerSessions

+ func GetKeyPairForSession(sid uint32, secureConfig *types.SecureConfig) *clientpb.KeyPair

type Connection

+ func GetConnection(conn *cryptostream.Conn, pipelineID string, secureConfig *types.SecureConfig) (*Connection, error)

type PipelineConfig

+ SecureConfig *types.SecureConfig

+ type SecureManager struct

+ func NewSecureSpiteManager(sess *Session) *SecureManager

+ func (s *SecureManager) IncrementCounter()

+ func (s *SecureManager) ResetCounters()

+ func (s *SecureManager) ShouldRotateKey() bool

+ func (s *SecureManager) UpdateKeyPair(keyPair *clientpb.KeyPair)

type Session

+ SecureManager *SecureManager

+ func (s *Session) FillSysInfo()

+ func (s *Session) PushCtrl()

+ func (s *Session) Save() error

+ func (s *Session) UpdateKeyPair(keyPair *clientpb.KeyPair)

+ func (s *Session) UpdatePrivateKey(key string)

+ func (s *Session) UpdatePublicKey(key string)

v0.1.1

Jul 8, 2025

Changes in this version

type PipelineConfig

+ TLSConfig *types.TlsConfig

+ func FromPipeline(pipeline *clientpb.Pipeline) *PipelineConfig

type Session

+ Cancel context.CancelFunc

+ CreatedAt time.Time

+ Ctx context.Context

+ func (s *Session) PushUpdate(msg string)

v0.1.0

Apr 13, 2025

Changes in this version

+ var CacheName = "cache.bin"

+ func HandleFileOperations(op string, data []byte, task *Task) error

+ func HandleScreenshot(data []byte, task *Task) error

+ func LoadContext(ctx output.Context) (output.Context, error)

+ func PushContextEvent(Op string, ctx *models.Context)

+ func ReadFileForContext(ctx output.Context) ([]byte, error)

+ func SaveContext(ctx output.Context, task *Task) (*models.Context, error)

type Connection

+ func (c *Connection) HandlerSimplex(ctx context.Context, conn *peek.Conn) error

type Event

+ Important bool

+ func (event *Event) String() string

+ func (event *Event) ToProtobuf() *clientpb.Event

type Forward

+ ListenerId string

+ func (f *Forward) Context(sid string) context.Context

type Job

+ Pipeline *clientpb.Pipeline

type Listener

+ Ctrl chan *clientpb.JobCtrl

+ CtrlJob *sync.Map

+ IP string

+ func (l *Listener) PushCtrl(ctrl *clientpb.JobCtrl) uint32

+ func (l *Listener) WaitCtrl(i uint32) *clientpb.JobStatus

+ type RingCache struct

+ func NewMessageCache(capacity int) *RingCache

+ func (mc *RingCache) Add(message interface{})

+ func (mc *RingCache) GetAll() []interface{}

+ func (mc *RingCache) GetLast() interface{}

+ func (mc *RingCache) GetN(n int) []interface{}

type Session

+ Note string

+ func (s *Session) Abstract() string

v0.0.4

Nov 20, 2024

v0.0.3

Nov 21, 2024

Changes in this version

+ func GetCurrentID() uint32

+ func NewBroker() *eventBroker

+ func NewSessions() *sessions

type Connection

+ Parser *parser.MessageParser

+ PipelineID string

+ func (c *Connection) Handler(ctx context.Context, conn *peek.Conn) error

type Event

+ Callee string

type Forward

+ Stream listenerrpc.ListenerRPC_SpiteStreamClient

type Listener

+ func (l *Listener) AddPipeline(pipeline *clientpb.Pipeline)

+ func (l *Listener) AllPipelines() []*clientpb.Pipeline

+ func (l *Listener) GetPipeline(name string) *clientpb.Pipeline

+ func (l *Listener) RemovePipeline(pipeline *clientpb.Pipeline)

type Message

+ RawID uint32

+ Spites *implantpb.Spites

+ type PipelineConfig struct

+ Encryption *configs.EncryptionConfig

+ ListenerID string

+ Parser string

+ Tls *configs.CertConfig

+ func FromProtobuf(pipeline *clientpb.Pipeline) *PipelineConfig

+ func (p *PipelineConfig) WrapConn(conn net.Conn) (*peek.Conn, error)

type Session

+ Initialized bool

+ LastCheckin int64

+ RawID uint32

+ Target string

+ Taskseq uint32

+ Type string

+ func RecoverSession(sess *clientpb.Session) (*Session, error)

+ func RegisterSession(req *clientpb.RegisterSession) (*Session, error)

+ func (s *Session) Publish(Op string, msg string)

+ func (s *Session) Recover() error

+ func (s *Session) RecoverTaskIDByLog() (int, error)

+ func (s *Session) RpcLogger() *logs.Logger

+ func (s *Session) TaskLog(task *Task, spite *implantpb.Spite) error

+ func (s *Session) ToModel() *models.Session

+ func (s *Session) ToProtobufLite() *clientpb.Session

type Task

+ CallBy string

+ Callee string

+ Closed bool

+ Deadline time.Time

+ func FromTaskProtobuf(task *clientpb.Task) *Task

+ func (t *Task) Finished() bool

+ func (t *Task) Publish(op string, spite *implantpb.Spite, msg string)

+ func (t *Task) TaskID() string

+ func (t *Task) Timeout() bool

type Tasks

+ func NewTasks() *Tasks

+ func (t *Tasks) GetNotFinish() []*clientpb.Task

v0.0.2

Sep 17, 2024

Changes in this version

type Event

+ IsNotify bool

+ Op string

+ Spite *implantpb.Spite

type Job

+ Name string

+ type Notifier struct

+ func (n *Notifier) Send(event *Event) error

type Session

+ Addons *implantpb.Addons

+ ListenerID string

type Task

+ DoneCh chan bool

+ Session *Session

v0.0.1

Aug 21, 2024

Changes in this version

+ var Clients = &clients

+ var Connections = &connections

+ var ErrImplantSendTimeout = errors.New("implant timeout")

+ var ErrUnknownMessageType = errors.New("unknown message type")

+ var EventBroker = newBroker()

+ var ExtensionModules = []string

+ var Forwarders = &forwarders

+ var Jobs = &jobs

+ var Listeners = listeners

+ var Sessions = &sessions

+ func CurrentJobID() uint32

+ func NextCtrlID() uint32

+ func NextJobID() uint32

+ type Cache struct

+ func NewCache(maxSize int, savePath string) *Cache

+ func (c *Cache) AddMessage(spite *implantpb.Spite, cur int)

+ func (c *Cache) GetAll()

+ func (c *Cache) GetLastMessage(taskID int) (*implantpb.Spite, bool)

+ func (c *Cache) GetMessage(taskID, cur int) (*implantpb.Spite, bool)

+ func (c *Cache) GetMessages(taskID int) ([]*implantpb.Spite, bool)

+ func (c *Cache) Load() error

+ func (c *Cache) Save() error

+ func (c *Cache) SetSize(size int)

+ type Client struct

+ func NewClient(operatorName string) *Client

+ func (c *Client) ToProtobuf() *clientpb.Client

+ type Connection struct

+ Alive bool

+ C chan *implantpb.Spite

+ LastMessage time.Time

+ RawID []byte

+ Sender chan *implantpb.Spites

+ SessionID string

+ func NewConnection(rawid []byte) *Connection

+ func (c *Connection) Send(ctx context.Context, conn net.Conn)

+ type Event struct

+ Client *Client

+ Data []byte

+ Err string

+ EventType string

+ Job *Job

+ Message string

+ Session *Session

+ SourceName string

+ Task *Task

+ type Forward struct

+ ImplantRpc listenerrpc.ImplantRPCClient

+ ListenerRpc listenerrpc.ListenerRPCClient

+ func NewForward(conn *grpc.ClientConn, pipeline Pipeline) (*Forward, error)

+ func (f *Forward) Add(msg *Message)

+ func (f *Forward) Count() int

+ func (f *Forward) Handler()

+ type Job struct

+ ID uint32

+ JobCtrl chan bool

+ Message proto.Message

+ PersistentID string

+ func (j *Job) ToProtobuf() *clientpb.Job

+ type Listener struct

+ Active bool

+ Host string

+ Name string

+ Pipelines Pipelines

+ func (l *Listener) ToProtobuf() *clientpb.Listener

+ type Message struct

+ MessageID string

+ RemoteAddr string

+ SessionID string

+ type Pipeline interface

+ Addr func() string

+ Close func() error

+ ID func() string

+ Start func() error

+ ToProtobuf func() proto.Message

+ ToTLSProtobuf func() proto.Message

+ type Pipelines map[string]Pipeline

+ func (ps Pipelines) Add(p Pipeline)

+ func (ps Pipelines) Get(id string) Pipeline

+ func (ps Pipelines) ToProtobuf() *lispb.Pipelines

+ type Session struct

+ Extensions *implantpb.Extensions

+ Filepath string

+ Group string

+ ID string

+ Locale string

+ Modules []string

+ Name string

+ Os *implantpb.Os

+ PipelineID string

+ Process *implantpb.Process

+ ProxyURL string

+ RemoteAddr string

+ Tasks *Tasks

+ Timer *implantpb.Timer

+ WordDir string

+ func NewSession(req *lispb.RegisterSession) *Session

+ func (s *Session) AllTask() []*Task

+ func (s *Session) DeleteResp(taskId uint32)

+ func (s *Session) GetResp(taskId uint32) (chan *implantpb.Spite, bool)

+ func (s *Session) Logger() *logs.Logger

+ func (s *Session) NewTask(name string, total int) *Task

+ func (s *Session) Request(msg *lispb.SpiteSession, stream grpc.ServerStream, timeout time.Duration) error

+ func (s *Session) RequestAndWait(msg *lispb.SpiteSession, stream grpc.ServerStream, timeout time.Duration) (*implantpb.Spite, error)

+ func (s *Session) RequestWithAsync(msg *lispb.SpiteSession, stream grpc.ServerStream, timeout time.Duration) (chan *implantpb.Spite, error)

+ func (s *Session) RequestWithStream(msg *lispb.SpiteSession, stream grpc.ServerStream, timeout time.Duration) (chan *implantpb.Spite, chan *implantpb.Spite, error)

+ func (s *Session) SetLastTaskId(id uint32)

+ func (s *Session) StoreResp(taskId uint32, ch chan *implantpb.Spite)

+ func (s *Session) ToProtobuf() *clientpb.Session

+ func (s *Session) Update(req *lispb.RegisterSession)

+ func (s *Session) UpdateLastCheckin()

+ func (s *Session) UpdateSysInfo(info *implantpb.SysInfo)

+ type Task struct

+ Callback func()

+ Cancel context.CancelFunc

+ Ctx context.Context

+ Cur int

+ Id uint32

+ SessionId string

+ Status *implantpb.Spite

+ Total int

+ Type string

+ func (t *Task) Close()

+ func (t *Task) Done(event Event)

+ func (t *Task) Finish()

+ func (t *Task) Handler()

+ func (t *Task) Name() string

+ func (t *Task) Panic(event Event, status *implantpb.Spite)

+ func (t *Task) Percent() string

+ func (t *Task) String() string

+ func (t *Task) ToProtobuf() *clientpb.Task

+ type Tasks struct

+ func (t *Tasks) Add(task *Task)

+ func (t *Tasks) All() []*Task

+ func (t *Tasks) Get(taskID uint32) *Task

+ func (t *Tasks) Remove(task *Task)

+ func (t *Tasks) ToProtobuf() *clientpb.Tasks

+ type Ticker struct

+ var GlobalTicker *Ticker

+ func NewTicker() *Ticker

+ func (t *Ticker) Remove(id cron.EntryID)

+ func (t *Ticker) RemoveAll()

+ func (t *Ticker) Start(interval int, cmd func()) (cron.EntryID, error)

+ type Website interface

+ Addr func() string

+ Close func() error

+ ID func() string

+ Start func() error

+ ToProtobuf func() proto.Message

+ ToTLSProtobuf func() proto.Message

+ type Websites map[string]Website

+ func (web Websites) Add(w Website)

+ func (web Websites) Get(id string) Website

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