s2s

Mar 15, 2021

Changes in this version

type Options

+ TLSConfig *tls.Config

+ UseTLS bool

Feb 22, 2021

Changes in this version

+ func NewRouter(outProvider *OutProvider) router.S2SRouter

+ type DialbackParams struct

+ From string

+ Key string

+ StreamID string

+ To string

+ type InHub struct

+ func NewInHub() *InHub

+ func (h *InHub) Start(_ context.Context) error

+ func (h *InHub) Stop(ctx context.Context) error

+ type Options struct

+ ConnectTimeout time.Duration

+ DialTimeout time.Duration

+ DialbackSecret string

+ KeepAlive time.Duration

+ MaxStanzaSize int

+ RequestTimeout time.Duration

type OutProvider

+ func (p *OutProvider) GetDialback(ctx context.Context, sender, target string, params DialbackParams) (stream.S2SDialback, error)

+ func (p *OutProvider) Start(_ context.Context) error

+ func (p *OutProvider) Stop(ctx context.Context) error

+ type SocketListener struct

+ func NewSocketListener(bindAddr string, port int, hosts *host.Hosts, router router.Router, ...) *SocketListener

+ func (l *SocketListener) Start(_ context.Context) error

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

Mar 23, 2020

Changes in this version

type Config

+ KeepAlive time.Duration

+ type Dialer interface

+ Dial func(ctx context.Context, remoteDomain string) (net.Conn, error)

+ type OutProvider struct

+ func NewOutProvider(config *Config, hosts *host.Hosts) *OutProvider

+ func (p *OutProvider) GetOut(localDomain, remoteDomain string) stream.S2SOut

+ func (p *OutProvider) Shutdown(ctx context.Context) error

Dec 27, 2019

Changes in this version

type Config

+ Timeout time.Duration

Jan 14, 2019

Changes in this version

type S2S

+ func (s *S2S) GetOut(localDomain, remoteDomain string) (stream.S2SOut, error)

Nov 3, 2018

Changes in this version

+ type S2S struct

+ func New(config *Config, mods *module.Modules, router *router.Router) *S2S

+ func (s *S2S) Enabled() bool

+ func (s *S2S) GetS2SOut(localDomain, remoteDomain string) (stream.S2SOut, error)

+ func (s *S2S) Shutdown(ctx context.Context)

+ func (s *S2S) Start()

Sep 3, 2018

Changes in this version

type Config

+ ID string

Jul 6, 2018

Changes in this version

+ func GetS2SOut(localDomain, remoteDomain string) (stream.S2SOut, error)

+ func Initialize(cfg *Config, modConfig *module.Config)

+ func Shutdown()

+ type Config struct

+ ConnectTimeout time.Duration

+ DialTimeout time.Duration

+ DialbackSecret string

+ Enabled bool

+ MaxStanzaSize int

+ Transport TransportConfig

+ func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type TLSConfig struct

+ CertFile string

+ PrivKeyFile string

+ type TransportConfig struct

+ BindAddress string

+ KeepAlive time.Duration

+ Port int

+ func (c *TransportConfig) UnmarshalYAML(unmarshal func(interface{}) error) error