internal

May 23, 2024

Changes in this version

+ type DeviceKeyData struct

+ ChangedBits int

+ FallbackKeyTypes []string

+ OTKCounts MapStringInt

+ func (dd *DeviceKeyData) FallbackKeysChanged() bool

+ func (dd *DeviceKeyData) OTKCountChanged() bool

+ func (dd *DeviceKeyData) SetFallbackKeysChanged()

+ func (dd *DeviceKeyData) SetOTKCountChanged()

+ type DeviceListChanges struct

+ DeviceListChanged []string

+ DeviceListLeft []string

Apr 26, 2024

Changes in this version

+ func AssociateUserIDWithRequest(ctx context.Context, userID, deviceID string) context.Context

Nov 24, 2023

Changes in this version

+ func GetBaseURL(httpOrUnixStr string) string

+ func IsUnixSocket(httpOrUnixStr string) bool

+ func UnixTransport(httpOrUnixStr string) *http.Transport

Nov 9, 2023

Changes in this version

+ func Keys[K comparable, V any](m map[K]V) []K

type RoomMetadata

+ func (m *RoomMetadata) DeepCopy() *RoomMetadata

Sep 6, 2023

Changes in this version

+ func RequestContextDurations(ctx context.Context) (setup time.Duration, processing time.Duration)

+ func SetRequestContextProcessingDuration(ctx context.Context, processing time.Duration)

+ func SetRequestContextSetupDuration(ctx context.Context, setup time.Duration)

Aug 24, 2023

Changes in this version

+ func ConfigureOTLP(otlpURL, otlpUser, otlpPass, version string) error

+ func SetAttributeOnContext(ctx context.Context, key TraceKey, val string) context.Context

type TraceKey

+ var OTLPTagConnID TraceKey = "conn_id"

+ var OTLPTagDeviceID TraceKey = "device_id"

+ var OTLPTagTxnID TraceKey = "txn_id"

+ var OTLPTagUserID TraceKey = "user_id"

Aug 23, 2023

Changes in this version

+ func NewDataError(msg string, args ...interface{}) error

+ type DataError struct

+ func (e *DataError) Error() string

+ type MapStringInt map[string]int

+ func (dl MapStringInt) Value() (driver.Value, error)

Aug 2, 2023

Changes in this version

+ func CalculateAvatar(metadata *RoomMetadata) string

+ func SetConnBufferInfo(ctx context.Context, bufferLen, nextLen, bufferCap int)

type Hero

+ Avatar string

type RoomMetadata

+ AvatarEvent string

+ func (m *RoomMetadata) CopyHeroes() *RoomMetadata

+ func (m *RoomMetadata) SameRoomAvatar(other *RoomMetadata) bool

Jul 12, 2023

Changes in this version

+ type WorkerPool struct

+ N int

+ func NewWorkerPool(n int) *WorkerPool

+ func (wp *WorkerPool) Queue(fn func())

+ func (wp *WorkerPool) Start()

+ func (wp *WorkerPool) Stop()

Jun 19, 2023

Changes in this version

+ const SentryCtxKey

+ func ExtractAccessToken(req *http.Request) (accessToken string, err error)

+ func ReportPanicsToSentry()

+ type EventMetadata struct

+ NID int64

+ Timestamp uint64

type HandlerError

+ func (e *HandlerError) Unwrap() error

type RoomMetadata

+ LatestEventsByType map[string]EventMetadata

+ func NewRoomMetadata(roomID string) *RoomMetadata

Apr 27, 2023

Changes in this version

+ func AssertWithContext(ctx context.Context, msg string, expr bool)

+ func GetSentryHubFromContextOrDefault(ctx context.Context) *sentry.Hub

Feb 24, 2023

Changes in this version

+ func ConfigureJaeger(jaegerURL, version string) error

+ func Logf(ctx context.Context, category, format string, args ...interface{})

+ type RuntimeTraceOTLPSpan struct

+ func StartSpan(ctx context.Context, name string) (newCtx context.Context, span *RuntimeTraceOTLPSpan)

