transports

Documentation

Index

• func C2Generator(c2Servers []string, abort <-chan struct{}) <-chan *url.URL
• func GetMaxConnectionErrors() int
• func GetReconnectInterval() time.Duration
• func SetReconnectInterval(interval int64)
• func StartBeaconLoop(c2s []string, abort <-chan struct{}) <-chan *Beacon
• func StartConnectionLoop(c2s []string, abort <-chan struct{}) <-chan *Connection
• type Beacon
  • func (b *Beacon) Duration() time.Duration
  • func (b *Beacon) Interval() int64
  • func (b *Beacon) Jitter() int64
• type BeaconCleanup
• type BeaconClose
• type BeaconInit
• type BeaconRecv
• type BeaconSend
• type BeaconStart
• type Connection
  • func (c *Connection) AddTunnel(tun *Tunnel)
  • func (c *Connection) Cleanup()
  • func (c *Connection) ProxyURL() string
  • func (c *Connection) RemoveTunnel(ID uint64)
  • func (c *Connection) RequestResend(data []byte)
  • func (c *Connection) Tunnel(ID uint64) *Tunnel
  • func (c *Connection) URL() string
• type Start
• type Stop
• type Tunnel

Functions

func C2Generator

func C2Generator(c2Servers []string, abort <-chan struct{}) <-chan *url.URL

C2Generator - Creates a stream of C2 URLs based on a connection strategy

func GetMaxConnectionErrors

func GetMaxConnectionErrors() int

GetMaxConnectionErrors - Parse the max connection errors inserted at compile-time

func GetReconnectInterval

func GetReconnectInterval() time.Duration

GetReconnectInterval - Parse the reconnect interval inserted at compile-time

func SetReconnectInterval

func SetReconnectInterval(interval int64)

SetReconnectInterval - Runtime set the running reconnect interval

func StartBeaconLoop

func StartBeaconLoop(c2s []string, abort <-chan struct{}) <-chan *Beacon

StartBeaconLoop - Starts the beacon loop generator

func StartConnectionLoop

func StartConnectionLoop(c2s []string, abort <-chan struct{}) <-chan *Connection

StartConnectionLoop - Starts the main connection loop

Types

type Beacon

type Beacon struct {
	Init    BeaconInit
	Start   BeaconStart
	Send    BeaconSend
	Recv    BeaconRecv
	Close   BeaconClose
	Cleanup BeaconCleanup

	ActiveC2 string
	ProxyURL string
}

Beacon - Abstract connection to the server

func (*Beacon) Duration

func (b *Beacon) Duration() time.Duration

Duration - Interval + random value <= Jitter

func (*Beacon) Interval

func (b *Beacon) Interval() int64

Interval - Interval between beacons

func (*Beacon) Jitter

func (b *Beacon) Jitter() int64

Jitter - Jitter between beacons

type BeaconCleanup

type BeaconCleanup func() error

type BeaconClose

type BeaconClose func() error

type BeaconInit

type BeaconInit func() error

type BeaconRecv

type BeaconRecv func() (*pb.Envelope, error)

type BeaconSend

type BeaconSend func(*pb.Envelope) error

type BeaconStart

type BeaconStart func() error

type Connection

type Connection struct {
	Send   chan *pb.Envelope
	Recv   chan *pb.Envelope
	IsOpen bool

	Start Start
	Stop  Stop
	// contains filtered or unexported fields
}

Connection - Abstract connection to the server

func (*Connection) AddTunnel

func (c *Connection) AddTunnel(tun *Tunnel)

AddTunnel - Add tunnel to mapping

func (*Connection) Cleanup

func (c *Connection) Cleanup()

Cleanup - Execute cleanup once

func (*Connection) ProxyURL

func (c *Connection) ProxyURL() string

ProxyURL - Get the c2 URL of the connection

func (*Connection) RemoveTunnel

func (c *Connection) RemoveTunnel(ID uint64)

RemoveTunnel - Add tunnel to mapping

func (*Connection) RequestResend

func (c *Connection) RequestResend(data []byte)

func (*Connection) Tunnel

func (c *Connection) Tunnel(ID uint64) *Tunnel

Tunnel - Add tunnel to mapping

func (*Connection) URL

func (c *Connection) URL() string

URL - Get the c2 URL of the connection

type Start

type Start func() error

type Stop

type Stop func() error

type Tunnel

type Tunnel struct {
	ID uint64

	Reader       io.ReadCloser
	ReadSequence uint64

	Writer        io.WriteCloser
	WriteSequence uint64
}

Tunnel - Duplex byte read/write