query

Documentation

Index

• func GetAuthChain(ctx context.Context, fn eventsFromIDs, authEventIDs []string) ([]*gomatrixserverlib.Event, error)
• type Queryer
  • func (r *Queryer) QueryAuthChain(ctx context.Context, req *api.QueryAuthChainRequest, ...) error
  • func (r *Queryer) QueryBulkStateContent(ctx context.Context, req *api.QueryBulkStateContentRequest, ...) error
  • func (r *Queryer) QueryCurrentState(ctx context.Context, req *api.QueryCurrentStateRequest, ...) error
  • func (r *Queryer) QueryEventsByID(ctx context.Context, request *api.QueryEventsByIDRequest, ...) error
  • func (r *Queryer) QueryKnownUsers(ctx context.Context, req *api.QueryKnownUsersRequest, ...) error
  • func (r *Queryer) QueryLatestEventsAndState(ctx context.Context, request *api.QueryLatestEventsAndStateRequest, ...) error
  • func (r *Queryer) QueryMembershipForUser(ctx context.Context, request *api.QueryMembershipForUserRequest, ...) error
  • func (r *Queryer) QueryMembershipsForRoom(ctx context.Context, request *api.QueryMembershipsForRoomRequest, ...) error
  • func (r *Queryer) QueryMissingAuthPrevEvents(ctx context.Context, request *api.QueryMissingAuthPrevEventsRequest, ...) error
  • func (r *Queryer) QueryMissingEvents(ctx context.Context, request *api.QueryMissingEventsRequest, ...) error
  • func (r *Queryer) QueryPublishedRooms(ctx context.Context, req *api.QueryPublishedRoomsRequest, ...) error
  • func (r *Queryer) QueryRoomVersionCapabilities(ctx context.Context, request *api.QueryRoomVersionCapabilitiesRequest, ...) error
  • func (r *Queryer) QueryRoomVersionForRoom(ctx context.Context, request *api.QueryRoomVersionForRoomRequest, ...) error
  • func (r *Queryer) QueryRoomsForUser(ctx context.Context, req *api.QueryRoomsForUserRequest, ...) error
  • func (r *Queryer) QueryServerAllowedToSeeEvent(ctx context.Context, request *api.QueryServerAllowedToSeeEventRequest, ...) (err error)
  • func (r *Queryer) QueryServerBannedFromRoom(ctx context.Context, req *api.QueryServerBannedFromRoomRequest, ...) error
  • func (r *Queryer) QueryServerJoinedToRoom(ctx context.Context, request *api.QueryServerJoinedToRoomRequest, ...) error
  • func (r *Queryer) QuerySharedUsers(ctx context.Context, req *api.QuerySharedUsersRequest, ...) error
  • func (r *Queryer) QueryStateAfterEvents(ctx context.Context, request *api.QueryStateAfterEventsRequest, ...) error
  • func (r *Queryer) QueryStateAndAuthChain(ctx context.Context, request *api.QueryStateAndAuthChainRequest, ...) error

Functions

func GetAuthChain

func GetAuthChain(
	ctx context.Context, fn eventsFromIDs, authEventIDs []string,
) ([]*gomatrixserverlib.Event, error)

GetAuthChain fetches the auth chain for the given auth events. An auth chain is the list of all events that are referenced in the auth_events section, and all their auth_events, recursively. The returned set of events contain the given events. Will *not* error if we don't have all auth events.

Types

type Queryer

type Queryer struct {
	DB         storage.Database
	Cache      caching.RoomServerCaches
	ServerACLs *acls.ServerACLs
}

func (*Queryer) QueryAuthChain

func (r *Queryer) QueryAuthChain(ctx context.Context, req *api.QueryAuthChainRequest, res *api.QueryAuthChainResponse) error

func (*Queryer) QueryBulkStateContent

func (r *Queryer) QueryBulkStateContent(ctx context.Context, req *api.QueryBulkStateContentRequest, res *api.QueryBulkStateContentResponse) error

func (*Queryer) QueryCurrentState

func (r *Queryer) QueryCurrentState(ctx context.Context, req *api.QueryCurrentStateRequest, res *api.QueryCurrentStateResponse) error

func (*Queryer) QueryEventsByID

func (r *Queryer) QueryEventsByID(
	ctx context.Context,
	request *api.QueryEventsByIDRequest,
	response *api.QueryEventsByIDResponse,
) error

QueryEventsByID implements api.RoomserverInternalAPI

func (*Queryer) QueryKnownUsers

func (r *Queryer) QueryKnownUsers(ctx context.Context, req *api.QueryKnownUsersRequest, res *api.QueryKnownUsersResponse) error

