internal

package
v0.13.8 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FederationInternalAPI 

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

FederationInternalAPI is an implementation of api.FederationInternalAPI

func NewFederationInternalAPI 

func NewFederationInternalAPI(
	db storage.Database, cfg *config.FederationAPI,
	rsAPI roomserverAPI.FederationRoomserverAPI,
	federation fclient.FederationClient,
	statistics *statistics.Statistics,
	caches *caching.Caches,
	queues *queue.OutgoingQueues,
	keyRing *gomatrixserverlib.KeyRing,
) *FederationInternalAPI

func (*FederationInternalAPI) Backfill 

func (a *FederationInternalAPI) Backfill(
	ctx context.Context, origin, s spec.ServerName, roomID string, limit int, eventIDs []string,
) (res gomatrixserverlib.Transaction, err error)

func (*FederationInternalAPI) ClaimKeys 

func (a *FederationInternalAPI) ClaimKeys(
	ctx context.Context, origin, s spec.ServerName, oneTimeKeys map[string]map[string]string,
) (fclient.RespClaimKeys, error)

func (*FederationInternalAPI) FetchKeys 

func (s *FederationInternalAPI) FetchKeys(
	_ context.Context,
	requests map[gomatrixserverlib.PublicKeyLookupRequest]spec.Timestamp,
) (map[gomatrixserverlib.PublicKeyLookupRequest]gomatrixserverlib.PublicKeyLookupResult, error)

func (*FederationInternalAPI) FetcherName 

func (s *FederationInternalAPI) FetcherName() string

func (*FederationInternalAPI) GetEvent 

func (a *FederationInternalAPI) GetEvent(
	ctx context.Context, origin, s spec.ServerName, eventID string,
) (res gomatrixserverlib.Transaction, err error)

func (*FederationInternalAPI) GetEventAuth 

func (a *FederationInternalAPI) GetEventAuth(
	ctx context.Context, origin, s spec.ServerName,
	roomVersion gomatrixserverlib.RoomVersion, roomID, eventID string,
) (res fclient.RespEventAuth, err error)

func (*FederationInternalAPI) GetUserDevices 

func (a *FederationInternalAPI) GetUserDevices(
	ctx context.Context, origin, s spec.ServerName, userID string,
) (fclient.RespUserDevices, error)

func (*FederationInternalAPI) IsBlacklistedOrBackingOff added in v0.13.5 

func (a *FederationInternalAPI) IsBlacklistedOrBackingOff(s spec.ServerName) (*statistics.ServerStatistics, error)

func (*FederationInternalAPI) KeyRing 

func (s *FederationInternalAPI) KeyRing() *gomatrixserverlib.KeyRing

func (*FederationInternalAPI) LookupMissingEvents 

func (a *FederationInternalAPI) LookupMissingEvents(
	ctx context.Context, origin, s spec.ServerName, roomID string,
	missing fclient.MissingEvents, roomVersion gomatrixserverlib.RoomVersion,
) (res fclient.RespMissingEvents, err error)

func (*FederationInternalAPI) LookupServerKeys 

func (a *FederationInternalAPI) LookupServerKeys(
	ctx context.Context, s spec.ServerName, keyRequests map[gomatrixserverlib.PublicKeyLookupRequest]spec.Timestamp,
) ([]gomatrixserverlib.ServerKeys, error)

func (*FederationInternalAPI) LookupState 

func (a *FederationInternalAPI) LookupState(
	ctx context.Context, origin, s spec.ServerName, roomID, eventID string, roomVersion gomatrixserverlib.RoomVersion,
) (res gomatrixserverlib.StateResponse, err error)

func (*FederationInternalAPI) LookupStateIDs 

func (a *FederationInternalAPI) LookupStateIDs(
	ctx context.Context, origin, s spec.ServerName, roomID, eventID string,
) (res gomatrixserverlib.StateIDResponse, err error)

func (*FederationInternalAPI) MSC2836EventRelationships 

func (a *FederationInternalAPI) MSC2836EventRelationships(
	ctx context.Context, origin, s spec.ServerName, r fclient.MSC2836EventRelationshipsRequest,
	roomVersion gomatrixserverlib.RoomVersion,
) (res fclient.MSC2836EventRelationshipsResponse, err error)

func (*FederationInternalAPI) MakeJoin added in v0.13.0 

func (a *FederationInternalAPI) MakeJoin(
	ctx context.Context, origin, s spec.ServerName, roomID, userID string,
) (res gomatrixserverlib.MakeJoinResponse, err error)

func (*FederationInternalAPI) MarkServersAlive added in v0.8.3 

func (r *FederationInternalAPI) MarkServersAlive(destinations []spec.ServerName)

func (*FederationInternalAPI) P2PAddRelayServers added in v0.11.1 

func (r *FederationInternalAPI) P2PAddRelayServers(
	ctx context.Context,
	request *api.P2PAddRelayServersRequest,
	response *api.P2PAddRelayServersResponse,
) error

