xlink_transport

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MinRetryInterval = 10 * time.Millisecond
	MaxRetryInterval = 24 * time.Hour

	MinRetryBackoffFactor = 1
	MaxRetryBackoffFactor = 100

	DefaultHealthyMinRetryInterval   = 5 * time.Second
	DefaultHealthyMaxRetryInterval   = 5 * time.Minute
	DefaultHealthyRetryBackoffFactor = 1.5

	DefaultUnhealthyMinRetryInterval   = time.Minute
	DefaultUnhealthyMaxRetryInterval   = time.Hour
	DefaultUnhealthyRetryBackoffFactor = 10
)
View Source
const (
	LinkHeaderConnId        = 0
	LinkHeaderType          = 1
	LinkHeaderRouterId      = 2
	LinkHeaderRouterVersion = 3
	LinkHeaderBinding       = 4
	LinkHeaderIteration     = 5

	PayloadChannel channelType = 1
	AckChannel     channelType = 2
)

Variables

This section is empty.

Functions

func NewFactory

func NewFactory(accepter xlink.Acceptor,
	bindHandlerFactory BindHandlerFactory,
	tcfg 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL