api

package
v0.0.0-...-9835270 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ContentRawJSON 

type ContentRawJSON []byte

func (*ContentRawJSON) Decode 

func (r *ContentRawJSON) Decode(input []byte) error

func (*ContentRawJSON) Encode 

func (r *ContentRawJSON) Encode() ([]byte, error)

type GetMessagesSource 

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

type InternalMsgConsumer 

type InternalMsgConsumer struct {
	apiconsumer.APIConsumer
	// contains filtered or unexported fields
}

func NewInternalMsgConsumer 

func NewInternalMsgConsumer(
	cfg config.Dendrite,
	rpcCli *common.RpcClient,
	idg *uid.UidGenerator,
	db model.SyncAPIDatabase,
	rsCurState *repos.RoomCurStateRepo,
	rsTimeline *repos.RoomStateTimeLineRepo,
	rmHsTimeline *repos.RoomHistoryTimeLineRepo,
	displayNameRepo *repos.DisplayNameRepo,
	receiptConsumer *consumers.ReceiptConsumer,
	settings *common.Settings,
	cache service.Cache,
) *InternalMsgConsumer

func (*InternalMsgConsumer) Start 

func (c *InternalMsgConsumer) Start()

type ReqGetEventContext 

type ReqGetEventContext struct{}

func (ReqGetEventContext) FillRequest 

func (ReqGetEventContext) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetEventContext) GetAPIType 

func (ReqGetEventContext) GetAPIType() int8

func (ReqGetEventContext) GetMethod 

func (ReqGetEventContext) GetMethod() []string

func (ReqGetEventContext) GetMetricsName 

func (ReqGetEventContext) GetMetricsName() string

func (ReqGetEventContext) GetMsgType 

func (ReqGetEventContext) GetMsgType() int32

func (ReqGetEventContext) GetPrefix 

func (ReqGetEventContext) GetPrefix() []string

func (ReqGetEventContext) GetRoute 

func (ReqGetEventContext) GetRoute() string

func (ReqGetEventContext) GetTopic 

func (ReqGetEventContext) GetTopic(cfg *config.Dendrite) string

func (ReqGetEventContext) NewRequest 

func (ReqGetEventContext) NewRequest() core.Coder

func (ReqGetEventContext) NewResponse 

func (ReqGetEventContext) NewResponse(code int) core.Coder

func (ReqGetEventContext) Process 

func (ReqGetEventContext) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomInitialSync 

type ReqGetRoomInitialSync struct{}

func (ReqGetRoomInitialSync) FillRequest 

func (ReqGetRoomInitialSync) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomInitialSync) GetAPIType 

func (ReqGetRoomInitialSync) GetAPIType() int8

func (ReqGetRoomInitialSync) GetMethod 

func (ReqGetRoomInitialSync) GetMethod() []string

func (ReqGetRoomInitialSync) GetMetricsName 

func (ReqGetRoomInitialSync) GetMetricsName() string

func (ReqGetRoomInitialSync) GetMsgType 

func (ReqGetRoomInitialSync) GetMsgType() int32

func (ReqGetRoomInitialSync) GetPrefix 

func (ReqGetRoomInitialSync) GetPrefix() []string

func (ReqGetRoomInitialSync) GetRoute 

func (ReqGetRoomInitialSync) GetRoute() string

func (ReqGetRoomInitialSync) GetTopic 

func (ReqGetRoomInitialSync) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomInitialSync) NewRequest 

func (ReqGetRoomInitialSync) NewRequest() core.Coder

func (ReqGetRoomInitialSync) NewResponse 

func (ReqGetRoomInitialSync) NewResponse(code int) core.Coder

func (ReqGetRoomInitialSync) Process 

func (ReqGetRoomInitialSync) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomMembers 

type ReqGetRoomMembers struct{}

func (ReqGetRoomMembers) FillRequest 

func (ReqGetRoomMembers) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomMembers) GetAPIType 

func (ReqGetRoomMembers) GetAPIType() int8

func (ReqGetRoomMembers) GetMethod 

func (ReqGetRoomMembers) GetMethod() []string

func (ReqGetRoomMembers) GetMetricsName 

func (ReqGetRoomMembers) GetMetricsName() string

func (ReqGetRoomMembers) GetMsgType 

func (ReqGetRoomMembers) GetMsgType() int32

func (ReqGetRoomMembers) GetPrefix 

