pivots

Jul 15, 2024

Changes in this version

+ const PipeAllowAllAccess — windows/amd64

+ var ErrFailedKeyExchange = errors.New("failed key exchange")

+ var ErrFailedWrite = errors.New("failed to write")

+ var MyPeerID = generatePeerID()

+ var SupportedPivotListeners = map[pb.PivotType]CreateListener

+ func AddListener(listener *PivotListener)

+ func GetListeners() []*pb.PivotListener

+ func ListenerID() uint32

+ func RemoveListener(id uint32)

+ func RestartAllListeners(send chan<- *pb.Envelope)

+ func SendToPeer(envelope *pb.Envelope) (bool, error)

+ func StartListener(id uint32)

+ func StopAllListeners()

+ func StopListener(id uint32)

+ type CreateListener func(string, chan<- *pb.Envelope, ...bool) (*PivotListener, error)

+ type NetConnPivot struct

+ Downstream chan *pb.Envelope

+ func (p *NetConnPivot) Close() error

+ func (p *NetConnPivot) DownstreamPeerID() int64

+ func (p *NetConnPivot) RemoteAddress() string

+ func (p *NetConnPivot) Start(pivots *sync.Map)

+ func (p *NetConnPivot) ToProtobuf() *pb.NetConnPivot

+ type PivotListener struct

+ BindAddress string

+ ID uint32

+ Listener net.Listener

+ Options []bool

+ PivotConnections *sync.Map

+ Type pb.PivotType

+ Upstream chan<- *pb.Envelope

+ func CreateNamedPipePivotListener(address string, upstream chan<- *pb.Envelope, opts ...bool) (*PivotListener, error)

+ func CreateTCPPivotListener(address string, upstream chan<- *pb.Envelope, opts ...bool) (*PivotListener, error)

+ func (l *PivotListener) Stop()

+ func (l *PivotListener) ToProtobuf() *pb.PivotListener

+ func (p *PivotListener) Start()