sluice

Documentation

Index

• Variables
• func AwaitRequest(pkt *packet.Info, domain string) error
• func StartStreamSluice(network, address string)
• type Request
• type Sluice
• type SluiceBase
  • func (s *SluiceBase) Abandon()
  • func (s *SluiceBase) AwaitRequest(r *Request)
• type StreamSluice

Variables

var (
	// ErrUnsupported is returned when a protocol is not supported.
	ErrUnsupported = errors.New("unsupported protocol")

	// ErrSluiceOffline is returned when the sluice for a network is offline.
	ErrSluiceOffline = errors.New("is offline")
)

Functions

func AwaitRequest

func AwaitRequest(pkt *packet.Info, domain string) error

func StartStreamSluice

func StartStreamSluice(network, address string)

Types

type Request

type Request struct {
	Domain string
	Info   *packet.Info
}

type Sluice

type Sluice interface {
	AwaitRequest(r *Request)
	Abandon()
}

type SluiceBase

type SluiceBase struct {
	// contains filtered or unexported fields
}

func (*SluiceBase) Abandon

func (s *SluiceBase) Abandon()

func (*SluiceBase) AwaitRequest

func (s *SluiceBase) AwaitRequest(r *Request)

type StreamSluice

type StreamSluice struct {
	SluiceBase
}