relay

Documentation

Index

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

Functions

func UpdateNodeRelayServers

func UpdateNodeRelayServers(
	node spec.ServerName,
	relays []spec.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 spec.ServerName,
	federationAPI federationAPI.FederationInternalAPI,
	relayAPI relayServerAPI.RelayInternalAPI,
	quit chan bool,
) RelayServerRetriever

func (*RelayServerRetriever) GetQueriedServerStatus

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

func (*RelayServerRetriever) GetRelayServers

func (r *RelayServerRetriever) GetRelayServers() []spec.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 []spec.ServerName)

func (*RelayServerRetriever) StartSync

func (r *RelayServerRetriever) StartSync()

func (*RelayServerRetriever) SyncRelayServers

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