processors

package

v0.0.0-...-9835270 Latest Latest Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/finogeeks/ligase

Documentation ¶

Index ¶

type AliasProcessor
type EventsProcessor
type FedProcessor
- func (r *FedProcessor) OnRoomEvent(ctx context.Context, event *gomatrixserverlib.Event) error
type InputContext
type InputResult
type RoomQryProcessor

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 InputResult struct {
	Num   int
	Error error
}

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL