datamesh

type Address string

type Circuit string

type Config struct {
	Listeners []*ListenerConfig
	Dialers   []*DialerConfig
	Profile   interface{}
}

type ContentType uint32

type Control struct {
	Flags   uint32
	Headers map[int32][]byte
}

type ControlFlag uint32

type Datamesh struct {
	Fwd      *Forwarder
	Handlers *Handlers
	// contains filtered or unexported fields
}

type Destination interface {
	Address() Address
	FromNetwork(data *Payload) error
	Close() error
}

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

type DialerConfig struct {
	Id          string
	BindAddress transport.Address
	LinkConfig  *LinkConfig
}

type Endpoint interface {
	Connect(txer EndpointTxer) error
	dilithium.Sink
}

type EndpointTxer interface {
	Tx(data []byte) error
}

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

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

type HeaderKey uint32

type Link interface {
	Destination
	Start() error
	Peer() *identity.TokenId
	Direction() LinkDirection
	SendControl(c *Control) error
}

type LinkConfig struct {
	PingPeriod      time.Duration
	PingQueueLength int
	MTU             uint32
}

type LinkDirection int8

type LinkDownHandler func(Link)

type LinkUpHandler func(Link)

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

type ListenerConfig struct {
	Id            string
	BindAddress   transport.Address
	Advertisement transport.Address
	LinkConfig    *LinkConfig
}

type NIC interface {
	Destination
}

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

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

type Payload struct {
	CircuitId Circuit
	Buf       *dilithium.Buffer
}

type PayloadFlag uint32

type ProxyFactory interface {
	Create() (Endpoint, error)
	Circuit() Circuit
}

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

type ProxyListenerFactory struct {
	BindAddress transport.Address
	CircuitId   Circuit
}

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

type ProxyTerminatorFactory struct {
	DialAddress transport.Address
	CircuitId   Circuit
}