perform

Documentation

Index

• type Backfiller
  • func (r *Backfiller) PerformBackfill(ctx context.Context, request *api.PerformBackfillRequest, ...) error
• type Inviter
  • func (r *Inviter) PerformInvite(ctx context.Context, req *api.PerformInviteRequest, ...) ([]api.OutputEvent, error)
• type Joiner
  • func (r *Joiner) PerformJoin(ctx context.Context, req *api.PerformJoinRequest, res *api.PerformJoinResponse)
• type Leaver
  • func (r *Leaver) PerformLeave(ctx context.Context, req *api.PerformLeaveRequest, ...) ([]api.OutputEvent, error)
• type Peeker
  • func (r *Peeker) PerformPeek(ctx context.Context, req *api.PerformPeekRequest, res *api.PerformPeekResponse)
• type Publisher
  • func (r *Publisher) PerformPublish(ctx context.Context, req *api.PerformPublishRequest, ...)

Types

type Backfiller

type Backfiller struct {
	ServerName gomatrixserverlib.ServerName
	DB         storage.Database
	FSAPI      federationSenderAPI.FederationSenderInternalAPI
	KeyRing    gomatrixserverlib.JSONVerifier

	// The servers which should be preferred above other servers when backfilling
	PreferServers []gomatrixserverlib.ServerName
}

func (*Backfiller) PerformBackfill

func (r *Backfiller) PerformBackfill(
	ctx context.Context,
	request *api.PerformBackfillRequest,
	response *api.PerformBackfillResponse,
) error

PerformBackfill implements api.RoomServerQueryAPI

type Inviter

type Inviter struct {
	DB      storage.Database
	Cfg     *config.RoomServer
	FSAPI   federationSenderAPI.FederationSenderInternalAPI
	Inputer *input.Inputer
}

func (*Inviter) PerformInvite

func (r *Inviter) PerformInvite(
	ctx context.Context,
	req *api.PerformInviteRequest,
	res *api.PerformInviteResponse,
) ([]api.OutputEvent, error)

nolint:gocyclo

type Joiner

type Joiner struct {
	ServerName gomatrixserverlib.ServerName
	Cfg        *config.RoomServer
	FSAPI      fsAPI.FederationSenderInternalAPI
	DB         storage.Database

	Inputer *input.Inputer
}

func (*Joiner) PerformJoin

func (r *Joiner) PerformJoin(
	ctx context.Context,
	req *api.PerformJoinRequest,
	res *api.PerformJoinResponse,
)

PerformJoin handles joining matrix rooms, including over federation by talking to the federationsender.

type Leaver

type Leaver struct {
	Cfg   *config.RoomServer
	DB    storage.Database
	FSAPI fsAPI.FederationSenderInternalAPI

	Inputer *input.Inputer
}

func (*Leaver) PerformLeave

func (r *Leaver) PerformLeave(
	ctx context.Context,
	req *api.PerformLeaveRequest,
	res *api.PerformLeaveResponse,
) ([]api.OutputEvent, error)

WriteOutputEvents implements OutputRoomEventWriter

type Peeker

type Peeker struct {
	ServerName gomatrixserverlib.ServerName
	Cfg        *config.RoomServer
	FSAPI      fsAPI.FederationSenderInternalAPI
	DB         storage.Database

	Inputer *input.Inputer
}

func (*Peeker) PerformPeek

func (r *Peeker) PerformPeek(
	ctx context.Context,
	req *api.PerformPeekRequest,
	res *api.PerformPeekResponse,
)

PerformPeek handles peeking into matrix rooms, including over federation by talking to the federationsender.

type Publisher

type Publisher struct {
	DB storage.Database
}

func (*Publisher) PerformPublish

func (r *Publisher) PerformPublish(
	ctx context.Context,
	req *api.PerformPublishRequest,
	res *api.PerformPublishResponse,
)