input

Documentation

Index

• type EDUServerInputAPI
  • func (t *EDUServerInputAPI) InputReceiptEvent(ctx context.Context, request *api.InputReceiptEventRequest, ...) error
  • func (t *EDUServerInputAPI) InputSendToDeviceEvent(ctx context.Context, request *api.InputSendToDeviceEventRequest, ...) error
  • func (t *EDUServerInputAPI) InputTypingEvent(ctx context.Context, request *api.InputTypingEventRequest, ...) error

Types

type EDUServerInputAPI

type EDUServerInputAPI struct {
	// Cache to store the current typing members in each room.
	Cache *cache.EDUCache
	// The kafka topic to output new typing events to.
	OutputTypingEventTopic string
	// The kafka topic to output new send to device events to.
	OutputSendToDeviceEventTopic string
	// The kafka topic to output new receipt events to
	OutputReceiptEventTopic string
	// kafka producer
	JetStream nats.JetStreamContext
	// Internal user query API
	UserAPI userapi.UserInternalAPI
	// our server name
	ServerName gomatrixserverlib.ServerName
}

EDUServerInputAPI implements api.EDUServerInputAPI

func (*EDUServerInputAPI) InputReceiptEvent

func (t *EDUServerInputAPI) InputReceiptEvent(
	ctx context.Context,
	request *api.InputReceiptEventRequest,
	response *api.InputReceiptEventResponse,
) error

InputReceiptEvent implements api.EDUServerInputAPI TODO: Intelligently batch requests sent by the same user (e.g wait a few milliseconds before emitting output events)

func (*EDUServerInputAPI) InputSendToDeviceEvent

func (t *EDUServerInputAPI) InputSendToDeviceEvent(
	ctx context.Context,
	request *api.InputSendToDeviceEventRequest,
	response *api.InputSendToDeviceEventResponse,
) error

InputTypingEvent implements api.EDUServerInputAPI

func (*EDUServerInputAPI) InputTypingEvent

func (t *EDUServerInputAPI) InputTypingEvent(
	ctx context.Context,
	request *api.InputTypingEventRequest,
	response *api.InputTypingEventResponse,
) error

InputTypingEvent implements api.EDUServerInputAPI