s2s

Documentation

Index

• type Config
  • func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
• type S2S
  • 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()
• type TLSConfig
• type TransportConfig
  • func (c *TransportConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

Types

type Config

type Config struct {
	ID             string
	DialTimeout    time.Duration
	ConnectTimeout time.Duration
	DialbackSecret string
	MaxStanzaSize  int
	Transport      TransportConfig
}

Config represents an s2s configuration.

func (*Config) UnmarshalYAML

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

UnmarshalYAML satisfies Unmarshaler interface.

type S2S

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

S2S represents a server-to-server connection manager.

func New

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

New returns a new instance of an s2s connection manager.

func (*S2S) Enabled

func (s *S2S) Enabled() bool

Enabled returns whether or not s2s sub system is enabled.

func (*S2S) GetS2SOut

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

GetS2SOut acts as an s2s outgoing stream provider.

func (*S2S) Shutdown

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

Shutdown gracefully shuts down s2s manager.

func (*S2S) Start

func (s *S2S) Start()

Start initializes s2s manager.

type TLSConfig

type TLSConfig struct {
	CertFile    string `yaml:"cert_path"`
	PrivKeyFile string `yaml:"privkey_path"`
}

TLSConfig represents a server TLS configuration.

type TransportConfig

type TransportConfig struct {
	BindAddress string
	Port        int
	KeepAlive   time.Duration
}

TransportConfig represents s2s transport configuration.

func (*TransportConfig) UnmarshalYAML

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

UnmarshalYAML satisfies Unmarshaler interface.