func (*Queryer) QueryLatestEventsAndState

func (r *Queryer) QueryLatestEventsAndState(
	ctx context.Context,
	request *api.QueryLatestEventsAndStateRequest,
	response *api.QueryLatestEventsAndStateResponse,
) error

QueryLatestEventsAndState implements api.RoomserverInternalAPI

func (*Queryer) QueryMembershipForUser

func (r *Queryer) QueryMembershipForUser(
	ctx context.Context,
	request *api.QueryMembershipForUserRequest,
	response *api.QueryMembershipForUserResponse,
) error

QueryMembershipForUser implements api.RoomserverInternalAPI

func (*Queryer) QueryMembershipsForRoom

func (r *Queryer) QueryMembershipsForRoom(
	ctx context.Context,
	request *api.QueryMembershipsForRoomRequest,
	response *api.QueryMembershipsForRoomResponse,
) error

QueryMembershipsForRoom implements api.RoomserverInternalAPI

func (*Queryer) QueryMissingAuthPrevEvents

func (r *Queryer) QueryMissingAuthPrevEvents(
	ctx context.Context,
	request *api.QueryMissingAuthPrevEventsRequest,
	response *api.QueryMissingAuthPrevEventsResponse,
) error

QueryMissingAuthPrevEvents implements api.RoomserverInternalAPI

func (*Queryer) QueryMissingEvents

func (r *Queryer) QueryMissingEvents(
	ctx context.Context,
	request *api.QueryMissingEventsRequest,
	response *api.QueryMissingEventsResponse,
) error

QueryMissingEvents implements api.RoomserverInternalAPI nolint:gocyclo

func (*Queryer) QueryPublishedRooms

func (r *Queryer) QueryPublishedRooms(
	ctx context.Context,
	req *api.QueryPublishedRoomsRequest,
	res *api.QueryPublishedRoomsResponse,
) error

func (*Queryer) QueryRoomVersionCapabilities

func (r *Queryer) QueryRoomVersionCapabilities(
	ctx context.Context,
	request *api.QueryRoomVersionCapabilitiesRequest,
	response *api.QueryRoomVersionCapabilitiesResponse,
) error

QueryRoomVersionCapabilities implements api.RoomserverInternalAPI

func (*Queryer) QueryRoomVersionForRoom

func (r *Queryer) QueryRoomVersionForRoom(
	ctx context.Context,
	request *api.QueryRoomVersionForRoomRequest,
	response *api.QueryRoomVersionForRoomResponse,
) error

QueryRoomVersionCapabilities implements api.RoomserverInternalAPI

func (*Queryer) QueryRoomsForUser

func (r *Queryer) QueryRoomsForUser(ctx context.Context, req *api.QueryRoomsForUserRequest, res *api.QueryRoomsForUserResponse) error

func (*Queryer) QueryServerAllowedToSeeEvent

func (r *Queryer) QueryServerAllowedToSeeEvent(
	ctx context.Context,
	request *api.QueryServerAllowedToSeeEventRequest,
	response *api.QueryServerAllowedToSeeEventResponse,
) (err error)

QueryServerAllowedToSeeEvent implements api.RoomserverInternalAPI

func (*Queryer) QueryServerBannedFromRoom

func (r *Queryer) QueryServerBannedFromRoom(ctx context.Context, req *api.QueryServerBannedFromRoomRequest, res *api.QueryServerBannedFromRoomResponse) error

func (*Queryer) QueryServerJoinedToRoom

func (r *Queryer) QueryServerJoinedToRoom(
	ctx context.Context,
	request *api.QueryServerJoinedToRoomRequest,
	response *api.QueryServerJoinedToRoomResponse,
) error

QueryServerJoinedToRoom implements api.RoomserverInternalAPI

func (*Queryer) QuerySharedUsers

func (r *Queryer) QuerySharedUsers(ctx context.Context, req *api.QuerySharedUsersRequest, res *api.QuerySharedUsersResponse) error

func (*Queryer) QueryStateAfterEvents

func (r *Queryer) QueryStateAfterEvents(
	ctx context.Context,
	request *api.QueryStateAfterEventsRequest,
	response *api.QueryStateAfterEventsResponse,
) error

QueryStateAfterEvents implements api.RoomserverInternalAPI nolint:gocyclo

func (*Queryer) QueryStateAndAuthChain

func (r *Queryer) QueryStateAndAuthChain(
	ctx context.Context,
	request *api.QueryStateAndAuthChainRequest,
	response *api.QueryStateAndAuthChainResponse,
) error

QueryStateAndAuthChain implements api.RoomserverInternalAPI