internal

Documentation

Index

• type RelayInternalAPI
  • func NewRelayInternalAPI(db storage.Database, fedClient fclient.FederationClient, ...) *RelayInternalAPI
  • func (r *RelayInternalAPI) PerformRelayServerSync(ctx context.Context, userID spec.UserID, relayServer spec.ServerName) error
  • func (r *RelayInternalAPI) PerformStoreTransaction(ctx context.Context, transaction gomatrixserverlib.Transaction, ...) error
  • func (r *RelayInternalAPI) QueryTransactions(ctx context.Context, userID spec.UserID, previousEntry fclient.RelayEntry) (api.QueryRelayTransactionsResponse, error)
  • func (r *RelayInternalAPI) RelayingEnabled() bool
  • func (r *RelayInternalAPI) SetRelayingEnabled(enabled bool)

Types

type RelayInternalAPI

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

func NewRelayInternalAPI

func NewRelayInternalAPI(
	db storage.Database,
	fedClient fclient.FederationClient,
	rsAPI rsAPI.RoomserverInternalAPI,
	keyRing *gomatrixserverlib.KeyRing,
	producer *producers.SyncAPIProducer,
	presenceEnabledInbound bool,
	serverName spec.ServerName,
	relayingEnabled bool,
) *RelayInternalAPI

func (*RelayInternalAPI) PerformRelayServerSync

func (r *RelayInternalAPI) PerformRelayServerSync(
	ctx context.Context,
	userID spec.UserID,
	relayServer spec.ServerName,
) error

PerformRelayServerSync implements api.RelayInternalAPI

func (*RelayInternalAPI) PerformStoreTransaction

func (r *RelayInternalAPI) PerformStoreTransaction(
	ctx context.Context,
	transaction gomatrixserverlib.Transaction,
	userID spec.UserID,
) error

PerformStoreTransaction implements api.RelayInternalAPI

func (*RelayInternalAPI) QueryTransactions

func (r *RelayInternalAPI) QueryTransactions(
	ctx context.Context,
	userID spec.UserID,
	previousEntry fclient.RelayEntry,
) (api.QueryRelayTransactionsResponse, error)

QueryTransactions implements api.RelayInternalAPI

func (*RelayInternalAPI) RelayingEnabled

func (r *RelayInternalAPI) RelayingEnabled() bool

RelayingEnabled implements api.RelayInternalAPI

func (*RelayInternalAPI) SetRelayingEnabled

func (r *RelayInternalAPI) SetRelayingEnabled(enabled bool)

SetRelayingEnabled implements api.RelayInternalAPI