func (ReqGetRoomMembers) GetPrefix() []string

func (ReqGetRoomMembers) GetRoute 

func (ReqGetRoomMembers) GetRoute() string

func (ReqGetRoomMembers) GetTopic 

func (ReqGetRoomMembers) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomMembers) NewRequest 

func (ReqGetRoomMembers) NewRequest() core.Coder

func (ReqGetRoomMembers) NewResponse 

func (ReqGetRoomMembers) NewResponse(code int) core.Coder

func (ReqGetRoomMembers) Process 

func (ReqGetRoomMembers) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomMessages 

type ReqGetRoomMessages struct{}

func (ReqGetRoomMessages) FillRequest 

func (ReqGetRoomMessages) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomMessages) GetAPIType 

func (ReqGetRoomMessages) GetAPIType() int8

func (ReqGetRoomMessages) GetMethod 

func (ReqGetRoomMessages) GetMethod() []string

func (ReqGetRoomMessages) GetMetricsName 

func (ReqGetRoomMessages) GetMetricsName() string

func (ReqGetRoomMessages) GetMsgType 

func (ReqGetRoomMessages) GetMsgType() int32

func (ReqGetRoomMessages) GetPrefix 

func (ReqGetRoomMessages) GetPrefix() []string

func (ReqGetRoomMessages) GetRoute 

func (ReqGetRoomMessages) GetRoute() string

func (ReqGetRoomMessages) GetTopic 

func (ReqGetRoomMessages) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomMessages) NewRequest 

func (ReqGetRoomMessages) NewRequest() core.Coder

func (ReqGetRoomMessages) NewResponse 

func (ReqGetRoomMessages) NewResponse(code int) core.Coder

func (ReqGetRoomMessages) Process 

func (r ReqGetRoomMessages) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomState 

type ReqGetRoomState struct{}

func (ReqGetRoomState) FillRequest 

func (ReqGetRoomState) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomState) GetAPIType 

func (ReqGetRoomState) GetAPIType() int8

func (ReqGetRoomState) GetMethod 

func (ReqGetRoomState) GetMethod() []string

func (ReqGetRoomState) GetMetricsName 

func (ReqGetRoomState) GetMetricsName() string

func (ReqGetRoomState) GetMsgType 

func (ReqGetRoomState) GetMsgType() int32

func (ReqGetRoomState) GetPrefix 

func (ReqGetRoomState) GetPrefix() []string

func (ReqGetRoomState) GetRoute 

func (ReqGetRoomState) GetRoute() string

func (ReqGetRoomState) GetTopic 

func (ReqGetRoomState) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomState) NewRequest 

func (ReqGetRoomState) NewRequest() core.Coder

func (ReqGetRoomState) NewResponse 

func (ReqGetRoomState) NewResponse(code int) core.Coder

func (ReqGetRoomState) Process 

func (ReqGetRoomState) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomStateByType 

type ReqGetRoomStateByType struct{}

func (ReqGetRoomStateByType) FillRequest 

func (ReqGetRoomStateByType) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomStateByType) GetAPIType 

func (ReqGetRoomStateByType) GetAPIType() int8

func (ReqGetRoomStateByType) GetMethod 

func (ReqGetRoomStateByType) GetMethod() []string

func (ReqGetRoomStateByType) GetMetricsName 

func (ReqGetRoomStateByType) GetMetricsName() string

func (ReqGetRoomStateByType) GetMsgType 

func (ReqGetRoomStateByType) GetMsgType() int32

func (ReqGetRoomStateByType) GetPrefix 

func (ReqGetRoomStateByType) GetPrefix() []string

func (ReqGetRoomStateByType) GetRoute 

func (ReqGetRoomStateByType) GetRoute() string

func (ReqGetRoomStateByType) GetTopic 

func (ReqGetRoomStateByType) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomStateByType) NewRequest 

func (ReqGetRoomStateByType) NewRequest() core.Coder

func (ReqGetRoomStateByType) NewResponse 

func (ReqGetRoomStateByType) NewResponse(code int) core.Coder

func (ReqGetRoomStateByType) Process 

func (ReqGetRoomStateByType) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetRoomStateByTypeAndKey 

type ReqGetRoomStateByTypeAndKey struct{}

func (ReqGetRoomStateByTypeAndKey) FillRequest 

