relay

Documentation

Index

• func UpdateNodeRelayServers(node gomatrixserverlib.ServerName, relays []gomatrixserverlib.ServerName, ...)
• type RelayServerRetriever
  • func NewRelayServerRetriever(ctx context.Context, serverName gomatrixserverlib.ServerName, ...) RelayServerRetriever
  • func (r *RelayServerRetriever) GetQueriedServerStatus() map[gomatrixserverlib.ServerName]bool
  • func (r *RelayServerRetriever) GetRelayServers() []gomatrixserverlib.ServerName
  • func (r *RelayServerRetriever) InitializeRelayServers(eLog *logrus.Entry)
  • func (r *RelayServerRetriever) IsRunning() bool
  • func (r *RelayServerRetriever) SetRelayServers(servers []gomatrixserverlib.ServerName)
  • func (r *RelayServerRetriever) StartSync()
  • func (r *RelayServerRetriever) SyncRelayServers(stop <-chan bool)

Functions

func UpdateNodeRelayServers

func UpdateNodeRelayServers(
	node gomatrixserverlib.ServerName,
	relays []gomatrixserverlib.ServerName,
	ctx context.Context,
	fedAPI federationAPI.FederationInternalAPI,
)

Types

type RelayServerRetriever

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

func NewRelayServerRetriever

func NewRelayServerRetriever(
	ctx context.Context,
	serverName gomatrixserverlib.ServerName,
	federationAPI federationAPI.FederationInternalAPI,
	relayAPI relayServerAPI.RelayInternalAPI,
	quit chan bool,
) RelayServerRetriever

func (*RelayServerRetriever) GetQueriedServerStatus

func (r *RelayServerRetriever) GetQueriedServerStatus() map[gomatrixserverlib.ServerName]bool

func (*RelayServerRetriever) GetRelayServers

func (r *RelayServerRetriever) GetRelayServers() []gomatrixserverlib.ServerName

func (*RelayServerRetriever) InitializeRelayServers

func (r *RelayServerRetriever) InitializeRelayServers(eLog *logrus.Entry)

func (*RelayServerRetriever) IsRunning

func (r *RelayServerRetriever) IsRunning() bool

func (*RelayServerRetriever) SetRelayServers

func (r *RelayServerRetriever) SetRelayServers(servers []gomatrixserverlib.ServerName)

func (*RelayServerRetriever) StartSync

func (r *RelayServerRetriever) StartSync()

func (*RelayServerRetriever) SyncRelayServers

func (r *RelayServerRetriever) SyncRelayServers(stop <-chan bool)