xep0114

Documentation

Index

• type Config
• type SocketListener
  • func NewSocketListener(bindAddr string, port int, hosts *host.Hosts, comps *component.Components, ...) *SocketListener
  • func (l *SocketListener) Start(ctx context.Context) error
  • func (l *SocketListener) Stop(ctx context.Context) error

Types

type Config

type Config struct {
	// ConnectTimeout defines connection timeout.
	ConnectTimeout time.Duration

	// KeepAliveTimeout defines the maximum amount of time that an inactive connection
	// would be considered alive.
	KeepAliveTimeout time.Duration

	// RequestTimeout defines component stream request timeout.
	RequestTimeout time.Duration

	// MaxStanzaSize is the maximum size a listener incoming stanza may have.
	MaxStanzaSize int

	// Secret is the external component shared secret.
	Secret string
}

Config defines component connection configuration.

type SocketListener

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

SocketListener represents a component socket listener type.

func NewSocketListener

func NewSocketListener(
	bindAddr string,
	port int,
	hosts *host.Hosts,
	comps *component.Components,
	extCompMng *extcomponentmanager.Manager,
	router router.Router,
	shapers shaper.Shapers,
	hk *hook.Hooks,
	cfg Config,
) *SocketListener

NewSocketListener returns a new external component socket listener.

func (*SocketListener) Start

func (l *SocketListener) Start(ctx context.Context) error

Start starts listening on the TCP network address bindAddr to handle incoming connections.

func (*SocketListener) Stop

func (l *SocketListener) Stop(ctx context.Context) error

Stop stops handling incoming connections and closes underlying TCP listener.