xlink_transport

Documentation

Index

• Constants
• func NewFactory(accepter xlink.Acceptor, bindHandlerFactory BindHandlerFactory, ...) xlink.Factory
• type BindHandlerFactory
• type ConnectionHandler
  • func (self *ConnectionHandler) HandleConnection(_ *channel.Hello, certificates []*x509.Certificate) error

Constants

const (
	LinkHeaderConnId        = 0
	LinkHeaderType          = 1
	LinkHeaderRouterId      = 2
	LinkHeaderRouterVersion = 3

	PayloadChannel channelType = 1
	AckChannel     channelType = 2
)

Functions

func NewFactory

func NewFactory(accepter xlink.Acceptor,
	bindHandlerFactory BindHandlerFactory,
	c transport.Configuration,
	xlinkRegistry xlink.Registry,
	metricsRegistry metrics.Registry) xlink.Factory

Types

type BindHandlerFactory

type BindHandlerFactory interface {
	NewBindHandler(xlink xlink.Xlink, latency bool, listenerSide bool) channel.BindHandler
}

BindHandlerFactory can be implemented and provided to the factory to perform channel binding and other channel setup tasks at accept time.

type ConnectionHandler

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

func (*ConnectionHandler) HandleConnection

func (self *ConnectionHandler) HandleConnection(_ *channel.Hello, certificates []*x509.Certificate) error