federationapi

package
v0.0.0-...-9835270 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0, MIT Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FederationAPIComponent

type FederationAPIComponent struct {
	Repo *repos.RoomServerCurStateRepo
	// contains filtered or unexported fields
}

func NewFederationAPIComponent

func NewFederationAPIComponent(
	cfg *config.Fed,
	_cache service.Cache,
	fedClient *client.FedClientWrap,
	fedDB fedmodel.FederationDatabase,
	keyDB dbmodel.KeyDatabase,
	feddomains *common.FedDomains,
	fedRpcCli *rpc.FederationRpcClient,
	backfillRepo *fedrepos.BackfillRepo,
	joinRoomsRepo *fedrepos.JoinRoomsRepo,
	backfillProc backfilltypes.BackFillProcessor,
	publicroomsAPI publicroomsapi.PublicRoomsQueryAPI,
	rpcClient *common.RpcClient,
	encryptionDB dbmodel.EncryptorAPIDatabase,
	c *cert.Cert,
	idg *uid.UidGenerator,
	complexCache *common.ComplexCache,
) *FederationAPIComponent

func (*FederationAPIComponent) OnMessage

func (fed *FederationAPIComponent) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*FederationAPIComponent) SetRepo

func (*FederationAPIComponent) Setup

func (fed *FederationAPIComponent) Setup()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL