perform

func (*Admin) PerformAdminDeleteEventReport ¶

func (r *Admin) PerformAdminDeleteEventReport(ctx context.Context, reportID uint64) error

func (*Admin) PerformAdminDownloadState ¶

func (r *Admin) PerformAdminDownloadState(
	ctx context.Context,
	roomID, userID string, serverName spec.ServerName,
) error

func (*Admin) PerformAdminEvacuateRoom ¶

func (r *Admin) PerformAdminEvacuateRoom(
	ctx context.Context,
	roomID string,
) (affected []string, err error)

PerformAdminEvacuateRoom will remove all local users from the given room.

func (*Admin) PerformAdminEvacuateUser ¶

func (r *Admin) PerformAdminEvacuateUser(
	ctx context.Context,
	userID string,
) (affected []string, err error)

PerformAdminEvacuateUser will remove the given user from all rooms.

func (*Admin) PerformAdminPurgeRoom ¶

func (r *Admin) PerformAdminPurgeRoom(
	ctx context.Context,
	roomID string,
) error

PerformAdminPurgeRoom removes all traces for the given room from the database.

func (*Backfiller) PerformBackfill ¶

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

PerformBackfill implements api.RoomServerQueryAPI

func (*Creator) PerformCreateRoom ¶

func (c *Creator) PerformCreateRoom(ctx context.Context, userID spec.UserID, roomID spec.RoomID, createRequest *api.PerformCreateRoomRequest) (string, *util.JSONResponse)

PerformCreateRoom handles all the steps necessary to create a new room. nolint: gocyclo

func (*Forgetter) PerformForget ¶

func (f *Forgetter) PerformForget(
	ctx context.Context,
	request *api.PerformForgetRequest,
	response *api.PerformForgetResponse,
) error

PerformForget implements api.RoomServerQueryAPI

func (*InboundPeeker) PerformInboundPeek ¶

func (r *InboundPeeker) PerformInboundPeek(
	ctx context.Context,
	request *api.PerformInboundPeekRequest,
	response *api.PerformInboundPeekResponse,
) error

PerformInboundPeek handles peeking into matrix rooms, including over federation by talking to the federationapi. called when a remote server initiates a /peek over federation.

It should atomically figure out the current state of the room (for the response to /peek) while adding the new inbound peek to the kafka stream so the fed sender can start sending peeked events without a race between the state snapshot and the stream of peeked events.

func (*Inviter) IsKnownRoom ¶

func (r *Inviter) IsKnownRoom(ctx context.Context, roomID spec.RoomID) (bool, error)

func (*Inviter) PerformInvite ¶

func (r *Inviter) PerformInvite(
	ctx context.Context,
	req *api.PerformInviteRequest,
) error

nolint:gocyclo

func (*Inviter) ProcessInviteMembership ¶

func (r *Inviter) ProcessInviteMembership(
	ctx context.Context, inviteEvent *types.HeaderedEvent,
) ([]api.OutputEvent, error)

func (*Inviter) StateQuerier ¶

func (r *Inviter) StateQuerier() gomatrixserverlib.StateQuerier

func (*Joiner) PerformJoin ¶

func (r *Joiner) PerformJoin(
	ctx context.Context,
	req *rsAPI.PerformJoinRequest,
) (roomID string, joinedVia spec.ServerName, err error)

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

func (*Leaver) PerformLeave ¶

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

WriteOutputEvents implements OutputRoomEventWriter

func (*Peeker) PerformPeek ¶

func (r *Peeker) PerformPeek(
	ctx context.Context,
	req *api.PerformPeekRequest,
) (roomID string, err error)

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

func (*Publisher) PerformPublish ¶

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

PerformPublish publishes or unpublishes a room from the room directory. Returns a database error, if any.

func (*QueryState) GetAuthEvents ¶

func (q *QueryState) GetAuthEvents(ctx context.Context, event gomatrixserverlib.PDU) (gomatrixserverlib.AuthEventProvider, error)

func (*QueryState) GetState ¶

func (q *QueryState) GetState(ctx context.Context, roomID spec.RoomID, stateWanted []gomatrixserverlib.StateKeyTuple) ([]gomatrixserverlib.PDU, error)

func (*Unpeeker) PerformUnpeek ¶

func (r *Unpeeker) PerformUnpeek(
	ctx context.Context,
	roomID, userID, deviceID string,
) error

PerformUnpeek handles un-peeking matrix rooms, including over federation by talking to the federationapi.

func (*Upgrader) PerformRoomUpgrade ¶

func (r *Upgrader) PerformRoomUpgrade(
	ctx context.Context,
	roomID string, userID spec.UserID, roomVersion gomatrixserverlib.RoomVersion,
) (newRoomID string, err error)

PerformRoomUpgrade upgrades a room from one version to another