func (ReqGetRoomStateByTypeAndKey) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetRoomStateByTypeAndKey) GetAPIType 

func (ReqGetRoomStateByTypeAndKey) GetAPIType() int8

func (ReqGetRoomStateByTypeAndKey) GetMethod 

func (ReqGetRoomStateByTypeAndKey) GetMethod() []string

func (ReqGetRoomStateByTypeAndKey) GetMetricsName 

func (ReqGetRoomStateByTypeAndKey) GetMetricsName() string

func (ReqGetRoomStateByTypeAndKey) GetMsgType 

func (ReqGetRoomStateByTypeAndKey) GetMsgType() int32

func (ReqGetRoomStateByTypeAndKey) GetPrefix 

func (ReqGetRoomStateByTypeAndKey) GetPrefix() []string

func (ReqGetRoomStateByTypeAndKey) GetRoute 

func (ReqGetRoomStateByTypeAndKey) GetRoute() string

func (ReqGetRoomStateByTypeAndKey) GetTopic 

func (ReqGetRoomStateByTypeAndKey) GetTopic(cfg *config.Dendrite) string

func (ReqGetRoomStateByTypeAndKey) NewRequest 

func (ReqGetRoomStateByTypeAndKey) NewRequest() core.Coder

func (ReqGetRoomStateByTypeAndKey) NewResponse 

func (ReqGetRoomStateByTypeAndKey) NewResponse(code int) core.Coder

func (ReqGetRoomStateByTypeAndKey) Process 

func (ReqGetRoomStateByTypeAndKey) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqGetVisibilityRange 

type ReqGetVisibilityRange struct{}

func (ReqGetVisibilityRange) FillRequest 

func (ReqGetVisibilityRange) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqGetVisibilityRange) GetAPIType 

func (ReqGetVisibilityRange) GetAPIType() int8

func (ReqGetVisibilityRange) GetMethod 

func (ReqGetVisibilityRange) GetMethod() []string

func (ReqGetVisibilityRange) GetMetricsName 

func (ReqGetVisibilityRange) GetMetricsName() string

func (ReqGetVisibilityRange) GetMsgType 

func (ReqGetVisibilityRange) GetMsgType() int32

func (ReqGetVisibilityRange) GetPrefix 

func (ReqGetVisibilityRange) GetPrefix() []string

func (ReqGetVisibilityRange) GetRoute 

func (ReqGetVisibilityRange) GetRoute() string

func (ReqGetVisibilityRange) GetTopic 

func (ReqGetVisibilityRange) GetTopic(cfg *config.Dendrite) string

func (ReqGetVisibilityRange) NewRequest 

func (ReqGetVisibilityRange) NewRequest() core.Coder

func (ReqGetVisibilityRange) NewResponse 

func (ReqGetVisibilityRange) NewResponse(code int) core.Coder

func (ReqGetVisibilityRange) Process 

func (ReqGetVisibilityRange) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPostRoomReadMarkers 

type ReqPostRoomReadMarkers struct{}

func (ReqPostRoomReadMarkers) FillRequest 

func (ReqPostRoomReadMarkers) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPostRoomReadMarkers) GetAPIType 

func (ReqPostRoomReadMarkers) GetAPIType() int8

func (ReqPostRoomReadMarkers) GetMethod 

func (ReqPostRoomReadMarkers) GetMethod() []string

func (ReqPostRoomReadMarkers) GetMetricsName 

func (ReqPostRoomReadMarkers) GetMetricsName() string

func (ReqPostRoomReadMarkers) GetMsgType 

func (ReqPostRoomReadMarkers) GetMsgType() int32

func (ReqPostRoomReadMarkers) GetPrefix 

func (ReqPostRoomReadMarkers) GetPrefix() []string

func (ReqPostRoomReadMarkers) GetRoute 

func (ReqPostRoomReadMarkers) GetRoute() string

func (ReqPostRoomReadMarkers) GetTopic 

func (ReqPostRoomReadMarkers) GetTopic(cfg *config.Dendrite) string

func (ReqPostRoomReadMarkers) NewRequest 

func (ReqPostRoomReadMarkers) NewRequest() core.Coder

func (ReqPostRoomReadMarkers) NewResponse 

func (ReqPostRoomReadMarkers) NewResponse(code int) core.Coder

func (ReqPostRoomReadMarkers) Process 

