internal

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FederationSenderInternalAPI 

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

FederationSenderInternalAPI is an implementation of api.FederationSenderInternalAPI

func NewFederationSenderInternalAPI 

func NewFederationSenderInternalAPI(
	db storage.Database, cfg *config.FederationSender,
	rsAPI roomserverAPI.RoomserverInternalAPI,
	federation *gomatrixserverlib.FederationClient,
	keyRing *gomatrixserverlib.KeyRing,
	statistics *statistics.Statistics,
	queues *queue.OutgoingQueues,
) *FederationSenderInternalAPI

func (*FederationSenderInternalAPI) Backfill 

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

func (*FederationSenderInternalAPI) ClaimKeys 

func (a *FederationSenderInternalAPI) ClaimKeys(
	ctx context.Context, s gomatrixserverlib.ServerName, oneTimeKeys map[string]map[string]string,
) (gomatrixserverlib.RespClaimKeys, error)

func (*FederationSenderInternalAPI) GetEvent 

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

func (*FederationSenderInternalAPI) GetUserDevices 

func (a *FederationSenderInternalAPI) GetUserDevices(
	ctx context.Context, s gomatrixserverlib.ServerName, userID string,
) (gomatrixserverlib.RespUserDevices, error)

func (*FederationSenderInternalAPI) LookupServerKeys 

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

func (*FederationSenderInternalAPI) LookupState 

func (a *FederationSenderInternalAPI) LookupState(
	ctx context.Context, s gomatrixserverlib.ServerName, roomID, eventID string, roomVersion gomatrixserverlib.RoomVersion,
) (res gomatrixserverlib.RespState, err error)

func (*FederationSenderInternalAPI) LookupStateIDs 

func (a *FederationSenderInternalAPI) LookupStateIDs(
	ctx context.Context, s gomatrixserverlib.ServerName, roomID, eventID string,
) (res gomatrixserverlib.RespStateIDs, err error)

func (*FederationSenderInternalAPI) MSC2836EventRelationships added in v0.3.3 

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

func (*FederationSenderInternalAPI) MSC2946Spaces added in v0.3.7 

func (a *FederationSenderInternalAPI) MSC2946Spaces(
	ctx context.Context, s gomatrixserverlib.ServerName, roomID string, r gomatrixserverlib.MSC2946SpacesRequest,
) (res gomatrixserverlib.MSC2946SpacesResponse, err error)

func (*FederationSenderInternalAPI) PerformBroadcastEDU 

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

PerformServersAlive implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformDirectoryLookup 

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

PerformLeaveRequest implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformInvite 

func (r *FederationSenderInternalAPI) PerformInvite(
	ctx context.Context,
	request *api.PerformInviteRequest,
	response *api.PerformInviteResponse,
) (err error)

PerformLeaveRequest implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformJoin 

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

PerformJoin implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformLeave 

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

PerformLeaveRequest implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformOutboundPeek added in v0.3.7 

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

PerformOutboundPeekRequest implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) PerformServersAlive 

func (r *FederationSenderInternalAPI) PerformServersAlive(
	ctx context.Context,
	request *api.PerformServersAliveRequest,
	response *api.PerformServersAliveResponse,
) (err error)

PerformServersAlive implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) QueryJoinedHostServerNamesInRoom 

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

QueryJoinedHostServerNamesInRoom implements api.FederationSenderInternalAPI

func (*FederationSenderInternalAPI) QueryKeys 

func (a *FederationSenderInternalAPI) QueryKeys(
	ctx context.Context, s gomatrixserverlib.ServerName, keys map[string][]string,
) (gomatrixserverlib.RespQueryKeys, error)

func (*FederationSenderInternalAPI) QueryServerKeys added in v0.4.1 

func (a *FederationSenderInternalAPI) QueryServerKeys(
	ctx context.Context, req *api.QueryServerKeysRequest, res *api.QueryServerKeysResponse,
) 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.