P2PAddRelayServers implements api.FederationInternalAPI

func (*FederationInternalAPI) P2PQueryRelayServers added in v0.11.1 

func (r *FederationInternalAPI) P2PQueryRelayServers(
	ctx context.Context,
	request *api.P2PQueryRelayServersRequest,
	response *api.P2PQueryRelayServersResponse,
) error

P2PQueryRelayServers implements api.FederationInternalAPI

func (*FederationInternalAPI) P2PRemoveRelayServers added in v0.11.1 

func (r *FederationInternalAPI) P2PRemoveRelayServers(
	ctx context.Context,
	request *api.P2PRemoveRelayServersRequest,
	response *api.P2PRemoveRelayServersResponse,
) error

P2PRemoveRelayServers implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformBroadcastEDU 

func (r *FederationInternalAPI) PerformBroadcastEDU(
	ctx context.Context,
	request *api.PerformBroadcastEDURequest,
	response *api.PerformBroadcastEDUResponse,
) (err error)

PerformServersAlive implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformDirectoryLookup 

func (r *FederationInternalAPI) PerformDirectoryLookup(
	ctx context.Context,
	request *api.PerformDirectoryLookupRequest,
	response *api.PerformDirectoryLookupResponse,
) (err error)

PerformLeaveRequest implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformJoin 

func (r *FederationInternalAPI) PerformJoin(
	ctx context.Context,
	request *api.PerformJoinRequest,
	response *api.PerformJoinResponse,
)

PerformJoin implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformLeave 

func (r *FederationInternalAPI) PerformLeave(
	ctx context.Context,
	request *api.PerformLeaveRequest,
	response *api.PerformLeaveResponse,
) (err error)

PerformLeaveRequest implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformOutboundPeek 

func (r *FederationInternalAPI) PerformOutboundPeek(
	ctx context.Context,
	request *api.PerformOutboundPeekRequest,
	response *api.PerformOutboundPeekResponse,
) error

PerformOutboundPeekRequest implements api.FederationInternalAPI

func (*FederationInternalAPI) PerformWakeupServers added in v0.10.8 

func (r *FederationInternalAPI) PerformWakeupServers(
	ctx context.Context,
	request *api.PerformWakeupServersRequest,
	response *api.PerformWakeupServersResponse,
) (err error)

PerformWakeupServers implements api.FederationInternalAPI

func (*FederationInternalAPI) QueryJoinedHostServerNamesInRoom 

func (f *FederationInternalAPI) QueryJoinedHostServerNamesInRoom(
	ctx context.Context,
	request *api.QueryJoinedHostServerNamesInRoomRequest,
	response *api.QueryJoinedHostServerNamesInRoomResponse,
) (err error)

QueryJoinedHostServerNamesInRoom implements api.FederationInternalAPI

func (*FederationInternalAPI) QueryKeys 

func (a *FederationInternalAPI) QueryKeys(
	ctx context.Context, origin, s spec.ServerName, keys map[string][]string,
) (fclient.RespQueryKeys, error)

func (*FederationInternalAPI) QueryServerKeys 

func (a *FederationInternalAPI) QueryServerKeys(
	ctx context.Context, req *api.QueryServerKeysRequest, res *api.QueryServerKeysResponse,
) error

func (*FederationInternalAPI) RoomHierarchies added in v0.13.2 

func (a *FederationInternalAPI) RoomHierarchies(
	ctx context.Context, origin, s spec.ServerName, roomID string, suggestedOnly bool,
) (res fclient.RoomHierarchyResponse, err error)

func (*FederationInternalAPI) SendInvite added in v0.13.0 

func (r *FederationInternalAPI) SendInvite(
	ctx context.Context,
	event gomatrixserverlib.PDU,
	strippedState []gomatrixserverlib.InviteStrippedState,
) (gomatrixserverlib.PDU, error)

SendInvite implements api.FederationInternalAPI

func (*FederationInternalAPI) SendInviteV3 added in v0.13.2 

func (r *FederationInternalAPI) SendInviteV3(
	ctx context.Context,
	event gomatrixserverlib.ProtoEvent,
	invitee spec.UserID,
	version gomatrixserverlib.RoomVersion,
	strippedState []gomatrixserverlib.InviteStrippedState,
) (gomatrixserverlib.PDU, error)

SendInviteV3 implements api.FederationInternalAPI

func (*FederationInternalAPI) SendJoin added in v0.13.0 

func (a *FederationInternalAPI) SendJoin(
	ctx context.Context, origin, s spec.ServerName, event gomatrixserverlib.PDU,
) (res gomatrixserverlib.SendJoinResponse, err error)

func (*FederationInternalAPI) StoreKeys 

func (s *FederationInternalAPI) StoreKeys(
	_ context.Context,
	results map[gomatrixserverlib.PublicKeyLookupRequest]gomatrixserverlib.PublicKeyLookupResult,
) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.