core

Documentation

Index

• func EnvelopeID() uint64
• type SliverServer
  • func BindSliverServer(send, recv chan *sliverpb.Envelope) *SliverServer
  • func (ss *SliverServer) AddRespListener(envelopeID uint64, resp chan *sliverpb.Envelope)
  • func (ss *SliverServer) CreateTunnel(sliverID uint32, defaultTimeout time.Duration) (*tunnel, error)
  • func (ss *SliverServer) RPC(envelope *sliverpb.Envelope, timeout time.Duration) chan *sliverpb.Envelope
  • func (ss *SliverServer) RemoveRespListener(envelopeID uint64)
  • func (ss *SliverServer) ResponseMapper()

Functions

func EnvelopeID

func EnvelopeID() uint64

EnvelopeID - Generate random ID

Types

type SliverServer

type SliverServer struct {
	Send chan *sliverpb.Envelope

	Config  *assets.ClientConfig
	Events  chan *clientpb.Event
	Tunnels *tunnels
	// contains filtered or unexported fields
}

SliverServer - Server info

func BindSliverServer

func BindSliverServer(send, recv chan *sliverpb.Envelope) *SliverServer

BindSliverServer - Bind send/recv channels to a server

func (*SliverServer) AddRespListener

func (ss *SliverServer) AddRespListener(envelopeID uint64, resp chan *sliverpb.Envelope)

AddRespListener - Add a response listener

func (*SliverServer) CreateTunnel

func (ss *SliverServer) CreateTunnel(sliverID uint32, defaultTimeout time.Duration) (*tunnel, error)

CreateTunnel - Create a new tunnel on the server, returns tunnel metadata

func (*SliverServer) RPC

func (ss *SliverServer) RPC(envelope *sliverpb.Envelope, timeout time.Duration) chan *sliverpb.Envelope

RPC - Send a request envelope and wait for a response (blocking)

func (*SliverServer) RemoveRespListener

func (ss *SliverServer) RemoveRespListener(envelopeID uint64)

RemoveRespListener - Remove a listener

func (*SliverServer) ResponseMapper

func (ss *SliverServer) ResponseMapper()

ResponseMapper - Maps recv'd envelopes to response channels