Documentation
¶
Index ¶
- func Download(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetFedDownloadResponse
- func GetAliasRoomID(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetDirectoryRoomAliasResponse
- func GetAvatar(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetAvatarURLResponse
- func GetDisplayName(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetDisplayNameResponse
- func GetProfile(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetProfileResponse
- func GetRoomState(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespState
- func GetUserInfo(ctx context.Context, fedClient *client.FedClientWrap, ...) external.GetUserInfoResponse
- func MakeJoin(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespMakeJoin
- func MakeLeave(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespMakeLeave
- func SendInvite(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespInvite
- func SendJoin(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespSendJoin
- func SendLeave(ctx context.Context, fedClient *client.FedClientWrap, ...) gomatrixserverlib.RespSendLeave
- type FedEventExtra
- type ProfileRpcConsumer
- type RpcResponse
- type SyncConsumer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Download ¶
func Download( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination, domain string, rpcCli *common.RpcClient, ) external.GetFedDownloadResponse
func GetAliasRoomID ¶
func GetAliasRoomID( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) external.GetDirectoryRoomAliasResponse
func GetAvatar ¶
func GetAvatar( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) external.GetAvatarURLResponse
func GetDisplayName ¶
func GetDisplayName( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) external.GetDisplayNameResponse
func GetProfile ¶
func GetProfile( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) external.GetProfileResponse
func GetRoomState ¶
func GetRoomState( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, proc backfilltypes.BackFillProcessor, ) gomatrixserverlib.RespState
func GetUserInfo ¶
func GetUserInfo( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) external.GetUserInfoResponse
func MakeJoin ¶
func MakeJoin( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) gomatrixserverlib.RespMakeJoin
func MakeLeave ¶
func MakeLeave( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) gomatrixserverlib.RespMakeLeave
func SendInvite ¶
func SendInvite( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, ) gomatrixserverlib.RespInvite
func SendJoin ¶
func SendJoin( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, proc backfilltypes.BackFillProcessor, ) gomatrixserverlib.RespSendJoin
func SendLeave ¶
func SendLeave( ctx context.Context, fedClient *client.FedClientWrap, request *roomserverapi.FederationEvent, destination string, proc backfilltypes.BackFillProcessor, ) gomatrixserverlib.RespSendLeave
Types ¶
type FedEventExtra ¶
type FedEventExtra struct {
FedEvent roomserverapi.FederationEvent
Subject string
}
type ProfileRpcConsumer ¶
type ProfileRpcConsumer struct {
// contains filtered or unexported fields
}
func NewProfileRpcConsumer ¶
func NewProfileRpcConsumer( cfg *config.Fed, fedClient *client.FedClientWrap, rpcClient *common.RpcClient, feddomain *common.FedDomains, ) *ProfileRpcConsumer
func (*ProfileRpcConsumer) GetTopic ¶
func (s *ProfileRpcConsumer) GetTopic() string
func (*ProfileRpcConsumer) Start ¶
func (s *ProfileRpcConsumer) Start() error
type RpcResponse ¶
type RpcResponse struct {
Error string
Payload interface{}
}
type SyncConsumer ¶
type SyncConsumer struct {
// contains filtered or unexported fields
}
func NewSyncConsumer ¶
func NewSyncConsumer( cfg *config.Fed, fedClient *client.FedClientWrap, rpcClient *common.RpcClient, feddomains *common.FedDomains, ) *SyncConsumer
func (*SyncConsumer) SetBackfill ¶
func (s *SyncConsumer) SetBackfill(bfp backfilltypes.BackFillProcessor)
func (*SyncConsumer) Start ¶
func (s *SyncConsumer) Start() error
Source Files
Click to show internal directories.
Click to hide internal directories.