+ func (s *RuntimeTraceOTLPSpan) End()

+ type Task struct

+ func StartTask(ctx context.Context, name string) (context.Context, *Task)

+ func (s *Task) End()

+ type TraceKey string

+ var OTLPSpan TraceKey = "otlp"

Feb 1, 2023

Changes in this version

type RequiredStateMap

+ func (rsm *RequiredStateMap) Empty() bool

Jan 12, 2023

Changes in this version

type DeviceData

+ ChangedBits int

+ func (dd *DeviceData) FallbackKeysChanged() bool

+ func (dd *DeviceData) OTKCountChanged() bool

+ func (dd *DeviceData) SetFallbackKeysChanged()

+ func (dd *DeviceData) SetOTKCountChanged()

Dec 16, 2022

Changes in this version

+ const DeviceListChanged

+ const DeviceListLeft

+ const StateKeyLazy

+ func Assert(msg string, expr bool)

+ func CalculateRoomName(heroInfo *RoomMetadata, maxNumNamesPerRoom int) string

+ func DecorateLogger(ctx context.Context, l *zerolog.Event) *zerolog.Event

+ func DeviceListChangesArrays(m map[string]int) (changed, left []string)

+ func HashedTokenFromRequest(req *http.Request) (hashAccessToken string, accessToken string, err error)

+ func IsMembershipChange(eventJSON gjson.Result) bool

+ func RequestContext(ctx context.Context) context.Context

+ func SetRequestContextResponseInfo(ctx context.Context, since, next int64, numRooms int, txnID string, ...)

+ func SetRequestContextUserID(ctx context.Context, userID string)

+ func ToDeviceListChangesMap(changed, left []string) map[string]int

+ type DeviceData struct

+ DeviceID string

+ DeviceLists DeviceLists

+ FallbackKeyTypes []string

+ OTKCounts map[string]int

+ UserID string

+ type DeviceDataMap struct

+ Pos int64

+ func NewDeviceDataMap(startPos int64, devices []DeviceData) *DeviceDataMap

+ func (d *DeviceDataMap) Get(userID, deviceID string) *DeviceData

+ func (d *DeviceDataMap) Update(dd DeviceData) DeviceData

+ type DeviceLists struct

+ New map[string]int

+ Sent map[string]int

+ func (dl DeviceLists) Combine(newer DeviceLists) DeviceLists

+ type HandlerError struct

+ Err error

+ ErrCode string

+ StatusCode int

+ func ExpiredSessionError() *HandlerError

+ func (e *HandlerError) Error() string

+ func (e HandlerError) JSON() []byte

+ type Hero struct

+ ID string

+ Name string

+ type Receipt struct

+ EventID string

+ IsPrivate bool

+ RoomID string

+ TS int64

+ ThreadID string

+ UserID string

+ type RequiredStateMap struct

+ func NewRequiredStateMap(eventTypesWithWildcardStateKeys map[string]struct{}, ...) *RequiredStateMap

+ func (rsm *RequiredStateMap) Include(evType, stateKey string) bool

+ func (rsm *RequiredStateMap) IsLazyLoading() bool

+ func (rsm *RequiredStateMap) QueryStateMap() map[string][]string

+ type RoomMetadata struct

+ CanonicalAlias string

+ ChildSpaceRooms map[string]struct{}

+ Encrypted bool

+ Heroes []Hero

+ InviteCount int

+ JoinCount int

+ LastMessageTimestamp uint64

+ NameEvent string

+ PredecessorRoomID *string

+ RoomID string

+ RoomType *string

+ TypingEvent json.RawMessage

+ UpgradedRoomID *string

+ func (m *RoomMetadata) IsSpace() bool

+ func (m *RoomMetadata) RemoveHero(userID string)

+ func (m *RoomMetadata) SameInviteCount(other *RoomMetadata) bool

+ func (m *RoomMetadata) SameJoinCount(other *RoomMetadata) bool

+ func (m *RoomMetadata) SameRoomName(other *RoomMetadata) bool

+ type UserDeviceKey struct

+ DeviceID string

+ UserID string