Documentation ¶
Index ¶
- type AliasProcessor
- func (r *AliasProcessor) AllocRoomAlias(ctx context.Context, request *roomserverapi.SetRoomAliasRequest, ...) error
- func (r *AliasProcessor) GetAliasRoomID(ctx context.Context, request *roomserverapi.GetAliasRoomIDRequest, ...) error
- func (r *AliasProcessor) RemoveRoomAlias(ctx context.Context, request *roomserverapi.RemoveRoomAliasRequest, ...) error
- func (r *AliasProcessor) SetRoomAlias(ctx context.Context, request *roomserverapi.SetRoomAliasRequest, ...) error
- type EventsProcessor
- func (r *EventsProcessor) InputRoomEvents(ctx context.Context, input *roomserverapi.RawEvent) (int, error)
- func (r *EventsProcessor) NewMonitor()
- func (r *EventsProcessor) SetFed(fed *FedProcessor)
- func (r *EventsProcessor) Start()
- func (r *EventsProcessor) WriteFedEvents(ctx context.Context, roomID string, update *gomatrixserverlib.Event) error
- func (r *EventsProcessor) WriteOutputEvents(ctx context.Context, roomID string, updates []roomserverapi.OutputEvent) error
- type FedProcessor
- type InputContext
- type InputResult
- type RoomQryProcessor
- func (s *RoomQryProcessor) QueryBackFillEvents(ctx context.Context, request *roomserverapi.QueryBackFillEventsRequest, ...) error
- func (s *RoomQryProcessor) QueryEventAuth(ctx context.Context, request *roomserverapi.QueryEventAuthRequest, ...) error
- func (s *RoomQryProcessor) QueryEventsByDomainOffset(ctx context.Context, request *roomserverapi.QueryEventsByDomainOffsetRequest, ...) error
- func (s *RoomQryProcessor) QueryEventsByID(ctx context.Context, request *roomserverapi.QueryEventsByIDRequest, ...) error
- func (s *RoomQryProcessor) QueryJoinRooms(ctx context.Context, request *roomserverapi.QueryJoinRoomsRequest, ...) error
- func (s *RoomQryProcessor) QueryRoomEventByID(ctx context.Context, request *roomserverapi.QueryRoomEventByIDRequest, ...) error
- func (s *RoomQryProcessor) QueryRoomState(ctx context.Context, request *roomserverapi.QueryRoomStateRequest, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AliasProcessor ¶
type AliasProcessor struct { DB model.RoomServerDatabase Cfg *config.Dendrite Filter *filter.Filter Cache service.Cache Repo *repos.RoomServerCurStateRepo Idg *uid.UidGenerator InputAPI roomserverapi.RoomserverInputAPI // contains filtered or unexported fields }
func (*AliasProcessor) AllocRoomAlias ¶
func (r *AliasProcessor) AllocRoomAlias( ctx context.Context, request *roomserverapi.SetRoomAliasRequest, response *roomserverapi.SetRoomAliasResponse, ) error
func (*AliasProcessor) GetAliasRoomID ¶
func (r *AliasProcessor) GetAliasRoomID( ctx context.Context, request *roomserverapi.GetAliasRoomIDRequest, response *roomserverapi.GetAliasRoomIDResponse, ) error
GetAliasRoomID implements roomserverapi.RoomserverAliasAPI
func (*AliasProcessor) RemoveRoomAlias ¶
func (r *AliasProcessor) RemoveRoomAlias( ctx context.Context, request *roomserverapi.RemoveRoomAliasRequest, response *roomserverapi.RemoveRoomAliasResponse, ) error
RemoveRoomAlias implements roomserverapi.RoomserverAliasAPI
func (*AliasProcessor) SetRoomAlias ¶
func (r *AliasProcessor) SetRoomAlias( ctx context.Context, request *roomserverapi.SetRoomAliasRequest, response *roomserverapi.SetRoomAliasResponse, ) error
type EventsProcessor ¶
type EventsProcessor struct { DB model.RoomServerDatabase Repo *repos.RoomServerCurStateRepo UmsRepo *repos.RoomServerUserMembershipRepo Fed *FedProcessor Cfg *config.Dendrite Idg *uid.UidGenerator RpcClient *common.RpcClient Federation *fed.Federation // contains filtered or unexported fields }
func (*EventsProcessor) InputRoomEvents ¶
func (r *EventsProcessor) InputRoomEvents( ctx context.Context, input *roomserverapi.RawEvent, ) (int, error)
func (*EventsProcessor) NewMonitor ¶
func (r *EventsProcessor) NewMonitor()
func (*EventsProcessor) SetFed ¶
func (r *EventsProcessor) SetFed(fed *FedProcessor)
func (*EventsProcessor) Start ¶
func (r *EventsProcessor) Start()
func (*EventsProcessor) WriteFedEvents ¶
func (r *EventsProcessor) WriteFedEvents(ctx context.Context, roomID string, update *gomatrixserverlib.Event) error
func (*EventsProcessor) WriteOutputEvents ¶
func (r *EventsProcessor) WriteOutputEvents(ctx context.Context, roomID string, updates []roomserverapi.OutputEvent) error
type FedProcessor ¶
type FedProcessor struct {
Alias AliasProcessor
}
func (*FedProcessor) OnRoomEvent ¶
func (r *FedProcessor) OnRoomEvent( ctx context.Context, event *gomatrixserverlib.Event, ) error
type InputContext ¶
type InputContext struct {
// contains filtered or unexported fields
}
type InputResult ¶
type RoomQryProcessor ¶
type RoomQryProcessor struct { DB model.RoomServerDatabase Repo *repos.RoomServerCurStateRepo UmsRepo *repos.RoomServerUserMembershipRepo Cfg *config.Dendrite }
func (*RoomQryProcessor) QueryBackFillEvents ¶
func (s *RoomQryProcessor) QueryBackFillEvents( ctx context.Context, request *roomserverapi.QueryBackFillEventsRequest, response *roomserverapi.QueryBackFillEventsResponse, ) error
func (*RoomQryProcessor) QueryEventAuth ¶
func (s *RoomQryProcessor) QueryEventAuth( ctx context.Context, request *roomserverapi.QueryEventAuthRequest, response *roomserverapi.QueryEventAuthResponse, ) error
func (*RoomQryProcessor) QueryEventsByDomainOffset ¶
func (s *RoomQryProcessor) QueryEventsByDomainOffset( ctx context.Context, request *roomserverapi.QueryEventsByDomainOffsetRequest, response *roomserverapi.QueryEventsByDomainOffsetResponse, ) error
func (*RoomQryProcessor) QueryEventsByID ¶
func (s *RoomQryProcessor) QueryEventsByID( ctx context.Context, request *roomserverapi.QueryEventsByIDRequest, response *roomserverapi.QueryEventsByIDResponse, ) error
func (*RoomQryProcessor) QueryJoinRooms ¶
func (s *RoomQryProcessor) QueryJoinRooms( ctx context.Context, request *roomserverapi.QueryJoinRoomsRequest, response *roomserverapi.QueryJoinRoomsResponse, ) error
func (*RoomQryProcessor) QueryRoomEventByID ¶
func (s *RoomQryProcessor) QueryRoomEventByID( ctx context.Context, request *roomserverapi.QueryRoomEventByIDRequest, response *roomserverapi.QueryRoomEventByIDResponse, ) error
func (*RoomQryProcessor) QueryRoomState ¶
func (s *RoomQryProcessor) QueryRoomState( ctx context.Context, request *roomserverapi.QueryRoomStateRequest, response *roomserverapi.QueryRoomStateResponse, ) error
Click to show internal directories.
Click to hide internal directories.