func (ReqPostRoomReadMarkers) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPostRoomReceipt 

type ReqPostRoomReceipt struct{}

func (ReqPostRoomReceipt) FillRequest 

func (ReqPostRoomReceipt) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPostRoomReceipt) GetAPIType 

func (ReqPostRoomReceipt) GetAPIType() int8

func (ReqPostRoomReceipt) GetMethod 

func (ReqPostRoomReceipt) GetMethod() []string

func (ReqPostRoomReceipt) GetMetricsName 

func (ReqPostRoomReceipt) GetMetricsName() string

func (ReqPostRoomReceipt) GetMsgType 

func (ReqPostRoomReceipt) GetMsgType() int32

func (ReqPostRoomReceipt) GetPrefix 

func (ReqPostRoomReceipt) GetPrefix() []string

func (ReqPostRoomReceipt) GetRoute 

func (ReqPostRoomReceipt) GetRoute() string

func (ReqPostRoomReceipt) GetTopic 

func (ReqPostRoomReceipt) GetTopic(cfg *config.Dendrite) string

func (ReqPostRoomReceipt) NewRequest 

func (ReqPostRoomReceipt) NewRequest() core.Coder

func (ReqPostRoomReceipt) NewResponse 

func (ReqPostRoomReceipt) NewResponse(code int) core.Coder

func (ReqPostRoomReceipt) Process 

func (ReqPostRoomReceipt) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPostSystemManager 

type ReqPostSystemManager struct{}

func (ReqPostSystemManager) FillRequest 

func (ReqPostSystemManager) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPostSystemManager) GetAPIType 

func (ReqPostSystemManager) GetAPIType() int8

func (ReqPostSystemManager) GetMethod 

func (ReqPostSystemManager) GetMethod() []string

func (ReqPostSystemManager) GetMetricsName 

func (ReqPostSystemManager) GetMetricsName() string

func (ReqPostSystemManager) GetMsgType 

func (ReqPostSystemManager) GetMsgType() int32

func (ReqPostSystemManager) GetPrefix 

func (ReqPostSystemManager) GetPrefix() []string

func (ReqPostSystemManager) GetRoute 

func (ReqPostSystemManager) GetRoute() string

func (ReqPostSystemManager) GetTopic 

func (ReqPostSystemManager) GetTopic(cfg *config.Dendrite) string

func (ReqPostSystemManager) NewRequest 

func (ReqPostSystemManager) NewRequest() core.Coder

func (ReqPostSystemManager) NewResponse 

func (ReqPostSystemManager) NewResponse(code int) core.Coder

func (ReqPostSystemManager) Process 

func (r ReqPostSystemManager) Process(ctx context.Context, ud interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type ReqPutTyping 

type ReqPutTyping struct{}

func (ReqPutTyping) FillRequest 

func (ReqPutTyping) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error

func (ReqPutTyping) GetAPIType 

func (ReqPutTyping) GetAPIType() int8

func (ReqPutTyping) GetMethod 

func (ReqPutTyping) GetMethod() []string

func (ReqPutTyping) GetMetricsName 

func (ReqPutTyping) GetMetricsName() string

func (ReqPutTyping) GetMsgType 

func (ReqPutTyping) GetMsgType() int32

func (ReqPutTyping) GetPrefix 

func (ReqPutTyping) GetPrefix() []string

func (ReqPutTyping) GetRoute 

func (ReqPutTyping) GetRoute() string

func (ReqPutTyping) GetTopic 

func (ReqPutTyping) GetTopic(cfg *config.Dendrite) string

func (ReqPutTyping) NewRequest 

func (ReqPutTyping) NewRequest() core.Coder

func (ReqPutTyping) NewResponse 

func (ReqPutTyping) NewResponse(code int) core.Coder

func (ReqPutTyping) Process 

func (ReqPutTyping) Process(ctx context.Context, consumer interface{}, msg core.Coder, device *authtypes.Device) (int, core.Coder)

type RoomVisibilityRange 

type RoomVisibilityRange struct {
	RoomID           string           `json:"room_id"`
	VisibilityRanges []userVisibility `json:"visibility_ranges"`
}

func (*RoomVisibilityRange) Decode 

func (r *RoomVisibilityRange) Decode(input []byte) error

func (*RoomVisibilityRange) Encode 

func (r *RoomVisibilityRange) Encode() ([]byte, 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.