models

package

Go to main page

Versions in this module

v1

v1.1.24

Mar 6, 2026

v1.1.23

Mar 5, 2026

v1.1.22

Mar 5, 2026

Changes in this version

+ const SKWellKnownLesserSoulAgent

+ type InstanceWellKnownLesserSoulAgent struct

+ ExpiresAt time.Time

+ PK string

+ ProofValue string

+ SK string

+ UpdatedAt time.Time

+ func NewInstanceWellKnownLesserSoulAgent() *InstanceWellKnownLesserSoulAgent

+ func (InstanceWellKnownLesserSoulAgent) TableName() string

+ func (c *InstanceWellKnownLesserSoulAgent) GetPK() string

+ func (c *InstanceWellKnownLesserSoulAgent) GetSK() string

+ func (c *InstanceWellKnownLesserSoulAgent) UpdateKeys() error

v1.1.21

Mar 2, 2026

v1.1.20

Mar 2, 2026

Changes in this version

type Activity

+ GSI2PK string

+ GSI2SK string

type AggregatedMetrics

+ GSI2PK string

+ GSI2SK string

type Bookmark

+ GSI8PK string

+ GSI8SK string

type CircuitBreakerState

+ GSI8PK string

+ GSI8SK string

type Device

+ GSI3PK string

+ GSI3SK string

type FederationEdge

+ GSI8PK string

+ GSI8SK string

type Filter

+ GSI1PK string

+ GSI1SK string

type ModerationEvent

+ GSI4PK string

+ GSI4SK string

type Relay

+ GSI8PK string

+ GSI8SK string

type Status

+ GSI8PK string

+ GSI8SK string

v1.1.19

Mar 1, 2026

v1.1.18

Mar 1, 2026

v1.1.17

Feb 21, 2026

v1.1.16

Feb 21, 2026

v1.1.15

Feb 21, 2026

v1.1.14

Feb 20, 2026

Changes in this version

type ConversationParticipantRecord

+ AcceptedAt *time.Time

+ DeclinedAt *time.Time

+ DeletedAt *time.Time

+ LastReadAt *time.Time

+ RequestState DmRequestState

+ RequestedAt *time.Time

+ Unread bool

+ type DirectMessageTombstone struct

+ CreatedAt time.Time

+ PK string

+ SK string

+ StatusID string

+ ViewerUsername string

+ func (DirectMessageTombstone) TableName() string

+ func (t *DirectMessageTombstone) GetPK() string

+ func (t *DirectMessageTombstone) GetSK() string

+ func (t *DirectMessageTombstone) UpdateKeys() error

+ type DmRequestState string

+ const DmRequestStateAccepted

+ const DmRequestStateDeclined

+ const DmRequestStatePending

+ type GraphQLStreamSubscription struct

+ ConnectionID string

+ CreatedAt time.Time

+ Field string

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ Stream string

+ SubscriptionID string

+ TTL int64

+ UserID string

+ func (GraphQLStreamSubscription) TableName() string

+ func (g *GraphQLStreamSubscription) GetPK() string

+ func (g *GraphQLStreamSubscription) GetSK() string

+ func (g *GraphQLStreamSubscription) UpdateKeys() error

type UserPreferences

+ DirectMessagesFrom string

type UserPreferencesStorage

+ DirectMessagesFrom string

v1.1.13

Feb 18, 2026

Changes in this version

+ const SKAIConfig

+ const SKTipsConfig

+ const SKTranslationConfig

+ const SKTrustConfig

type AIInstanceConfig

+ LegacyAIContentDetection bool

+ LegacyAIEnabled bool

+ LegacyModerationEnabled bool

+ LegacyNSFWDetectionEnabled bool

+ LegacyPIIDetectionEnabled bool

+ LegacySpamDetectionEnabled bool

+ Managed *AIInstanceConfigManaged

+ Override *AIInstanceConfigOverride

+ type AIInstanceConfigManaged struct

+ AIContentDetection bool

+ AIEnabled bool

+ ModerationEnabled bool

+ NSFWDetectionEnabled bool

+ PIIDetectionEnabled bool

+ SpamDetectionEnabled bool

+ type AIInstanceConfigOverride struct

+ AIContentDetection *bool

+ AIEnabled *bool

+ ModerationEnabled *bool

+ NSFWDetectionEnabled *bool

+ PIIDetectionEnabled *bool

+ SpamDetectionEnabled *bool

+ type AIInstanceConfigPatch struct

+ AIContentDetection *bool

+ AIEnabled *bool

+ ModerationEnabled *bool

+ NSFWDetectionEnabled *bool

+ PIIDetectionEnabled *bool

+ SpamDetectionEnabled *bool

+ type EffectiveAIInstanceConfig struct

+ AIContentDetection bool

+ AIEnabled bool

+ ModerationEnabled bool

+ NSFWDetectionEnabled bool

+ PIIDetectionEnabled bool

+ SpamDetectionEnabled bool

+ type EffectiveTipsConfig struct

+ ChainID int

+ ContractAddress string

+ Enabled bool

+ type EffectiveTrustConfig struct

+ AttestationsBaseURL string

+ InstanceKeySecretARN string

+ PublicAttestationsEnabled bool

+ TrustBaseURL string

+ TrustProxyEnabled bool

+ type InstanceTipsConfig struct

+ Managed *InstanceTipsConfigManaged

+ Override *InstanceTipsConfigOverride

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func NewInstanceTipsConfig() *InstanceTipsConfig

+ func (InstanceTipsConfig) TableName() string

+ func (c *InstanceTipsConfig) GetPK() string

+ func (c *InstanceTipsConfig) GetSK() string

+ func (c *InstanceTipsConfig) UpdateKeys() error

+ type InstanceTipsConfigManaged struct

+ ChainID int

+ ContractAddress string

+ Enabled bool

+ type InstanceTipsConfigOverride struct

+ ChainID *int

+ ContractAddress *string

+ Enabled *bool

+ type InstanceTipsConfigPatch struct

+ ChainID *int

+ ContractAddress *string

+ Enabled *bool

+ type InstanceTranslationConfig struct

+ Managed *InstanceTranslationConfigManaged

+ Override *InstanceTranslationConfigOverride

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func NewInstanceTranslationConfig() *InstanceTranslationConfig

+ func (InstanceTranslationConfig) TableName() string

+ func (c *InstanceTranslationConfig) GetPK() string

+ func (c *InstanceTranslationConfig) GetSK() string

+ func (c *InstanceTranslationConfig) UpdateKeys() error

+ type InstanceTranslationConfigManaged struct

+ Enabled bool

+ type InstanceTranslationConfigOverride struct

+ Enabled *bool

+ type InstanceTranslationConfigPatch struct

+ Enabled *bool

+ type InstanceTrustConfig struct

+ Managed *InstanceTrustConfigManaged

+ Override *InstanceTrustConfigOverride

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func NewInstanceTrustConfig() *InstanceTrustConfig

+ func (InstanceTrustConfig) TableName() string

+ func (c *InstanceTrustConfig) GetPK() string

+ func (c *InstanceTrustConfig) GetSK() string

+ func (c *InstanceTrustConfig) UpdateKeys() error

+ type InstanceTrustConfigManaged struct

+ AttestationsURL string

+ BaseURL string

+ InstanceKeySecretARN string

+ type InstanceTrustConfigOverride struct

+ AttestationsURL *string

+ BaseURL *string

+ InstanceKeySecretARN *string

+ type InstanceTrustConfigPatch struct

+ AttestationsURL *string

+ BaseURL *string

+ InstanceKeySecretARN *string

v1.1.12

Feb 17, 2026

v1.1.11

Feb 16, 2026

v1.1.10

Feb 15, 2026

v1.1.9

Feb 14, 2026

Changes in this version

+ type RevokedAccessToken struct

+ ExpiresAt time.Time

+ JTI string

+ PK string

+ RevokedAt time.Time

+ SK string

+ TTL int64

+ func (RevokedAccessToken) TableName() string

+ func (r *RevokedAccessToken) BeforeCreate() error

+ func (r *RevokedAccessToken) GetPK() string

+ func (r *RevokedAccessToken) GetSK() string

+ func (r *RevokedAccessToken) UpdateKeys() error

v1.1.8

Feb 13, 2026

v1.1.7

Feb 13, 2026

v1.1.6

Feb 13, 2026

v1.1.5

Feb 12, 2026

v1.1.4

Feb 12, 2026

Changes in this version

type AuthorizationCode

+ RedirectURI string

v1.1.3

Feb 11, 2026

v1.1.2

Feb 11, 2026

Changes in this version

type OAuthClient

+ ClientClass string

+ type OAuthDeviceSession struct

+ ApprovedAt *time.Time

+ ApprovedUsername string

+ ClientID string

+ ConsumedAt *time.Time

+ CreatedAt time.Time

+ DeniedAt *time.Time

+ DeviceCodeHash string

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ IntervalSeconds int

+ LastPolledAt *time.Time

+ PK string

+ PollCount int

+ SK string

+ Scopes []string

+ Status string

+ TTL int64

+ UpdatedAt time.Time

+ UserCode string

+ func (OAuthDeviceSession) TableName() string

+ func (o *OAuthDeviceSession) GetPK() string

+ func (o *OAuthDeviceSession) GetSK() string

+ func (o *OAuthDeviceSession) UpdateKeys() error

type RefreshToken

+ ClientClass string

+ SessionID string

v1.1.1

Feb 10, 2026

v1.1.0

Feb 10, 2026

v1.0.1

Feb 8, 2026

v0

v0.1.0

Feb 5, 2026

Changes in this version

+ const APIGatewayConnectionCostPerMinute

+ const APIGatewayMessageCostPerMessage

+ const BookmarkPartitionPrefix

+ const BookmarkRecordTypeObject

+ const BookmarkRecordTypeTime

+ const BookmarkSortKeyPrefixObject

+ const BookmarkSortKeyPrefixTime

+ const CMSArticleIndexSKPrefix

+ const CircuitBreakerStateClosed

+ const CircuitBreakerStateHalfOpen

+ const CircuitBreakerStateOpen

+ const CloudWatchLogsCostMicroCentsPerMB

+ const CollectionFeatured

+ const CollectionFollowers

+ const CollectionFollowing

+ const CollectionLikes

+ const CollectionShares

+ const CostDriverPK

+ const CostProjectionPK

+ const CostTierHigh

+ const CostTierLow

+ const CostTierMedium

+ const CostTierPremium

+ const DataTransferCostMicroCentsPerMB

+ const DataTransferCostPerMB

+ const DefaultBootstrapUsername

+ const DeliveryStatusDelivered

+ const DeliveryStatusFailed

+ const DeliveryStatusPending

+ const DomainBlockSeveritySilence

+ const DomainBlockSeveritySuspend

+ const DynamoDBReadCostMicroCentsPerUnit

+ const DynamoDBReadCostPerRCU

+ const DynamoDBWriteCostMicroCentsPerUnit

+ const DynamoDBWriteCostPerWCU

+ const EntityTypeAccount

+ const EntityTypeScheduledStatus

+ const EntityTypeStatus

+ const EntityTypeUser

+ const FailureReasonDeleted

+ const FailureReasonForbidden

+ const FailureReasonInvalid

+ const FailureReasonNotFound

+ const FailureReasonTimeout

+ const FailureReasonUnreachable

+ const FederationStatsPK

+ const FollowStateAccepted

+ const FollowStatePending

+ const FollowStateRejected

+ const IndexGSI1

+ const IndexGSI2

+ const IndexGSI3

+ const IndexGSI4

+ const IndexGSI5

+ const IndexGSI6

+ const IndexGSI7

+ const IndexGSI8

+ const IndexGSI9

+ const IndexOAuthClients

+ const KeyPatternActor

+ const KeyPatternActorBlocks

+ const KeyPatternConnection

+ const KeyPatternConversation

+ const KeyPatternDevice

+ const KeyPatternHashtag

+ const KeyPatternHashtagSearch

+ const KeyPatternList

+ const KeyPatternMedia

+ const KeyPatternMediaBudget

+ const KeyPatternMediaIdempotency

+ const KeyPatternMediaJob

+ const KeyPatternMediaSpending

+ const KeyPatternNote

+ const KeyPatternObject

+ const KeyPatternObjectNotes

+ const KeyPatternSession

+ const KeyPatternSpendingTxn

+ const KeyPatternStatus

+ const KeyPatternStatusMeta

+ const KeyPatternTranscodingJob

+ const KeyPatternUser

+ const KeyPatternUserPins

+ const KeyPatternUserScheduled

+ const LambdaCostPerGBSecond

+ const LambdaCostPerInvocation

+ const LambdaCostPerMSMicroCents

+ const LambdaCostPerSecond512MB

+ const MediaCostAnalysis

+ const MediaCostDelivery

+ const MediaCostModeration

+ const MediaCostStorage

+ const MediaCostThumbnail

+ const MediaCostTranscode

+ const MediaCostUpload

+ const MediaStatusCancelled

+ const MediaStatusCompleted

+ const MediaStatusFailed

+ const MediaStatusPending

+ const MediaStatusProcessing

+ const MediaStatusReady

+ const MediaTaskBlurhash

+ const MediaTaskDimensions

+ const MediaTaskDuration

+ const MediaTaskEXIF

+ const MediaTaskMetadata

+ const MediaTaskModeration

+ const MediaTaskResize

+ const MediaTaskThumbnail

+ const MediaTaskTranscode

+ const MediaTaskUpload

+ const MediaTaskWaveform

+ const MemoryEventCorrection

+ const MemoryEventCreate

+ const MemoryEventRetraction

+ const MemoryEventTombstone

+ const MissingReplyStatusFailed

+ const MissingReplyStatusFetching

+ const MissingReplyStatusPending

+ const MissingReplyStatusResolved

+ const ModerationTypeEvent

+ const Period5Min

+ const PeriodDaily

+ const PeriodDay

+ const PeriodHour

+ const PeriodHourly

+ const PeriodMonth

+ const PeriodMonthly

+ const PeriodRaw

+ const PeriodTimeHour

+ const PeriodWeek

+ const PeriodWeekly

+ const PushCostPerMessage

+ const ReadCostMicroCentsPerUnit

+ const RelationshipAccepted

+ const RelationshipPending

+ const RelationshipRejected

+ const ResourceBandwidth

+ const ResourceCompute

+ const ResourceLambda

+ const ResourceProcessing

+ const ResourceStorage

+ const S3GetCostMicroCentsPerRequest

+ const S3PutCostMicroCentsPerRequest

+ const SKCode

+ const SKConfig

+ const SKCurrent

+ const SKEntry

+ const SKInfo

+ const SKMetadata

+ const SKProfile

+ const SKState

+ const SKStats

+ const SKToken

+ const SQSCostMicroCentsPerMessage

+ const StatusActive

+ const StatusCancelled

+ const StatusComplete

+ const StatusCompleted

+ const StatusCritical

+ const StatusDisabled

+ const StatusError

+ const StatusFailed

+ const StatusHealthy

+ const StatusPending

+ const StatusProcessing

+ const StatusReady

+ const StatusRetry

+ const StatusSuccess

+ const StatusTimeout

+ const StatusWarning

+ const TimelinePublic

+ const TrendDecreasing

+ const TrendIncreasing

+ const TrendStable

+ const TrusteeConfigPK

+ const TypeEmail

+ const TypeFollowed

+ const VisibilityDirect

+ const VisibilityDisabled

+ const VisibilityPrivate

+ const VisibilityPublic

+ const VisibilityUnlisted

+ const WebSocketCostPerMessage

+ const WriteCostMicroCentsPerUnit

+ var ErrAccessTokenExpired = centralErrors.NewAppError(centralErrors.CodeTokenExpired, centralErrors.CategoryAuth, ...)

+ var ErrAccessTokenGenerationFailed = centralErrors.AccessTokenGenerationFailed(stdErrors.New("access token generation failed"))

+ var ErrAggregationLevelRequired = centralErrors.RequiredFieldMissing("AggregationLevel")

+ var ErrAlertIDRequired = centralErrors.RequiredFieldMissing("alert_id")

+ var ErrBlockUpdateKeysFailed = centralErrors.FailedToUpdate("block keys", stdErrors.New("failed to update block keys"))

+ var ErrBudgetLimitsInvalid = centralErrors.BudgetLimitsInvalid()

+ var ErrBudgetMicroCentsNegative = centralErrors.ValueOutOfRange("BudgetMicroCents", 0, int64(^uint64(0) >> 1), -1)

+ var ErrCSRFCreatedAtRequired = centralErrors.RequiredFieldMissing("CreatedAt")

+ var ErrCSRFExpiresAtRequired = centralErrors.RequiredFieldMissing("ExpiresAt")

+ var ErrCSRFInvalidTimeRange = centralErrors.NewValidationError("expires_at", "ExpiresAt must be after CreatedAt")

+ var ErrCSRFTokenRequired = centralErrors.RequiredFieldMissing("token")

+ var ErrCSRFUserIDRequired = centralErrors.RequiredFieldMissing("UserID")

+ var ErrCalculatedAtFieldMissing = centralErrors.RequiredFieldMissing("calculatedAt")

+ var ErrCalculatedAtParseFailed = centralErrors.ParsingFailed("calculatedAt", stdErrors.New("calculatedAt parsing failed"))

+ var ErrCloudWatchMetricServiceNameRequired = centralErrors.RequiredFieldMissing("ServiceName")

+ var ErrConversationDataRequired = centralErrors.RequiredFieldMissing("conversation data")

+ var ErrConversationIDRequired = centralErrors.RequiredFieldMissing("conversation ID")

+ var ErrConversationMuteConversationIDRequired = centralErrors.RequiredFieldMissing("conversation ID")

+ var ErrConversationMuteUsernameRequired = centralErrors.RequiredFieldMissing("username")

+ var ErrConversationStatusIDRequired = centralErrors.RequiredFieldMissing("conversation ID")

+ var ErrConversationStatusStatusIDRequired = centralErrors.RequiredFieldMissing("status ID")

+ var ErrConversationStatusUserIDRequired = centralErrors.RequiredFieldMissing("user ID")

+ var ErrCostWindowEndBeforeStart = centralErrors.NewValidationError("window_end", "WindowEnd must be after WindowStart")

+ var ErrCostWindowEndRequired = centralErrors.RequiredFieldMissing("WindowEnd")

+ var ErrCostWindowStartRequired = centralErrors.RequiredFieldMissing("WindowStart")

+ var ErrDLQErrorMessageRequired = centralErrors.RequiredFieldMissing("ErrorMessage")

+ var ErrDLQErrorTypeRequired = centralErrors.RequiredFieldMissing("ErrorType")

+ var ErrDLQIDRequired = centralErrors.RequiredFieldMissing("ID")

+ var ErrDLQInvalidPriority = centralErrors.NewValidationError("priority", "Invalid priority")

+ var ErrDLQInvalidStatus = centralErrors.NewValidationError("status", "Invalid status")

+ var ErrDLQMessageBodyRequired = centralErrors.RequiredFieldMissing("MessageBody")

+ var ErrDLQOriginalMessageIDRequired = centralErrors.RequiredFieldMissing("OriginalMessageID")

+ var ErrDLQServiceRequired = centralErrors.RequiredFieldMissing("service")

+ var ErrDeliveryIDRequired = centralErrors.RequiredFieldMissing("delivery_id")

+ var ErrDeliveryMethodRequired = centralErrors.RequiredFieldMissing("delivery method")

+ var ErrExpiresAtRequired = centralErrors.RequiredFieldMissing("ExpiresAt")

+ var ErrExportInvalidEndDate = centralErrors.InvalidFormat("end_date", "valid date format")

+ var ErrExportInvalidStartDate = centralErrors.InvalidFormat("start_date", "valid date format")

+ var ErrFailedToUpdateKeys = centralErrors.FailedToUpdate("keys", stdErrors.New("failed to update keys"))

+ var ErrFileSizeTooLarge = centralErrors.FileSizeExceedsLimit(0, 0)

+ var ErrFileSizeZero = centralErrors.ValueOutOfRange("FileSize", 1, int64(^uint64(0) >> 1), 0)

+ var ErrInvalidActorIDFormat = centralErrors.InvalidFormat("actorID", "valid actor ID format")

+ var ErrInvalidAggregationLevel = centralErrors.NewValidationError("aggregation_level", "Invalid aggregation level")

+ var ErrInvalidBudgetLimit = centralErrors.ValidationFailedWithField("limit_micro_cents must be positive")

+ var ErrInvalidCostPeriod = centralErrors.NewValidationError("period", "Invalid period")

+ var ErrInvalidDailyPeriodFormat = centralErrors.InvalidFormat("daily_period", "YYYY-MM-DD format")

+ var ErrInvalidDeliveryMethod = centralErrors.NewValidationError("delivery_method", "Invalid delivery method")

+ var ErrInvalidDeliveryStatus = centralErrors.NewValidationError("delivery_status", "Invalid delivery status")

+ var ErrInvalidFileSize = centralErrors.InvalidFileSize()

+ var ErrInvalidJobStatus = centralErrors.NewValidationError("job_status", "Invalid job status")

+ var ErrInvalidJobType = centralErrors.NewValidationError("job_type", "Invalid job type")

+ var ErrInvalidMediaCategory = centralErrors.NewValidationError("media_category", "Invalid media category")

+ var ErrInvalidMediaJobStatus = centralErrors.NewValidationError("job_status", "Invalid job status")

+ var ErrInvalidMediaStatus = centralErrors.NewValidationError("media_status", "Invalid media status")

+ var ErrInvalidMetricType = centralErrors.NewValidationError("metric_type", "Invalid metric type")

+ var ErrInvalidMonthlyPeriodFormat = centralErrors.InvalidFormat("monthly_period", "YYYY-MM format")

+ var ErrInvalidNotificationType = centralErrors.NewValidationError("notification_type", "Invalid notification type")

+ var ErrInvalidOperationType = centralErrors.NewValidationError("operation_type", "Invalid operation type")

+ var ErrInvalidPeriod = centralErrors.NewValidationError("period", "Invalid period")

+ var ErrInvalidPeriodType = centralErrors.NewValidationError("period_type", "Invalid period type")

+ var ErrInvalidPeriodTypeValue = centralErrors.NewValidationError("period_type", "PeriodType must be 'monthly' or 'daily'")

+ var ErrInvalidPlanTier = centralErrors.InvalidPlanTier()

+ var ErrInvalidProvider = centralErrors.NewValidationError("provider", "Invalid provider")

+ var ErrInvalidQualitySetting = centralErrors.InvalidQualitySetting()

+ var ErrInvalidReputationDataJSON = centralErrors.JSONFormatInvalid("invalid reputation data structure")

+ var ErrInvalidReputationJSON = centralErrors.JSONFormatInvalid("invalid reputation structure")

+ var ErrInvalidScheduledJobPeriod = centralErrors.NewValidationError("period", "Invalid period")

+ var ErrInvalidScheduledJobSchedule = centralErrors.NewValidationError("schedule", "Invalid schedule")

+ var ErrInvalidScheduledJobStatus = centralErrors.NewValidationError("status", "Invalid status")

+ var ErrInvalidSpendingCategory = centralErrors.NewValidationError("category", "Invalid category")

+ var ErrInvalidWebSocketOperationType = centralErrors.NewValidationError("operation_type", "Invalid operation type")

+ var ErrInvalidWebSocketPeriod = centralErrors.NewValidationError("period", "Invalid period")

+ var ErrMediaAttachmentEntityIDRequired = centralErrors.RequiredFieldMissing("EntityID")

+ var ErrMediaAttachmentEntityTypeRequired = centralErrors.RequiredFieldMissing("EntityType")

+ var ErrMediaAttachmentIDRequired = centralErrors.RequiredFieldMissing("MediaID")

+ var ErrMediaAttachmentInvalidEntityType = centralErrors.NewValidationError("entity_type", "Invalid entity type")

+ var ErrMediaAttachmentInvalidFocalPoint = centralErrors.InvalidFormat("focal_point", "x,y format")

+ var ErrMediaAttachmentOrderNegative = centralErrors.ValueOutOfRange("order", 0, int64(^uint64(0) >> 1), -1)

+ var ErrMediaIDRequired = centralErrors.RequiredFieldMissing("MediaID")

+ var ErrMediaJobIDRequired = centralErrors.RequiredFieldMissing("JobID")

+ var ErrMediaMetadataDurationNegative = centralErrors.ValueOutOfRange("duration", 0, int64(^uint64(0) >> 1), -1)

+ var ErrMediaMetadataFileSizeNegative = centralErrors.ValueOutOfRange("file_size", 0, int64(^uint64(0) >> 1), -1)

+ var ErrMediaMetadataHeightNegative = centralErrors.ValueOutOfRange("height", 0, int64(^uint64(0) >> 1), -1)

+ var ErrMediaMetadataIDRequired = centralErrors.RequiredFieldMissing("MediaID")

+ var ErrMediaMetadataInvalidStatus = centralErrors.NewValidationError("status", "Invalid status")

+ var ErrMediaMetadataWidthNegative = centralErrors.ValueOutOfRange("width", 0, int64(^uint64(0) >> 1), -1)

+ var ErrMediaSpendingPeriodRequired = centralErrors.RequiredFieldMissing("period")

+ var ErrMediaSpendingTransactionIDRequired = centralErrors.RequiredFieldMissing("TransactionID")

+ var ErrMediaSpendingUserIDRequired = centralErrors.RequiredFieldMissing("UserID")

+ var ErrMessageIDRequired = centralErrors.RequiredFieldMissing("message_id")

+ var ErrMetricIDRequired = centralErrors.RequiredFieldMissing("ID")

+ var ErrMetricRecordServiceRequired = centralErrors.RequiredFieldMissing("ServiceName")

+ var ErrMetricRecordTypeRequired = centralErrors.RequiredFieldMissing("MetricType")

+ var ErrMetricServiceRequired = centralErrors.RequiredFieldMissing("service")

+ var ErrMetricTypeRequired = centralErrors.RequiredFieldMissing("type")

+ var ErrMetricWindowEndRequired = centralErrors.RequiredFieldMissing("WindowEnd")

+ var ErrMetricWindowStartRequired = centralErrors.RequiredFieldMissing("WindowStart")

+ var ErrModerationThresholdInvalid = centralErrors.ModerationThresholdInvalid()

+ var ErrMuteUpdateKeysFailed = centralErrors.FailedToUpdate("mute keys", stdErrors.New("failed to update mute keys"))

+ var ErrNegativeCost = centralErrors.ValueOutOfRange("cost", 0, int64(^uint64(0) >> 1), -1)

+ var ErrNegativeCostMicros = centralErrors.ValueOutOfRange("CostMicros", 0, int64(^uint64(0) >> 1), -1)

+ var ErrNegativeSize = centralErrors.ValueOutOfRange("size", 0, int64(^uint64(0) >> 1), -1)

+ var ErrNegativeSpendingAmounts = centralErrors.ValueOutOfRange("spending_amounts", 0, int64(^uint64(0) >> 1), -1)

+ var ErrNotificationIDRequired = centralErrors.RequiredFieldMissing("notification ID")

+ var ErrOAuthCSRFTokenGenerationFailed = centralErrors.CSRFTokenGenerationFailed(stdErrors.New("OAuth CSRF token generation failed"))

+ var ErrOAuthSessionIDGenerationFailed = centralErrors.SessionIDGenerationFailed(stdErrors.New("OAuth session ID generation failed"))

+ var ErrPlanUpgradeFailed = centralErrors.PlanUpgradeFailed(stdErrors.New("plan upgrade failed"))

+ var ErrProviderIDRequired = centralErrors.RequiredFieldMissing("provider ID")

+ var ErrPushSubscriptionAuthRequired = centralErrors.RequiredFieldMissing("auth secret")

+ var ErrPushSubscriptionP256dhRequired = centralErrors.RequiredFieldMissing("p256dh public key")

+ var ErrRelayWindowStartRequired = centralErrors.ValidationFailedWithField("window start is required")

+ var ErrReputationDataUnmarshalFailed = centralErrors.UnmarshalingFailed("reputation data", stdErrors.New("reputation data unmarshaling failed"))

+ var ErrReputationMarshalFailed = centralErrors.MarshalingFailed("reputation", stdErrors.New("reputation marshaling failed"))

+ var ErrReputationUnmarshalFailed = centralErrors.UnmarshalingFailed("reputation to map", stdErrors.New("reputation unmarshaling failed"))

+ var ErrScheduledJobWindowEndBeforeStart = centralErrors.NewValidationError("window_end", "WindowEnd must be after WindowStart")

+ var ErrScheduledJobWindowEndRequired = centralErrors.RequiredFieldMissing("WindowEnd")

+ var ErrScheduledJobWindowStartRequired = centralErrors.RequiredFieldMissing("WindowStart")

+ var ErrSessionIDGenerationFailed = centralErrors.SessionIDGenerationFailed(stdErrors.New("session ID generation failed"))

+ var ErrTimestampRequired = centralErrors.RequiredFieldMissing("timestamp")

+ var ErrTranscodingJobIDRequired = centralErrors.RequiredFieldMissing("transcoding job ID")

+ var ErrTranscodingMediaIDRequired = centralErrors.RequiredFieldMissing("transcoding media ID")

+ var ErrTranscodingUserIDRequired = centralErrors.RequiredFieldMissing("transcoding user ID")

+ var ErrUnsupportedContentType = centralErrors.ContentTypeNotAllowed("unknown")

+ var ErrUploadLimitsInvalid = centralErrors.UploadLimitsInvalid()

+ var ErrUserIDRequired = centralErrors.UserIDRequired()

+ var ErrVideoDurationInvalid = centralErrors.VideoDurationInvalid()

+ var ErrWebSocketWindowEndBeforeStart = centralErrors.NewValidationError("window_end", "WindowEnd must be after WindowStart")

+ var ErrWebSocketWindowEndRequired = centralErrors.RequiredFieldMissing("WindowEnd")

+ var ErrWebSocketWindowStartRequired = centralErrors.RequiredFieldMissing("WindowStart")

+ var ErrWebhookIDRequired = centralErrors.RequiredFieldMissing("webhook_id")

+ var ErrWindowEndBeforeStart = centralErrors.NewValidationError("window_end", "WindowEnd must be after WindowStart")

+ var MainTableName = config.GetMainTableName()

+ func CMSArticleIndexExtractArticleID(sk string) string

+ func CMSArticleIndexPKForAuthor(actorID string) string

+ func CMSArticleIndexPKForCategory(categoryID string) string

+ func CMSArticleIndexPKForSeries(seriesID string) string

+ func CMSArticleIndexSK(published time.Time, articleID string) string

+ func CMSArticleSlugIndexPK(slug string) string

+ func CMSArticleSlugIndexSK() string

+ func CMSCategorySlugIndexPK(slug string) string

+ func CMSCategorySlugIndexSK() string

+ func CMSPublicationSlugIndexPK(slug string) string

+ func CMSPublicationSlugIndexSK() string

+ func CMSSeriesSlugIndexPK(slug string) string

+ func CMSSeriesSlugIndexSK() string

+ func CMSSlugIndexSK() string

+ func CalculateCost(readUnits, writeUnits float64) (readCostMicroCents, writeCostMicroCents, totalCostMicroCents int64)

+ func CalculateDynamoDBCost(readCapacityUnits, writeCapacityUnits float64) int64

+ func CalculateEmailCost(_ int64) int64

+ func CalculateLambdaCost(invocations int64, gbSeconds float64) int64

+ func CalculatePatternAccuracy(feedbacks []*PatternFeedback) float64

+ func CalculatePatternMetrics(feedbacks []*PatternFeedback) map[string]interface

+ func CalculatePushCost(messageCount int64) int64

+ func CalculateSMSCost(_ int64) int64

+ func CalculateScheduledJobCosts(lambdaDurationMs int64, memoryMB int, dynamoDBReadOps, dynamoDBWriteOps int64, ...) (...)

+ func CalculateWebSocketCost(messageCount int64) int64

+ func ExtractDomain(actorID string) string

+ func FormatStatsDate(t time.Time) string

+ func GetCostDriverKey(category, resource string) (pk, sk string)

+ func GetCostDriversByCategoryKeys(category string) (pk, skPrefix string)

+ func GetCostProjectionKey(period string, timestamp time.Time) (pk, sk string)

+ func GetFederationStatsKey(date string) (pk, sk string)

+ func GetFederationStatsRangeKeys(startDate, endDate string) (pk, skStart, skEnd string)

+ func GetHealthReportKey(domain, timestamp string) (pk, sk string)

+ func GetHealthReportRangeKeys(domain string, startTime, endTime time.Time) (pk, skStart, skEnd string)

+ func GetLatestHealthReportKeys(domain string) (pk, skPrefix string)

+ func GetLatestProjectionKeys(period string) (pk, skPrefix string)

+ func GetLinkMetadataKey(linkURL string) (pk, sk string)

+ func GetPatternFeedbackKey(patternID, timestamp, feedbackID string) (pk, sk string)

+ func GetPatternFeedbackKeys(patternID string) (pk, skPrefix string)

+ func GetPatternFeedbackRangeKeys(patternID string, startTime, endTime time.Time) (pk, skStart, skEnd string)

+ func GetProjectionRangeKeys(period string, startTime, endTime time.Time) (pk, skStart, skEnd string)

+ func GetReviewerStatsKey(reviewerID string) (pk, sk string)

+ func GetTimeBucket(timestamp time.Time, period string) time.Time

+ func GetTrendingLinkKey(date, linkID string, score float64) (pk, sk string)

+ func GetTrendingLinksByDomainKeys(date, _ string) (pk, skPrefix string)

+ func GetTrendingLinksKeys(date string) (pk, skPrefix string)

+ func GetTrendingStatusesKeys(date string) (pk, skPrefix string)

+ func GetTrusteeConfigKey(category, username string) (pk, sk string)

+ func GetTrusteeConfigsByCategoryKeys(category string) (pk, skPrefix string)

+ func GetTrusteeConfigsByUserKeys(_ string) (pk, skStart, skEnd string)

+ func IsValidMediaCategory(category MediaCategory) bool

+ type AIAggregatedCost struct

+ AvgComplexityScore float64

+ AvgComprehensivenessScore float64

+ AvgCostMicroCents int64

+ AvgEfficiencyScore float64

+ AvgInputTokens float64

+ AvgLatencyMs float64

+ AvgOutputTokens float64

+ AvgQualityScore float64

+ AvgRelevanceScore float64

+ AvgTokensPerSecond float64

+ CostPerInputToken float64

+ CostPerOutputToken float64

+ CreatedAt time.Time

+ FailedOperations int64

+ GSI1PK string

+ GSI1SK string

+ MaxCostMicroCents int64

+ MedianCostMicroCents int64

+ MinCostMicroCents int64

+ ModelName string

+ OperationType string

+ P95LatencyMs float64

+ P99LatencyMs float64

+ PK string

+ Period string

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ SK string

+ SuccessRate float64

+ SuccessfulOperations int64

+ TTL int64

+ TopComplexityFactors []string

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalInputTokens int64

+ TotalOperations int64

+ TotalOutputTokens int64

+ UpdatedAt time.Time

+ func (a *AIAggregatedCost) BeforeCreate() error

+ func (a *AIAggregatedCost) BeforeUpdate() error

+ func (a *AIAggregatedCost) GetPK() string

+ func (a *AIAggregatedCost) GetSK() string

+ func (a *AIAggregatedCost) TableName() string

+ func (a *AIAggregatedCost) UpdateKeys() error

+ type AIAnalysis struct

+ AIDetection *ai.AIDetection

+ AnalyzedAt time.Time

+ Confidence float64

+ CreatedAt time.Time

+ GSI4PK string

+ GSI4SK string

+ ID string

+ ImageAnalysis *ai.ImageAnalysis

+ ModerationAction string

+ ObjectID string

+ ObjectType string

+ OverallRisk float64

+ PK string

+ SK string

+ SpamAnalysis *ai.SpamAnalysis

+ TextAnalysis *ai.TextAnalysis

+ Type string

+ UpdatedAt time.Time

+ Version string

+ func (AIAnalysis) TableName() string

+ func (a *AIAnalysis) BeforeCreate() error

+ func (a *AIAnalysis) BeforeUpdate() error

+ func (a *AIAnalysis) GetPK() string

+ func (a *AIAnalysis) GetSK() string

+ func (a *AIAnalysis) UpdateKeys() error

+ type AIAnalysisQueue struct

+ ForceAnalysis bool

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func (AIAnalysisQueue) TableName() string

+ func (q *AIAnalysisQueue) BeforeUpdate() error

+ func (q *AIAnalysisQueue) GetPK() string

+ func (q *AIAnalysisQueue) GetSK() string

+ func (q *AIAnalysisQueue) UpdateKeys() error

+ type AICost struct

+ ActorID string

+ BillingPeriod string

+ CharactersPerToken float64

+ ComplexityFactors []string

+ ComplexityPenaltyCost int64

+ ComplexityScore float64

+ ComprehensivenesScore float64

+ ContentLength int64

+ ContentType string

+ CostPerCharacter float64

+ CostPerInputToken float64

+ CostPerOutputToken float64

+ CostTier string

+ CreatedAt time.Time

+ EfficiencyScore float64

+ ErrorCode string

+ ErrorMessage string

+ FirstTokenLatencyMs int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ InputCharacters int64

+ InputTokenCost int64

+ InputTokens int64

+ LanguageDetected string

+ MaxTokens int64

+ ModelConfig map[string]interface{}

+ ModelEndpoint string

+ ModelFamily string

+ ModelInferenceCost int64

+ ModelLatencyMs int64

+ ModelName string

+ ModelRegion string

+ ModelVersion string

+ ObjectID string

+ OperationContext map[string]string

+ OperationID string

+ OperationType string

+ OutputCharacters int64

+ OutputTokenCost int64

+ OutputTokens int64

+ PK string

+ Priority string

+ ProcessingEnd time.Time

+ ProcessingStart time.Time

+ QualityScore float64

+ QueueWaitTimeMs int64

+ RelevanceScore float64

+ RequestID string

+ RequestLatencyMs int64

+ ResponseFormat string

+ RetryCost int64

+ RetryCount int

+ SK string

+ SentimentMagnitude float64

+ SentimentPolarity float64

+ StreamingEnabled bool

+ Success bool

+ SystemPrompt string

+ TTL int64

+ Temperature float64

+ Timestamp time.Time

+ TokenGenerationMs int64

+ TokensPerSecond float64

+ TopP float64

+ TotalCostMicroCents int64

+ TotalTokens int64

+ UpdatedAt time.Time

+ UserID string

+ UserPrompt string

+ func (a *AICost) AddComplexityFactor(factor string)

+ func (a *AICost) BeforeCreate() error

+ func (a *AICost) BeforeUpdate() error

+ func (a *AICost) CalculateTotalCost()

+ func (a *AICost) GetOperationSummary() map[string]interface{}

+ func (a *AICost) GetPK() string

+ func (a *AICost) GetPerformanceMetrics() map[string]interface{}

+ func (a *AICost) GetSK() string

+ func (a *AICost) GetTotalCostDollars() float64

+ func (a *AICost) SetModelPricing()

+ func (a *AICost) TableName() string

+ func (a *AICost) UpdateKeys() error

+ type AIInstanceConfig struct

+ AIContentDetection bool

+ AIEnabled bool

+ ModerationEnabled bool

+ NSFWDetectionEnabled bool

+ PIIDetectionEnabled bool

+ PK string

+ SK string

+ SpamDetectionEnabled bool

+ UpdatedAt time.Time

+ func NewAIInstanceConfig() *AIInstanceConfig

+ func (AIInstanceConfig) TableName() string

+ func (c *AIInstanceConfig) GetPK() string

+ func (c *AIInstanceConfig) GetSK() string

+ func (c *AIInstanceConfig) UpdateKeys() error

+ type APIRateLimit struct

+ Blocked bool

+ BlockedUntil time.Time

+ Count int

+ Domain string

+ Endpoint string

+ FirstViolation time.Time

+ LastViolation time.Time

+ PK string

+ SK string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ UserID string

+ ViolationCount int

+ Window time.Time

+ func NewAPIRateLimit(userID, endpoint string, windowStart time.Time) *APIRateLimit

+ func NewFederationRateLimit(domain, endpoint string, windowStart time.Time) *APIRateLimit

+ func (APIRateLimit) TableName() string

+ func (arl *APIRateLimit) GetPK() string

+ func (arl *APIRateLimit) GetSK() string

+ func (arl *APIRateLimit) UpdateKeys() error

+ type AccountNote struct

+ CreatedAt time.Time

+ Note string

+ PK string

+ SK string

+ TargetActorID string

+ UpdatedAt time.Time

+ Username string

+ func (AccountNote) TableName() string

+ func (n *AccountNote) BeforeCreate() error

+ func (n *AccountNote) GetPK() string

+ func (n *AccountNote) GetSK() string

+ func (n *AccountNote) UpdateKeys() error

+ type AccountPin struct

+ CreatedAt time.Time

+ PK string

+ PinnedActorID string

+ PinnedUsername string

+ SK string

+ Username string

+ func (AccountPin) TableName() string

+ func (p *AccountPin) BeforeCreate() error

+ func (p *AccountPin) GetPK() string

+ func (p *AccountPin) GetSK() string

+ func (p *AccountPin) UpdateKeys() error

+ type Activity struct

+ Activity *activitypub.Activity

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ func (Activity) TableName() string

+ func (a *Activity) GetPK() string

+ func (a *Activity) GetSK() string

+ func (a *Activity) UpdateKeys() error

+ type ActivityMetric struct

+ ActivityType string

+ ActorID string

+ CreatedAt time.Time

+ PK string

+ SK string

+ Timestamp string

+ Type string

+ func NewActivityMetric(activityType, actorID string, timestamp time.Time) *ActivityMetric

+ func (ActivityMetric) TableName() string

+ type Actor struct

+ Actor *activitypub.Actor

+ CreatedAt time.Time

+ Fields []ActorField

+ FollowerCount int

+ FollowingCount int

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ GSI5PK string

+ GSI5SK string

+ KeyType string

+ LastStatusAt *time.Time

+ NumericID string

+ PK string

+ PrivateKey string

+ SK string

+ StatusCount int

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func (Actor) TableName() string

+ func (a *Actor) BeforeCreate() error

+ func (a *Actor) BeforeUpdate() error

+ func (a *Actor) GetPK() string

+ func (a *Actor) GetSK() string

+ func (a *Actor) UpdateKeys() error

+ type ActorField struct

+ Name string

+ Value string

+ VerifiedAt *time.Time

+ func (ActorField) TableName() string

+ type ActorMetadata struct

+ CreatedAt time.Time

+ Fields []ActorField

+ LastStatusAt *time.Time

+ UpdatedAt time.Time

+ func (ActorMetadata) TableName() string

+ type AdvancedModerationAction string

+ const AdvancedModerationActionAllow

+ const AdvancedModerationActionFlag

+ const AdvancedModerationActionQuarantine

+ const AdvancedModerationActionRemove

+ const AdvancedModerationActionReportToAuth

+ const AdvancedModerationActionShadowBan

+ type AdvancedSeverity string

+ const AdvancedSeverityCritical

+ const AdvancedSeverityHigh

+ const AdvancedSeverityLow

+ const AdvancedSeverityMedium

+ type AffectedRelationship struct

+ ActorDomain string

+ ActorHandle string

+ ActorID string

+ CreatedAt time.Time

+ EstablishedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ LastInteraction *time.Time

+ PK string

+ RelationshipType string

+ SK string

+ SeveranceID string

+ TTL int64

+ func NewAffectedRelationship(severanceID, actorID, actorHandle, actorDomain, relationshipType string, ...) *AffectedRelationship

+ func (AffectedRelationship) TableName() string

+ func (a *AffectedRelationship) GetPK() string

+ func (a *AffectedRelationship) GetSK() string

+ func (a *AffectedRelationship) UpdateKeys() error

+ type AgentConcurrencySlot struct

+ ExpiresAt time.Time

+ LeaseID string

+ PK string

+ SK string

+ TTL int64

+ func (AgentConcurrencySlot) TableName() string

+ func (s *AgentConcurrencySlot) BeforeCreate() error

+ type AgentInstanceConfig struct

+ AgentMaxFollowsPerHour int

+ AgentMaxPostsPerHour int

+ AllowAgentRegistration bool

+ AllowAgents bool

+ AllowRemoteAgents bool

+ BlockedAgentDomains []string

+ DefaultQuarantineDays int

+ HybridRetrievalEnabled bool

+ HybridRetrievalMaxCandidates int

+ MaxAgentsPerOwner int

+ PK string

+ RemoteQuarantineDays int

+ SK string

+ TrustedAgentDomains []string

+ UpdatedAt time.Time

+ VerifiedAgentMaxFollowsPerHour int

+ VerifiedAgentMaxPostsPerHour int

+ func NewAgentInstanceConfig() *AgentInstanceConfig

+ func (AgentInstanceConfig) TableName() string

+ func (c *AgentInstanceConfig) GetPK() string

+ func (c *AgentInstanceConfig) GetSK() string

+ func (c *AgentInstanceConfig) UpdateKeys() error

+ type AgentKeyChallenge struct

+ Action string

+ ExpiresAt time.Time

+ ID string

+ IssuedAt time.Time

+ Message string

+ Nonce string

+ PK string

+ SK string

+ TTL int64

+ Used bool

+ Username string

+ func (AgentKeyChallenge) TableName() string

+ func (c *AgentKeyChallenge) BeforeCreate() error

+ type AgentMemoryEvent struct

+ AgentUsername string

+ CreatedAt time.Time

+ EventID string

+ EventType string

+ GSI1PK string

+ GSI1SK string

+ OriginalID string

+ PK string

+ Reason string

+ SK string

+ StatusID string

+ Timestamp time.Time

+ func (AgentMemoryEvent) TableName() string

+ func (e *AgentMemoryEvent) BeforeCreate() error

+ type AggregatedMetrics struct

+ Average float64

+ CreatedAt time.Time

+ DimensionBreakdown map[string]DimensionStats

+ ExpiresAt int64

+ Max float64

+ Min float64

+ PK string

+ Percentiles map[string]float64

+ Period string

+ SK string

+ Service string

+ ServiceMetrics map[string]interface{}

+ StdDev float64

+ TotalCount int64

+ TotalSum float64

+ Type string

+ UpdatedAt time.Time

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (AggregatedMetrics) TableName() string

+ func (am *AggregatedMetrics) BeforeCreate() error

+ func (am *AggregatedMetrics) BeforeUpdate() error

+ func (am *AggregatedMetrics) GetPK() string

+ func (am *AggregatedMetrics) GetSK() string

+ func (am *AggregatedMetrics) UpdateKeys() error

+ func (am *AggregatedMetrics) Validate() error

+ type Alert struct

+ AlertID string

+ CreatedAt time.Time

+ DeliveryAttempts int

+ DeliveryChannels []string

+ Description string

+ Dimensions map[string]string

+ EscalationLevel int

+ FiredAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GroupKey string

+ LastDeliveryAt *time.Time

+ Message string

+ Metadata map[string]interface{}

+ NextRetryAt *time.Time

+ PK string

+ Priority string

+ Region string

+ ResolvedAt *time.Time

+ RunbookURL string

+ SK string

+ Service string

+ Severity string

+ Source string

+ Status string

+ SuppressionUntil *time.Time

+ TTL int64

+ Thresholds map[string]float64

+ Title string

+ Type string

+ UpdatedAt time.Time

+ Values map[string]float64

+ func (Alert) TableName() string

+ func (a *Alert) Acknowledge()

+ func (a *Alert) AddDimension(key, value string)

+ func (a *Alert) AddMetadata(key string, value interface{})

+ func (a *Alert) AddThreshold(key string, value float64)

+ func (a *Alert) AddValue(key string, value float64)

+ func (a *Alert) CalculateNextRetry() time.Time

+ func (a *Alert) Escalate()

+ func (a *Alert) GetPK() string

+ func (a *Alert) GetSK() string

+ func (a *Alert) IsActive() bool

+ func (a *Alert) IsCritical() bool

+ func (a *Alert) IsHighPriority() bool

+ func (a *Alert) IsResolved() bool

+ func (a *Alert) RecordDeliveryAttempt(success bool)

+ func (a *Alert) Resolve()

+ func (a *Alert) ShouldRetry() bool

+ func (a *Alert) Suppress(until time.Time)

+ func (a *Alert) UpdateKeys() error

+ type Announce struct

+ Actor string

+ CC []string

+ CreatedAt time.Time

+ GSI4PK string

+ GSI4SK string

+ ID string

+ Object string

+ PK string

+ Published time.Time

+ SK string

+ To []string

+ func (Announce) TableName() string

+ func (a *Announce) BeforeCreate() error

+ func (a *Announce) GetPK() string

+ func (a *Announce) GetSK() string

+ func (a *Announce) UpdateKeys() error

+ type Announcement struct

+ AllDay bool

+ Content string

+ CreatedAt time.Time

+ CreatedBy string

+ Emojis []CustomEmoji

+ EndsAt *time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ Mentions []Mention

+ PK string

+ PublishedAt time.Time

+ Reactions []Reaction

+ SK string

+ StartsAt *time.Time

+ Tags []string

+ Text string

+ UpdatedAt time.Time

+ func (Announcement) TableName() string

+ func (a *Announcement) BeforeCreate() error

+ func (a *Announcement) GetPK() string

+ func (a *Announcement) GetSK() string

+ func (a *Announcement) IsActive() bool

+ func (a *Announcement) UpdateKeys() error

+ type AnnouncementDismissal struct

+ AnnouncementID string

+ DismissedAt time.Time

+ PK string

+ SK string

+ Username string

+ func (AnnouncementDismissal) TableName() string

+ func (d *AnnouncementDismissal) BeforeCreate() error

+ func (d *AnnouncementDismissal) GetPK() string

+ func (d *AnnouncementDismissal) GetSK() string

+ func (d *AnnouncementDismissal) UpdateKeys() error

+ type AnnouncementReaction struct

+ AnnouncementID string

+ EmojiName string

+ PK string

+ ReactedAt time.Time

+ SK string

+ Username string

+ func (AnnouncementReaction) TableName() string

+ func (r *AnnouncementReaction) BeforeCreate() error

+ func (r *AnnouncementReaction) GetPK() string

+ func (r *AnnouncementReaction) GetSK() string

+ func (r *AnnouncementReaction) UpdateKeys() error

+ type Article struct

+ CanonicalURL string

+ CategoryIDs []string

+ ContentFormat string

+ CreatedAt time.Time

+ EditorNotes string

+ Excerpt string

+ FeaturedImage *Media

+ OGImage string

+ ReadingTimeMinutes int

+ ReviewStatus string

+ SEODescription string

+ SEOTitle string

+ SeriesID *string

+ SeriesOrder *int

+ Slug string

+ Subtitle string

+ TableOfContents []TOCEntry

+ UpdatedAt time.Time

+ WordCount int

+ func (Article) TableName() string

+ func (a *Article) UpdateKeys() error

+ type AuditLog struct

+ Action string

+ AdminID string

+ AdminRole string

+ CreatedAt time.Time

+ Details any

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ IPAddress string

+ PK string

+ Reason string

+ RequestID string

+ SK string

+ TTL int64

+ TargetID string

+ TargetType string

+ Timestamp time.Time

+ Type string

+ UserAgent string

+ func (AuditLog) TableName() string

+ func (a *AuditLog) UpdateKeys()

+ type AuthAuditLog struct

+ City string

+ ComplianceFlags []string

+ Country string

+ CreatedAt time.Time

+ DataRetentionDays int

+ DeviceName string

+ EventType string

+ FailureReason string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ ID string

+ IPAddress string

+ Latitude float64

+ Longitude float64

+ Metadata string

+ PK string

+ Region string

+ RequestID string

+ RiskFlags []string

+ RiskScore float64

+ SK string

+ SessionID string

+ Severity string

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ UserAgent string

+ UserID string

+ Username string

+ func (AuthAuditLog) TableName() string

+ func (a *AuthAuditLog) BeforeSave() error

+ func (a *AuthAuditLog) GetPK() string

+ func (a *AuthAuditLog) GetSK() string

+ func (a *AuthAuditLog) UpdateKeys() error

+ type AuthRefreshToken struct

+ CreatedAt int64

+ DeviceName string

+ ExpiresAt int64

+ Family string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ Generation int

+ IPAddress string

+ LastUsedAt int64

+ PK string

+ Revoked bool

+ RevokedReason string

+ SK string

+ TTL int64

+ Token string

+ UserFamily string

+ UserID string

+ func (AuthRefreshToken) TableName() string

+ func (a *AuthRefreshToken) BeforeCreate() error

+ func (a *AuthRefreshToken) BeforeUpdate() error

+ func (a *AuthRefreshToken) GetPK() string

+ func (a *AuthRefreshToken) GetSK() string

+ func (a *AuthRefreshToken) IsActive() bool

+ func (a *AuthRefreshToken) IsExpired() bool

+ func (a *AuthRefreshToken) UpdateKeys() error

+ type AuthorizationCode struct

+ ClientID string

+ Code string

+ CodeChallenge string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ PK string

+ SK string

+ Scopes []string

+ TTL int64

+ Username string

+ func (AuthorizationCode) TableName() string

+ func (a *AuthorizationCode) BeforeCreate() error

+ func (a *AuthorizationCode) GetPK() string

+ func (a *AuthorizationCode) GetSK() string

+ func (a *AuthorizationCode) UpdateKeys() error

+ type BackgroundFetchJob struct

+ Attempts int

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ ErrorDetails string

+ FetchMetadata map[string]string

+ FetchType string

+ GSI1PK string

+ GSI1SK string

+ JobID string

+ LastAttempt *time.Time

+ LastError string

+ MaxRetries int

+ NextAttempt *time.Time

+ PK string

+ Priority string

+ RemoteURL string

+ SK string

+ Status string

+ StatusID string

+ TTL int64

+ UpdatedAt time.Time

+ UserAgent string

+ func NewBackgroundFetchJob(statusID, fetchType string) *BackgroundFetchJob

+ func (BackgroundFetchJob) TableName() string

+ func (j *BackgroundFetchJob) AddMetadata(key, value string)

+ func (j *BackgroundFetchJob) BeforeCreate() error

+ func (j *BackgroundFetchJob) BeforeUpdate() error

+ func (j *BackgroundFetchJob) GetMetadata(key string) string

+ func (j *BackgroundFetchJob) IsReady() bool

+ func (j *BackgroundFetchJob) IsRetryable() bool

+ func (j *BackgroundFetchJob) MarkCompleted()

+ func (j *BackgroundFetchJob) MarkFailed(errorMsg, errorDetails string)

+ func (j *BackgroundFetchJob) MarkRunning()

+ func (j *BackgroundFetchJob) SetRemoteURL(url string)

+ func (j *BackgroundFetchJob) UpdateKeys()

+ type BatchGetKeys struct

+ BatchType string

+ CreatedAt time.Time

+ Key string

+ PK string

+ SK string

+ TTL int64

+ func (BatchGetKeys) TableName() string

+ func (b *BatchGetKeys) GetPK() string

+ func (b *BatchGetKeys) GetSK() string

+ func (b *BatchGetKeys) UpdateKeys() error

+ type Block struct

+ Actor string

+ CreatedAt time.Time

+ GSI5PK string

+ GSI5SK string

+ ID string

+ Object string

+ PK string

+ Published time.Time

+ SK string

+ Type string

+ func (Block) TableName() string

+ func (b *Block) BeforeCreate() error

+ func (b *Block) GetPK() string

+ func (b *Block) GetSK() string

+ func (b *Block) UpdateKeys() error

+ type Bookmark struct

+ CreatedAt time.Time

+ Locked bool

+ ObjectID string

+ PK string

+ RecordType string

+ SK string

+ TTL int64

+ TimeRecordSK string

+ Username string

+ func NewObjectIndexedBookmark(username, objectID string, createdAt time.Time, timeRecordSK string) (*Bookmark, error)

+ func NewTimeOrderedBookmark(username, objectID string, createdAt time.Time) (*Bookmark, error)

+ func (Bookmark) TableName() string

+ func (b *Bookmark) GetPK() string

+ func (b *Bookmark) GetSK() string

+ func (b *Bookmark) UpdateKeys() error

+ type CMSArticleIndex struct

+ ArticleID string

+ CreatedAt time.Time

+ PK string

+ PublishedAt time.Time

+ SK string

+ func (CMSArticleIndex) TableName() string

+ func (i *CMSArticleIndex) GetPK() string

+ func (i *CMSArticleIndex) GetSK() string

+ func (i *CMSArticleIndex) UpdateKeys() error

+ type CMSSeriesSlugIndex struct

+ AuthorID string

+ CreatedAt time.Time

+ PK string

+ SK string

+ SeriesID string

+ Slug string

+ UpdatedAt time.Time

+ func (CMSSeriesSlugIndex) TableName() string

+ func (i *CMSSeriesSlugIndex) GetPK() string

+ func (i *CMSSeriesSlugIndex) GetSK() string

+ func (i *CMSSeriesSlugIndex) UpdateKeys() error

+ type CMSSlugIndex struct

+ CreatedAt time.Time

+ PK string

+ SK string

+ Slug string

+ TargetID string

+ UpdatedAt time.Time

+ func (CMSSlugIndex) TableName() string

+ func (i *CMSSlugIndex) GetPK() string

+ func (i *CMSSlugIndex) GetSK() string

+ func (i *CMSSlugIndex) UpdateKeys() error

+ type CSRFToken struct

+ CreatedAt int64

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ TTL int64

+ Token string

+ Used bool

+ UserID string

+ func (CSRFToken) TableName() string

+ func (c *CSRFToken) BeforeCreate() error

+ func (c *CSRFToken) BeforeUpdate() error

+ func (c *CSRFToken) GetPK() string

+ func (c *CSRFToken) GetSK() string

+ func (c *CSRFToken) IsExpired() bool

+ func (c *CSRFToken) IsValid() bool

+ func (c *CSRFToken) MarkAsUsed()

+ func (c *CSRFToken) RemainingTime() time.Duration

+ func (c *CSRFToken) UpdateKeys() error

+ func (c *CSRFToken) Validate() error

+ type Category struct

+ ArticleCount int

+ Color string

+ CreatedAt time.Time

+ Description string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Name string

+ Order int

+ PK string

+ ParentID *string

+ SK string

+ Slug string

+ UpdatedAt time.Time

+ func (Category) TableName() string

+ func (c *Category) GetPK() string

+ func (c *Category) GetSK() string

+ func (c *Category) UpdateKeys() error

+ type CircuitBreakerConfig struct

+ BackoffMultiplier float64

+ FailureThreshold int

+ HalfOpenTimeout time.Duration

+ MaxBackoff time.Duration

+ MinimumRequests int

+ OpenTimeout time.Duration

+ SampleWindow time.Duration

+ SuccessThreshold int

+ func DefaultCircuitBreakerConfig() *CircuitBreakerConfig

+ func (CircuitBreakerConfig) TableName() string

+ type CircuitBreakerEvent struct

+ Error string

+ ErrorType string

+ EventType string

+ InstanceID string

+ NewStatus string

+ OldStatus string

+ PK string

+ Reason string

+ SK string

+ Success *bool

+ TTL int64

+ Timestamp time.Time

+ func (CircuitBreakerEvent) TableName() string

+ func (e *CircuitBreakerEvent) GetPK() string

+ func (e *CircuitBreakerEvent) GetSK() string

+ func (e *CircuitBreakerEvent) UpdateKeys() error

+ type CircuitBreakerState struct

+ BackoffDuration int64

+ ConsecutiveFails int

+ FailureCount int

+ InstanceID string

+ LastFailure time.Time

+ LastStateChange time.Time

+ LastSuccess time.Time

+ NextRetry time.Time

+ PK string

+ Reason string

+ SK string

+ Status string

+ SuccessCount int

+ TTL int64

+ TotalFailures int64

+ TotalRequests int64

+ TotalSuccesses int64

+ func (CircuitBreakerState) TableName() string

+ func (c *CircuitBreakerState) GetBackoffDuration() time.Duration

+ func (c *CircuitBreakerState) GetPK() string

+ func (c *CircuitBreakerState) GetSK() string

+ func (c *CircuitBreakerState) SetBackoffDuration(d time.Duration)

+ func (c *CircuitBreakerState) UpdateKeys() error

+ type CloudWatchMetrics struct

+ CacheExpiry time.Time

+ CloudWatchQueryTime time.Time

+ DataTransferBytes int64

+ Date string

+ DynamoDBReads int64

+ DynamoDBWrites int64

+ ErrorCount int64

+ EstimatedCostUSD float64

+ GSI1PK string

+ GSI1SK string

+ LambdaInvocations int64

+ LatencyP50Ms float64

+ LatencyP90Ms float64

+ LatencyP99Ms float64

+ PK string

+ RequestCount int64

+ S3Requests int64

+ SK string

+ ServiceName string

+ TTL int64

+ Timestamp time.Time

+ func (CloudWatchMetrics) TableName() string

+ func (c *CloudWatchMetrics) GetPK() string

+ func (c *CloudWatchMetrics) GetSK() string

+ func (c *CloudWatchMetrics) IsExpired() bool

+ func (c *CloudWatchMetrics) SetCacheExpiry()

+ func (c *CloudWatchMetrics) UpdateKeys() error

+ type CollectionItem struct

+ AddedAt time.Time

+ AddedBy string

+ Collection string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ItemID string

+ ItemType string

+ PK string

+ Position int

+ SK string

+ TTL *int64

+ func NewCollectionItem(collection, itemID, itemType, addedBy string) *CollectionItem

+ func (CollectionItem) TableName() string

+ func (c *CollectionItem) BeforeCreate() error

+ func (c *CollectionItem) ExtractCollection() string

+ func (c *CollectionItem) ExtractItemID() string

+ func (c *CollectionItem) SetPosition(position int)

+ func (c *CollectionItem) SetTTL(ttl time.Time)

+ func (c *CollectionItem) UpdateKeys()

+ type CommunityNote struct

+ AuthorID string

+ Content string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ HelpfulVotes int

+ ID string

+ Language string

+ NotHelpfulVotes int

+ ObjectID string

+ ObjectType string

+ Objectivity float64

+ PK string

+ SK string

+ Score float64

+ Sentiment float64

+ SourceQuality float64

+ Sources []string

+ TTL int64

+ UpdatedAt time.Time

+ VisibilityStatus string

+ func (CommunityNote) TableName() string

+ func (n *CommunityNote) GetPK() string

+ func (n *CommunityNote) GetSK() string

+ func (n *CommunityNote) UpdateKeys() error

+ type CommunityNoteVote struct

+ CreatedAt time.Time

+ Helpful bool

+ NoteID string

+ PK string

+ SK string

+ TTL int64

+ VoteType string

+ VoterID string

+ Weight float64

+ func (CommunityNoteVote) TableName() string

+ func (v *CommunityNoteVote) GetPK() string

+ func (v *CommunityNoteVote) GetSK() string

+ func (v *CommunityNoteVote) UpdateKeys() error

+ type ComponentHealthHistory struct

+ CheckTime time.Time

+ Component string

+ ComponentType string

+ Error string

+ LatencyMs int64

+ PK string

+ SK string

+ Status string

+ TTL int64

+ func NewComponentHealthHistory(componentType, component, status string, checkTime time.Time, latencyMs int64, ...) *ComponentHealthHistory

+ func (ComponentHealthHistory) TableName() string

+ func (c *ComponentHealthHistory) UpdateKeys()

+ type ConcurrentViewerMetrics struct

+ AverageViewers int64

+ CurrentViewers int64

+ NewViewers int64

+ PeakViewerTime time.Time

+ PeakViewers int64

+ ReturningViewers int64

+ SessionDuration float64

+ ViewerGrowthRate float64

+ func (ConcurrentViewerMetrics) TableName() string

+ type ConnectionInfo struct

+ APIVersion string

+ AuthMethod string

+ ClientIP string

+ CustomHeaders map[string]string

+ Origin string

+ Protocol string

+ UserAgent string

+ func (ConnectionInfo) TableName() string

+ type ConnectionMetrics struct

+ BytesReceived int64

+ BytesSent int64

+ ConnectionQuality float64

+ ErrorCount int32

+ LastError string

+ LastPingTime time.Time

+ LastPongTime time.Time

+ MessagesReceived int64

+ MessagesSent int64

+ PingLatencyMs int64

+ func (ConnectionMetrics) TableName() string

+ type ConnectionState string

+ const ConnectionStateClosed

+ const ConnectionStateClosing

+ const ConnectionStateConnected

+ const ConnectionStateConnecting

+ const ConnectionStateError

+ const ConnectionStateIdle

+ type Conversation struct

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ LastMessageTime time.Time

+ LastStatusID string

+ PK string

+ Participants []string

+ SK string

+ TotalMessageCount int64

+ Unread bool

+ UpdatedAt time.Time

+ func (Conversation) TableName() string

+ func (c *Conversation) BeforeCreate() error

+ func (c *Conversation) GetPK() string

+ func (c *Conversation) GetSK() string

+ func (c *Conversation) UpdateKeys() error

+ type ConversationMessage struct

+ ConversationID string

+ CreatedAt time.Time

+ PK string

+ ReadBy map[string]time.Time

+ SK string

+ SenderUsername string

+ StatusID string

+ TTL int64

+ func (ConversationMessage) TableName() string

+ func (m *ConversationMessage) BeforeCreate() error

+ func (m *ConversationMessage) GetPK() string

+ func (m *ConversationMessage) GetSK() string

+ func (m *ConversationMessage) UpdateKeys() error

+ type ConversationMute struct

+ ConversationID string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ PK string

+ SK string

+ TTL int64

+ Username string

+ func (ConversationMute) TableName() string

+ func (c *ConversationMute) BeforeCreate() error

+ func (c *ConversationMute) GetPK() string

+ func (c *ConversationMute) GetSK() string

+ func (c *ConversationMute) UpdateKeys() error

+ type ConversationParticipantKey struct

+ ConversationID string

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ func (ConversationParticipantKey) TableName() string

+ func (k *ConversationParticipantKey) GetPK() string

+ func (k *ConversationParticipantKey) GetSK() string

+ func (k *ConversationParticipantKey) UpdateKeys() error

+ type ConversationParticipantRecord struct

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ func (ConversationParticipantRecord) TableName() string

+ func (p *ConversationParticipantRecord) BeforeCreate(participantID string) error

+ func (p *ConversationParticipantRecord) GetPK() string

+ func (p *ConversationParticipantRecord) GetSK() string

+ func (p *ConversationParticipantRecord) UpdateKeys() error

+ type ConversationStatus struct

+ ConversationID string

+ LastReadAt time.Time

+ PK string

+ SK string

+ Unread bool

+ UserID string

+ func (ConversationStatus) TableName() string

+ func (s *ConversationStatus) BeforeCreate() error

+ func (s *ConversationStatus) GetPK() string

+ func (s *ConversationStatus) GetSK() string

+ func (s *ConversationStatus) UpdateKeys() error

+ type CostProjection struct

+ CalculatedAt time.Time

+ CurrentCost float64

+ PK string

+ Period string

+ ProjectedCost float64

+ Recommendations []string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ TopDrivers []Driver

+ Variance float64

+ func NewCostProjection(period string) *CostProjection

+ func (CostProjection) TableName() string

+ func (c *CostProjection) AddDriver(driver Driver)

+ func (c *CostProjection) CalculateVariance()

+ func (c *CostProjection) GenerateRecommendations()

+ func (c *CostProjection) IsOverBudget(budgetLimit float64) bool

+ func (c *CostProjection) UpdateKeys()

+ type CustomEmoji struct

+ Category string

+ Shortcode string

+ StaticURL string

+ URL string

+ VisibleInPicker bool

+ func (CustomEmoji) TableName() string

+ type DLQMessage struct

+ BusinessImpact string

+ CreatedAt time.Time

+ ErrorMessage string

+ ErrorStack string

+ ErrorType string

+ ExpiresAt int64

+ FailureReason string

+ FirstSeenAt time.Time

+ FunctionName string

+ FunctionVersion string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ ID string

+ IsPermanent bool

+ LastProcessedAt *time.Time

+ LogGroup string

+ LogStream string

+ MaxReprocessAttempts int

+ MessageAttributes map[string]string

+ MessageBody string

+ MessageMetadata map[string]interface{}

+ NextRetryAt *time.Time

+ OriginalMessageID string

+ OriginalRetryCount int

+ PK string

+ Priority string

+ ProcessingCostMicroCents int64

+ QueueName string

+ ReprocessingCostMicroCents int64

+ ReprocessingCount int

+ RequestID string

+ ResolvedAt *time.Time

+ SK string

+ Service string

+ SimilarityHash string

+ SourceQueue string

+ Status string

+ Tags []string

+ UpdatedAt time.Time

+ Version int

+ func NewDependencyErrorDLQ(service, messageID, body, errorMsg string) *DLQMessage

+ func NewProcessingErrorDLQ(service, messageID, body, errorMsg string) *DLQMessage

+ func NewTransientErrorDLQ(service, messageID, body, errorMsg string) *DLQMessage

+ func NewValidationErrorDLQ(service, messageID, body, errorMsg string) *DLQMessage

+ func (DLQMessage) TableName() string

+ func (d *DLQMessage) AddTag(tag string)

+ func (d *DLQMessage) BeforeCreate() error

+ func (d *DLQMessage) BeforeUpdate() error

+ func (d *DLQMessage) CanReprocess() bool

+ func (d *DLQMessage) GetMetadata(key string) (interface{}, bool)

+ func (d *DLQMessage) GetPK() string

+ func (d *DLQMessage) GetSK() string

+ func (d *DLQMessage) GetTotalCost() int64

+ func (d *DLQMessage) MarkAbandoned()

+ func (d *DLQMessage) MarkFailed(errorMsg string)

+ func (d *DLQMessage) MarkForReprocessing()

+ func (d *DLQMessage) MarkResolved()

+ func (d *DLQMessage) SetMetadata(key string, value interface{})

+ func (d *DLQMessage) ShouldAbandon() bool

+ func (d *DLQMessage) UpdateCosts(processingCost, reprocessingCost int64)

+ func (d *DLQMessage) UpdateKeys() error

+ func (d *DLQMessage) Validate() error

+ type DLQMessageBuilder struct

+ func NewDLQMessageBuilder() *DLQMessageBuilder

+ func (DLQMessageBuilder) TableName() string

+ func (b *DLQMessageBuilder) Build() *DLQMessage

+ func (b *DLQMessageBuilder) ForService(service string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) MarkAsPermanent() *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithAttributes(attributes map[string]string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithBusinessImpact(impact string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithContext(functionName, logGroup, logStream, requestID string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithError(errorType, errorMessage, errorStack string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithFailureReason(reason string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithMetadata(metadata map[string]interface{}) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithOriginalMessage(messageID, body string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithPriority(priority string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithQueue(queueName, sourceQueue string) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithRetryInfo(originalRetryCount, maxReprocessAttempts int) *DLQMessageBuilder

+ func (b *DLQMessageBuilder) WithTags(tags ...string) *DLQMessageBuilder

+ type DNSCache struct

+ ExpiresAt int64

+ Hostname string

+ IPs []string

+ PK string

+ ResolvedAt time.Time

+ SK string

+ TTL int

+ func (DNSCache) TableName() string

+ func (d *DNSCache) GetPK() string

+ func (d *DNSCache) GetSK() string

+ func (d *DNSCache) UpdateKeys() error

+ type DeadLetterMessage struct

+ AttemptCount int

+ CreatedAt time.Time

+ ErrorMessage string

+ ErrorType string

+ LastAttemptAt time.Time

+ MessageID string

+ OriginalID string

+ OriginalType string

+ PK string

+ Payload map[string]interface{}

+ SK string

+ TTL int64

+ func (DeadLetterMessage) TableName() string

+ func (d *DeadLetterMessage) GetPK() string

+ func (d *DeadLetterMessage) GetSK() string

+ func (d *DeadLetterMessage) UpdateKeys() error

+ type DeliveryStatus struct

+ ActivityID string

+ Attempts int

+ CreatedAt time.Time

+ DeliveredAt time.Time

+ Error string

+ GSI1PK string

+ GSI1SK string

+ LastAttempt time.Time

+ NextRetry time.Time

+ PK string

+ SK string

+ Status string

+ TTL int64

+ TargetDomain string

+ func (DeliveryStatus) TableName() string

+ func (d *DeliveryStatus) UpdateKeys()

+ type Device struct

+ Active bool

+ AppVersion string

+ CreatedAt time.Time

+ DeviceID string

+ DeviceName string

+ DeviceType string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ LastIPAddress string

+ LastSeenAt time.Time

+ LastUserAgent string

+ Location string

+ PK string

+ Platform string

+ SK string

+ TTL int64

+ TrustLevel string

+ Username string

+ func (Device) TableName() string

+ func (d *Device) IsActive() bool

+ func (d *Device) SetTrustLevel(level string)

+ func (d *Device) UpdateKeys()

+ func (d *Device) UpdateLastSeen(ipAddress, userAgent string)

+ type DimensionStats struct

+ Average float64

+ Count int64

+ Max float64

+ Min float64

+ Sum float64

+ Value string

+ func (DimensionStats) TableName() string

+ type DomainAllow struct

+ CreatedAt time.Time

+ CreatedBy string

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ PK string

+ SK string

+ func (DomainAllow) TableName() string

+ func (d *DomainAllow) GetDomain() string

+ func (d *DomainAllow) GetID() string

+ func (d *DomainAllow) GetPK() string

+ func (d *DomainAllow) GetSK() string

+ func (d *DomainAllow) UpdateKeys() error

+ type Draft struct

+ AuthorID string

+ AutosaveVersion int

+ Content string

+ ContentFormat string

+ ContentType string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI4PK string

+ GSI4SK string

+ ID string

+ LastSavedAt time.Time

+ MetadataJSON string

+ ObjectID *string

+ PK string

+ SK string

+ ScheduledAt *time.Time

+ Slug string

+ Status string

+ Title string

+ UpdatedAt time.Time

+ func (Draft) TableName() string

+ func (d *Draft) GetPK() string

+ func (d *Draft) GetSK() string

+ func (d *Draft) UpdateKeys() error

+ type Driver struct

+ Category string

+ Cost float64

+ Domain string

+ MeasuredAt time.Time

+ PK string

+ PercentOfTotal float64

+ Period string

+ PreviousCost float64

+ Resource string

+ SK string

+ TTL int64

+ Trend string

+ Type string

+ VolumeMetrics map[string]int64

+ func NewDriver(category, resource string) *Driver

+ func (Driver) TableName() string

+ func (c *Driver) CalculateTrend()

+ func (c *Driver) DetermineCostType()

+ func (c *Driver) FormatCostSummary() string

+ func (c *Driver) GetCostPerUnit(metric string) float64

+ func (c *Driver) IsSignificant() bool

+ func (c *Driver) SetVolumeMetric(metric string, value int64)

+ func (c *Driver) UpdateKeys()

+ type DynamoDBCostAggregation struct

+ AverageCostPerOperation float64

+ AverageDuration float64

+ CostPercentiles map[string]float64

+ CreatedAt time.Time

+ ExpiresAt int64

+ OperationType string

+ PK string

+ Period string

+ SK string

+ ServiceBreakdown map[string]*DynamoDBServiceCostStats

+ Table string

+ TableBreakdown map[string]*DynamoDBTableCostStats

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalItemCount int64

+ TotalOperations int64

+ TotalReadCapacityUnits float64

+ TotalReadCostMicroCents int64

+ TotalWriteCapacityUnits float64

+ TotalWriteCostMicroCents int64

+ UpdatedAt time.Time

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (DynamoDBCostAggregation) TableName() string

+ func (act *DynamoDBCostAggregation) BeforeCreate() error

+ func (act *DynamoDBCostAggregation) BeforeUpdate() error

+ func (act *DynamoDBCostAggregation) GetPK() string

+ func (act *DynamoDBCostAggregation) GetSK() string

+ func (act *DynamoDBCostAggregation) UpdateKeys() error

+ func (act *DynamoDBCostAggregation) Validate() error

+ type DynamoDBCostRecord struct

+ ConsistentRead bool

+ CreatedAt time.Time

+ EstimatedCostDollars float64

+ ExpiresAt int64

+ FunctionName string

+ FunctionVersion string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ IndexName string

+ ItemCount int

+ OperationType string

+ PK string

+ Period string

+ Properties map[string]interface{}

+ ReadCapacityUnits float64

+ ReadCostMicroCents int64

+ RequestDuration int64

+ RequestID string

+ SK string

+ ServiceName string

+ Table string

+ Tags map[string]string

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ UpdatedAt time.Time

+ WriteCapacityUnits float64

+ WriteCostMicroCents int64

+ func (DynamoDBCostRecord) TableName() string

+ func (ct *DynamoDBCostRecord) AddTag(key, value string)

+ func (ct *DynamoDBCostRecord) BeforeCreate() error

+ func (ct *DynamoDBCostRecord) BeforeUpdate() error

+ func (ct *DynamoDBCostRecord) GetPK() string

+ func (ct *DynamoDBCostRecord) GetProperty(key string) (interface{}, bool)

+ func (ct *DynamoDBCostRecord) GetSK() string

+ func (ct *DynamoDBCostRecord) SetProperty(key string, value interface{})

+ func (ct *DynamoDBCostRecord) UpdateKeys() error

+ func (ct *DynamoDBCostRecord) Validate() error

+ type DynamoDBCostRecordBuilder struct

+ func NewDynamoDBCostRecordBuilder() *DynamoDBCostRecordBuilder

+ func (DynamoDBCostRecordBuilder) TableName() string

+ func (ctb *DynamoDBCostRecordBuilder) Build() *DynamoDBCostRecord

+ func (ctb *DynamoDBCostRecordBuilder) ForOperation(operationType string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) OnTable(tableName string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithCapacityUnits(readUnits, writeUnits float64) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithConsistentRead(consistent bool) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithCostMicroCents(readCost, writeCost int64) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithDuration(durationMs int64) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithIndex(indexName string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithItemCount(count int) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithPeriod(period string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithRequestID(requestID string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithService(serviceName, functionName string) *DynamoDBCostRecordBuilder

+ func (ctb *DynamoDBCostRecordBuilder) WithTag(key, value string) *DynamoDBCostRecordBuilder

+ type DynamoDBServiceCostStats struct

+ AverageCostPerOp float64

+ DataTransferBytes int64

+ OperationCount int64

+ ServiceName string

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ func (DynamoDBServiceCostStats) TableName() string

+ type DynamoDBTableCostStats struct

+ OperationCount int64

+ ReadCapacityUnits float64

+ Table string

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ UniqueUsers int64

+ WriteCapacityUnits float64

+ func (DynamoDBTableCostStats) TableName() string

+ type EmailDomainBlock struct

+ CreatedAt time.Time

+ CreatedBy string

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ PK string

+ SK string

+ func (EmailDomainBlock) TableName() string

+ func (d *EmailDomainBlock) GetDomain() string

+ func (d *EmailDomainBlock) GetID() string

+ func (d *EmailDomainBlock) GetPK() string

+ func (d *EmailDomainBlock) GetSK() string

+ func (d *EmailDomainBlock) UpdateKeys() error

+ type EmojiModel struct

+ AltText string

+ Category string

+ CreatedAt time.Time

+ Disabled bool

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ ImageContentType string

+ ImageFileSize int64

+ ImageHeight int

+ ImageRemoteURL string

+ ImageStorageVersion int

+ ImageUpdatedAt time.Time

+ ImageWidth int

+ LastUsedAt time.Time

+ PK string

+ PopularityScore float64

+ SK string

+ SearchKeywords []string

+ Shortcode string

+ StaticURL string

+ URL string

+ UpdatedAt time.Time

+ UsageCount int64

+ VisibleInPicker bool

+ func (EmojiModel) TableName() string

+ func (e *EmojiModel) GetPK() string

+ func (e *EmojiModel) GetSK() string

+ func (e *EmojiModel) IncrementUsage()

+ func (e *EmojiModel) UpdateKeys() error

+ type EngagementMetrics struct

+ BoostCount int64

+ Date string

+ EngagementBucket string

+ GSI8PK string

+ GSI8SK string

+ LikeCount int64

+ Likes int64

+ MetricType string

+ PK string

+ Replies int64

+ ReplyCount int64

+ SK string

+ Score float64

+ Shares int64

+ StatusID string

+ TTL int64

+ TargetID string

+ UniqueUsers int64

+ UpdatedAt time.Time

+ Views int64

+ func (e *EngagementMetrics) GetPK() string

+ func (e *EngagementMetrics) GetSK() string

+ func (e *EngagementMetrics) TableName() string

+ func (e *EngagementMetrics) UpdateKeys() error

+ type EnhancedModerationPattern struct

+ Action string

+ Active bool

+ AverageMatchTime float64

+ BlockDuration int64

+ Category string

+ CompilationHash string

+ Compiled bool

+ ConfidenceScore float64

+ CreatedAt time.Time

+ CreatedBy string

+ Description string

+ Effectiveness float64

+ EscalationThreshold int

+ ExpiresAt time.Time

+ FalsePositiveCount int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ LastMatch time.Time

+ LastUsed time.Time

+ LastValidated time.Time

+ MatchCount int64

+ Name string

+ PK string

+ PatternContent string

+ PatternID string

+ PatternType string

+ Priority int

+ SK string

+ Severity string

+ TTL int64

+ Tags []string

+ TestResults map[string]interface{}

+ TruePositiveCount int64

+ Type string

+ UpdatedAt time.Time

+ UpdatedBy string

+ ValidationScore float64

+ Version int

+ WhitelistOverride bool

+ func (EnhancedModerationPattern) TableName() string

+ func (p *EnhancedModerationPattern) CalculateEffectiveness()

+ func (p *EnhancedModerationPattern) GetPK() string

+ func (p *EnhancedModerationPattern) GetSK() string

+ func (p *EnhancedModerationPattern) IsExpired() bool

+ func (p *EnhancedModerationPattern) ShouldEscalate() bool

+ func (p *EnhancedModerationPattern) UpdateKeys() error

+ type ErrorFrequency struct

+ Count int64

+ ErrorCode string

+ Percentage float64

+ func (ErrorFrequency) TableName() string

+ type Export struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ DateRange *ExportDateRange

+ DownloadURL string

+ Error string

+ ExpiresAt *time.Time

+ FileSize int64

+ Format string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ IncludeMedia bool

+ Options map[string]any

+ PK string

+ RecordCount int64

+ S3Key string

+ SK string

+ Status string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ Username string

+ func (e *Export) GetCreatedAt() time.Time

+ func (e *Export) GetStatus() string

+ func (e *Export) TableName() string

+ func (e *Export) UpdateKeys()

+ type ExportCostSummary struct

+ AverageCostPerExport float64

+ AverageExportSize int64

+ CompletedExports int64

+ EndDate time.Time

+ FailedExports int64

+ Period string

+ StartDate time.Time

+ TotalCostMicroCents int64

+ TotalDynamoDBCost int64

+ TotalExports int64

+ TotalFileSize int64

+ TotalLambdaCost int64

+ TotalMediaFiles int64

+ TotalRecordCount int64

+ TotalS3Cost int64

+ TypeBreakdown map[string]*ExportTypeCostStats

+ Username string

+ func (ExportCostSummary) TableName() string

+ type ExportCostTracking struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ DataTransferBytes int64

+ DynamoDBOperations int64

+ DynamoDBReadCost int64

+ DynamoDBReadUnits float64

+ ExportID string

+ FileSize int64

+ Format string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IncludeMedia bool

+ LambdaDurationMs int64

+ LambdaExecutionCost int64

+ MediaFilesIncluded int64

+ MediaSizeBytes int64

+ PK string

+ RecordCount int64

+ S3DataTransferCost int64

+ S3GetRequestCost int64

+ S3GetRequests int64

+ S3PutRequestCost int64

+ S3PutRequests int64

+ S3StorageCost int64

+ SK string

+ StartedAt time.Time

+ Status string

+ TTL int64

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ Type string

+ UpdatedAt time.Time

+ Username string

+ func (e *ExportCostTracking) BeforeCreate() error

+ func (e *ExportCostTracking) BeforeUpdate() error

+ func (e *ExportCostTracking) CalculateTotalCost()

+ func (e *ExportCostTracking) GetTimestamp() time.Time

+ func (e *ExportCostTracking) GetTotalCostDollars() float64

+ func (e *ExportCostTracking) GetTotalCostMicroCents() int64

+ func (e *ExportCostTracking) TableName() string

+ func (e *ExportCostTracking) UpdateKeys()

+ type ExportDateRange struct

+ End time.Time

+ Start time.Time

+ func NewExportDateRangeFromStrings(start, end string) (*ExportDateRange, error)

+ func (ExportDateRange) TableName() string

+ type ExportTypeCostStats struct

+ AverageCostMicroCents int64

+ AverageFileSize int64

+ AverageRecordCount int64

+ Count int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ Type string

+ func (ExportTypeCostStats) TableName() string

+ type FeaturedTag struct

+ CreatedAt time.Time

+ ID string

+ LastStatusAt string

+ Name string

+ PK string

+ SK string

+ StatusesCount int

+ URL string

+ Username string

+ func (FeaturedTag) TableName() string

+ func (f *FeaturedTag) GetPK() string

+ func (f *FeaturedTag) GetSK() string

+ func (f *FeaturedTag) UpdateKeys() error

+ type FederationActivity struct

+ ActivityType string

+ ActorID string

+ CreatedAt time.Time

+ Domain string

+ ErrorMessage string

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ Headers map[string]string

+ ID string

+ InboundSize int64

+ InstanceInfo *InstanceInfo

+ ObjectID string

+ ObjectType string

+ OutboundSize int64

+ PK string

+ Properties map[string]interface{}

+ RemoteIP string

+ ResponseTime float64

+ SK string

+ Success bool

+ Timestamp time.Time

+ UpdatedAt time.Time

+ UserAgent string

+ func (FederationActivity) TableName() string

+ func (fa *FederationActivity) BeforeCreate() error

+ func (fa *FederationActivity) BeforeUpdate() error

+ func (fa *FederationActivity) GetHeader(key string) (string, bool)

+ func (fa *FederationActivity) GetPK() string

+ func (fa *FederationActivity) GetProperty(key string) (interface{}, bool)

+ func (fa *FederationActivity) GetSK() string

+ func (fa *FederationActivity) IsRemote(localDomain string) bool

+ func (fa *FederationActivity) MarkFailed(errorMsg string)

+ func (fa *FederationActivity) MarkSuccess()

+ func (fa *FederationActivity) SetHeader(key, value string)

+ func (fa *FederationActivity) SetProperty(key string, value interface{})

+ func (fa *FederationActivity) UpdateKeys() error

+ func (fa *FederationActivity) Validate() error

+ type FederationActivityBuilder struct

+ func NewFederationActivityBuilder() *FederationActivityBuilder

+ func (FederationActivityBuilder) TableName() string

+ func (fab *FederationActivityBuilder) Build() *FederationActivity

+ func (fab *FederationActivityBuilder) FromDomain(domain string) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithActor(actorID string) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithError(err error) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithInstanceInfo(info *InstanceInfo) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithObject(objectID, objectType string) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithResponseTime(ms float64) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithType(activityType string) *FederationActivityBuilder

+ func (fab *FederationActivityBuilder) WithVolume(inbound, outbound int64) *FederationActivityBuilder

+ type FederationAlert struct

+ Domain string

+ HealthScore float64

+ Level string

+ Message string

+ Timestamp time.Time

+ func (FederationAlert) TableName() string

+ type FederationAnalyticsTimeSeries struct

+ ActivityCount int64

+ AggregationLevel string

+ BandwidthCost float64

+ BurstCapacity float64

+ CircuitBreakerActive bool

+ CompressedData []byte

+ ComputeCost float64

+ ConsecutiveFailures int64

+ CreatedAt time.Time

+ Domain string

+ EgressCost float64

+ EndpointAvailability float64

+ ErrorRate float64

+ FailedActivities int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HealthScore float64

+ InboxDeliveryP50 int64

+ InboxDeliveryP95 int64

+ InboxDeliveryP99 int64

+ IncomingActivitiesPerSec float64

+ InstanceReachability float64

+ LastSuccessfulContact *time.Time

+ MalformedActivities int64

+ MediaDeliveryTime int64

+ OutboxProcessingTime int64

+ OutgoingActivitiesPerSec float64

+ PK string

+ PerActivityCost float64

+ Period string

+ ProcessingBacklog int64

+ QueueDepth int64

+ RateLimitHits int64

+ SK string

+ SampleCount int64

+ SignatureFailures int64

+ SignatureVerificationTime int64

+ StorageCost float64

+ SuccessfulActivities int64

+ TTL int64

+ TimeoutRate float64

+ Timestamp time.Time

+ TotalInboundVolume int64

+ TotalOutboundVolume int64

+ UpdatedAt time.Time

+ ValidationFailures int64

+ WindowEnd time.Time

+ WindowStart time.Time

+ func NewFederationAnalyticsTimeSeries(domain, period string, timestamp time.Time) *FederationAnalyticsTimeSeries

+ func (FederationAnalyticsTimeSeries) TableName() string

+ func (f *FederationAnalyticsTimeSeries) Aggregate(rawMetrics []*FederationAnalyticsTimeSeries)

+ func (f *FederationAnalyticsTimeSeries) CalculateHealthScore()

+ func (f *FederationAnalyticsTimeSeries) IsCritical() bool

+ func (f *FederationAnalyticsTimeSeries) IsDegraded() bool

+ func (f *FederationAnalyticsTimeSeries) IsHealthy() bool

+ func (f *FederationAnalyticsTimeSeries) IsUnhealthy() bool

+ func (f *FederationAnalyticsTimeSeries) ShouldTriggerAlert() (bool, string)

+ func (f *FederationAnalyticsTimeSeries) UpdateKeys()

+ type FederationBudget struct

+ ActivityTypeLimits map[string]int64

+ ActivityTypeUsage map[string]int64

+ AlertSendingEnabled bool

+ AlertThresholdPercent float64

+ BlockOnLimitExceeded bool

+ CombinedLimitMicroCents int64

+ CreatedAt time.Time

+ CurrentCombinedCost int64

+ CurrentInboundCost int64

+ CurrentOutboundCost int64

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ InboundActivityCount int64

+ InboundLimitMicroCents int64

+ IsActive bool

+ LastAlertSentAt *time.Time

+ LastInboundAt *time.Time

+ LastOutboundAt *time.Time

+ OutboundActivityCount int64

+ OutboundLimitMicroCents int64

+ PK string

+ Period string

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ RateLimitOnThreshold bool

+ SK string

+ Status string

+ UpdatedAt time.Time

+ func (FederationBudget) TableName() string

+ func (f *FederationBudget) AddUsage(activityType, direction string, cost int64)

+ func (f *FederationBudget) BeforeCreate() error

+ func (f *FederationBudget) BeforeUpdate() error

+ func (f *FederationBudget) GetActivityTypeUsagePercent(activityType string) float64

+ func (f *FederationBudget) GetCombinedUsagePercent() float64

+ func (f *FederationBudget) GetInboundUsagePercent() float64

+ func (f *FederationBudget) GetOutboundUsagePercent() float64

+ func (f *FederationBudget) GetPK() string

+ func (f *FederationBudget) GetSK() string

+ func (f *FederationBudget) IsOverActivityTypeLimit(activityType string) bool

+ func (f *FederationBudget) IsOverCombinedLimit() bool

+ func (f *FederationBudget) IsOverInboundLimit() bool

+ func (f *FederationBudget) IsOverOutboundLimit() bool

+ func (f *FederationBudget) ResetPeriod(newPeriodStart, newPeriodEnd time.Time)

+ func (f *FederationBudget) ShouldBlock() bool

+ func (f *FederationBudget) ShouldRateLimit() bool

+ func (f *FederationBudget) ShouldSendAlert() bool

+ func (f *FederationBudget) UpdateKeys() error

+ type FederationCost struct

+ AvgResponseTime float64

+ Domain string

+ EgressBytes int64

+ ErrorCount int64

+ ErrorRate float64

+ EstimatedCostUSD float64

+ IngressBytes int64

+ LastUpdated time.Time

+ PK string

+ Period string

+ RequestCount int64

+ SK string

+ func (FederationCost) TableName() string

+ func (f *FederationCost) UpdateKeys()

+ type FederationCostActivity struct

+ ActivityType string

+ ByteSize int64

+ Domain string

+ ErrorMessage string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ PK string

+ ResponseTime int64

+ SK string

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ Type string

+ func (FederationCostActivity) TableName() string

+ func (f *FederationCostActivity) GetPK() string

+ func (f *FederationCostActivity) GetSK() string

+ func (f *FederationCostActivity) UpdateKeys() error

+ type FederationCostTracking struct

+ ActivityID string

+ ActivityType string

+ AverageCostUSD float64

+ BillingPeriod string

+ BytesSent int64

+ CompressedSize int64

+ CompressionRatio float64

+ CreatedAt time.Time

+ DNSLookupCost int64

+ DNSLookupCount int64

+ DataTransferBytes int64

+ DataTransferCost int64

+ DeliveryAttempts int

+ DestinationServer string

+ Direction string

+ Domain string

+ DynamoDBReadCost int64

+ DynamoDBReadCount int64

+ DynamoDBReadUnits float64

+ DynamoDBWriteCost int64

+ DynamoDBWriteCount int64

+ DynamoDBWriteUnits float64

+ EgressBytes int64

+ ErrorCount int

+ ErrorMessage string

+ ErrorRate float64

+ FinalRetrySuccess bool

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HTTPRequestCost int64

+ HTTPRequestCount int64

+ IngressBytes int64

+ InstanceDomain string

+ LambdaDurationMs int64

+ LambdaExecutionCost int64

+ LambdaMemoryMB int64

+ LastUpdated time.Time

+ OperationType string

+ PK string

+ PayloadSize int64

+ ProcessingTimeMs int64

+ QueueWaitTimeMs int64

+ RequestCount int

+ ResponseTimeMs int64

+ RetryAttempts int

+ RetryCost int64

+ RetryCount int

+ RetryDelaySeconds []int64

+ RetryErrorMessages []string

+ RouteAttempts map[string]int

+ RouteBreakdown map[string]int64

+ RouteErrors map[string]int

+ RouteID string

+ RouteLatency map[string]int64

+ RouteSuccessRates map[string]float64

+ SK string

+ SQSMessageCost int64

+ SQSMessageCount int64

+ SignatureVerificationCost int64

+ SignatureVerificationMs int64

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ UpdatedAt time.Time

+ WebFingerCost int64

+ WebFingerCount int64

+ func (FederationCostTracking) TableName() string

+ func (f *FederationCostTracking) AddRetryDelay(delaySeconds int64)

+ func (f *FederationCostTracking) AddRouteDeliveryAttempt(routeID string, bytes int64, latencyMs int64, success bool, errorMsg string)

+ func (f *FederationCostTracking) BeforeCreate() error

+ func (f *FederationCostTracking) BeforeUpdate() error

+ func (f *FederationCostTracking) CalculateTotalCost()

+ func (f *FederationCostTracking) GetAverageRouteLatency() int64

+ func (f *FederationCostTracking) GetMostExpensiveRoute() (string, int64)

+ func (f *FederationCostTracking) GetPK() string

+ func (f *FederationCostTracking) GetRetryEfficiency() map[string]interface{}

+ func (f *FederationCostTracking) GetSK() string

+ func (f *FederationCostTracking) GetTotalCostDollars() float64

+ func (f *FederationCostTracking) GetTotalRouteErrors() int

+ func (f *FederationCostTracking) UpdateKeys() error

+ type FederationEdge struct

+ ConnectionType string

+ ErrorCount int64

+ GSI2PK string

+ GSI2SK string

+ LastActivity time.Time

+ PK string

+ SK string

+ SharedUsers int64

+ SourceDomain string

+ Strength float64

+ SuccessRate float64

+ TargetDomain string

+ VolumeIn int64

+ VolumeOut int64

+ func (FederationEdge) TableName() string

+ func (f *FederationEdge) UpdateKeys()

+ type FederationHealthReport struct

+ Domain string

+ ErrorRate float64

+ FederationDelay float64

+ Issues []string

+ LastChecked time.Time

+ QueueDepth int

+ Recommendations []string

+ ResponseTime float64

+ Status string

+ func (FederationHealthReport) TableName() string

+ type FederationInstance struct

+ ActiveUsers int

+ Domain string

+ FirstSeen time.Time

+ GSI1PK string

+ GSI1SK string

+ LastSeen time.Time

+ PK string

+ PublicKey string

+ SK string

+ SharedInbox string

+ Software string

+ TotalMessages int64

+ TrustScore float64

+ Version string

+ func (FederationInstance) TableName() string

+ func (f *FederationInstance) UpdateKeys()

+ type FederationInstanceConfigTracking struct

+ AllowFollowers bool

+ AllowMentions bool

+ AllowPublicActivities bool

+ AutoAcceptThreshold float64

+ CacheTTLSeconds int

+ CompressionThreshold int

+ ConnectionPoolSize int

+ ContactEmail string

+ Created time.Time

+ CustomBudgetUSD *float64

+ Domain string

+ EnableBudgetEnforcement bool

+ EnableCaching bool

+ EnableRateLimiting bool

+ EnableSignatureValidation bool

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ LastModified time.Time

+ MaxCacheSize int

+ MaxConcurrentRequests int

+ Notes string

+ PK string

+ RateLimitOverride *int

+ ReputationMultiplier float64

+ RequestTimeoutSeconds int

+ RequireVouch bool

+ RetryPolicy *RetryPolicy

+ SK string

+ Tier FederationTier

+ TrustScore float64

+ Type string

+ func (FederationInstanceConfigTracking) TableName() string

+ func (f *FederationInstanceConfigTracking) BeforeCreate() error

+ func (f *FederationInstanceConfigTracking) BeforeUpdate() error

+ func (f *FederationInstanceConfigTracking) GetBudgetLimit() float64

+ func (f *FederationInstanceConfigTracking) GetRateLimit() int

+ func (f *FederationInstanceConfigTracking) UpdateKeys()

+ type FederationInstanceHealthTracking struct

+ AverageResponseTime int64

+ BackoffUntil *int64

+ ConsecutiveFails int

+ CreatedAt time.Time

+ Domain string

+ FailedRequests int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HealthScore float64

+ IsHealthy bool

+ LastHealthCheck time.Time

+ PK string

+ RateLimitRemaining int

+ RateLimitReset int64

+ ResponseTimeP95 int64

+ SK string

+ SuccessRate float64

+ TTL int64

+ TotalRequests int64

+ UpdatedAt time.Time

+ func (f *FederationInstanceHealthTracking) BeforeCreate() error

+ func (f *FederationInstanceHealthTracking) BeforeUpdate() error

+ func (f *FederationInstanceHealthTracking) CalculateHealthScore()

+ func (f *FederationInstanceHealthTracking) TableName() string

+ func (f *FederationInstanceHealthTracking) UpdateKeys()

+ type FederationInstanceRegistry struct

+ AvgResponseTime int64

+ CurrentUsage int64

+ Domain string

+ ErrorRate float64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ InboxURL string

+ LastSeen time.Time

+ MaxMessageSize int64

+ MonthlyQuota int64

+ PK string

+ PublicKeyPEM string

+ RateLimits map[string]interface{}

+ RegisteredAt time.Time

+ SK string

+ SharedInboxURL string

+ Status string

+ SuccessRate float64

+ SupportedTypes []string

+ TTL int64

+ TierLevel string

+ func (FederationInstanceRegistry) TableName() string

+ func (f *FederationInstanceRegistry) GetPK() string

+ func (f *FederationInstanceRegistry) GetSK() string

+ func (f *FederationInstanceRegistry) ToInstance() *types.Instance

+ func (f *FederationInstanceRegistry) UpdateKeys() error

+ type FederationInstanceRegistryHealthHistory struct

+ ErrorMessage string

+ ErrorRate float64

+ InboxBacklog int

+ PK string

+ ProcessingDelay int64

+ Reachable bool

+ ResponseTime int64

+ SK string

+ StatusCode int

+ TTL int64

+ Timestamp time.Time

+ func (FederationInstanceRegistryHealthHistory) TableName() string

+ func (h *FederationInstanceRegistryHealthHistory) GetPK() string

+ func (h *FederationInstanceRegistryHealthHistory) GetSK() string

+ func (h *FederationInstanceRegistryHealthHistory) UpdateKeys() error

+ type FederationIssue struct

+ Description string

+ Domain string

+ IssueType string

+ PK string

+ Resolved bool

+ SK string

+ Severity string

+ TTL int64

+ Timestamp time.Time

+ func (FederationIssue) TableName() string

+ func (f *FederationIssue) UpdateKeys()

+ type FederationNode struct

+ ActiveConnections int64

+ ActiveUsers int64

+ ActivityVolume int64

+ ConnectionType string

+ Description string

+ DisplayName string

+ Domain string

+ ErrorRate float64

+ FirstSeen time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI3PK string

+ GSI3SK string

+ Health string

+ LastSeen time.Time

+ Metadata map[string]any

+ PK string

+ ResponseTime float64

+ SK string

+ Software string

+ StatusCount int64

+ TotalConnections int64

+ UserCount int64

+ Version string

+ func (FederationNode) TableName() string

+ func (f *FederationNode) UpdateKeys()

+ type FederationRelationship struct

+ ArchiveLocation string

+ AvgResponseTime float64

+ CompressedMetrics string

+ CreatedAt time.Time

+ CurrentRate float64

+ FailureCount15m int64

+ FirstSeen time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HistoricalBaseline float64

+ ID string

+ IsCompressed bool

+ LastActivity time.Time

+ LastCompressedAttempts int64

+ LastCompressionTime time.Time

+ PK string

+ RelationshipType string

+ SK string

+ State RelationshipState

+ StateChangedAt time.Time

+ SuccessCount15m int64

+ SuccessRate float64

+ TTL int64

+ TargetInstance string

+ TargetUserID string

+ TotalAttempts int64

+ TotalFailures int64

+ TotalSuccesses int64

+ UpdatedAt time.Time

+ UserID string

+ WarmupUntil *time.Time

+ WindowStart15m time.Time

+ func (FederationRelationship) TableName() string

+ func (fr *FederationRelationship) GetTrafficRate() float64

+ func (fr *FederationRelationship) IsInWarmup() bool

+ func (fr *FederationRelationship) ShouldTransitionState() (RelationshipState, bool)

+ func (fr *FederationRelationship) TransitionToState(newState RelationshipState)

+ func (fr *FederationRelationship) UpdateKeys()

+ func (fr *FederationRelationship) UpdateSuccessRate(success bool, responseTime float64)

+ type FederationRelationshipAggregate struct

+ ActiveRelationships int64

+ AvgResponseTime float64

+ CreatedAt time.Time

+ DormantRelationships int64

+ GSI1PK string

+ GSI1SK string

+ IdleRelationships int64

+ InstanceDomain string

+ OverallSuccessRate float64

+ P95ResponseTime float64

+ PK string

+ Period string

+ ReactivationCount int64

+ SK string

+ StateTransitions map[string]int64

+ TTL int64

+ Timestamp time.Time

+ TotalFailures15m int64

+ TotalRelationships int64

+ TotalSuccesses15m int64

+ func (FederationRelationshipAggregate) TableName() string

+ func (fra *FederationRelationshipAggregate) UpdateKeys()

+ type FederationRelationshipIndex struct

+ ArchiveLocation string

+ CreatedAt time.Time

+ LastActivity time.Time

+ PK string

+ RelationshipID string

+ SK string

+ State RelationshipState

+ TTL int64

+ TargetInstance string

+ UserID string

+ func (FederationRelationshipIndex) TableName() string

+ func (fri *FederationRelationshipIndex) UpdateKeys()

+ type FederationRouteAggregation struct

+ AvgCostPerDelivery int64

+ AvgHealthScore float64

+ AvgLatencyMs int64

+ CircuitBreakerTrips int64

+ CostEfficiencyRank int

+ CostEfficiencyScore float64

+ CostTrend string

+ CreatedAt time.Time

+ DestinationDomain string

+ DowntimeMinutes int64

+ GSI1PK string

+ GSI1SK string

+ HealthScoreStdDev float64

+ LatencyStdDev float64

+ MTBF float64

+ MTTR float64

+ MaxConsecutiveFailures int64

+ MaxHealthScore float64

+ MedianLatencyMs int64

+ MinHealthScore float64

+ OverallRank int

+ OverallSuccessRate float64

+ P95LatencyMs int64

+ PK string

+ PercentileScore float64

+ PerformanceRank int

+ PerformanceTrend string

+ Period string

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ ReliabilityRank int

+ ReliabilityTrend string

+ RouteID string

+ SK string

+ TTL int64

+ TopErrors []ErrorFrequency

+ TotalAttempts int64

+ TotalCostMicroCents int64

+ TotalSuccesses int64

+ TrendConfidence float64

+ UpdatedAt time.Time

+ UptimePercentage float64

+ func (FederationRouteAggregation) TableName() string

+ func (f *FederationRouteAggregation) BeforeCreate() error

+ func (f *FederationRouteAggregation) BeforeUpdate() error

+ func (f *FederationRouteAggregation) GetRouteComparisonMetrics() map[string]interface{}

+ func (f *FederationRouteAggregation) UpdateKeys()

+ type FederationRouteMetrics struct

+ ASN string

+ AvgCostPerDelivery int64

+ AvgLatencyMs int64

+ AvgPayloadSize int64

+ AvgRetriesPerFail float64

+ AvgRetryDelayMs int64

+ CDNProvider string

+ CircuitBreakerState string

+ ConsecutiveFailures int64

+ CostEfficiencyScore float64

+ CreatedAt time.Time

+ CurrentWeight float64

+ DataCenter string

+ DataTransferBytes int64

+ DestinationDomain string

+ ErrorBreakdown map[string]int64

+ FailedAttempts int64

+ FirstUsed time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GeographicZone string

+ HealthHistory []float64

+ HealthScore float64

+ HealthTrend string

+ IPAddress string

+ LastErrorCode string

+ LastErrorMessage string

+ LastErrorTime *time.Time

+ LastHealthCheck time.Time

+ LastSuccess time.Time

+ LastUsed time.Time

+ LastWeightChange *time.Time

+ LoadBalancingScore float64

+ MaxConsecutiveFails int64

+ MaxLatencyMs int64

+ MedianLatencyMs int64

+ MinLatencyMs int64

+ NetworkPath string

+ NextRetryTime *time.Time

+ OptimalWeight float64

+ P95LatencyMs int64

+ P99LatencyMs int64

+ PK string

+ PerformanceScore float64

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ PeriodType string

+ Port int

+ Protocol string

+ RecoveryTime *time.Time

+ ReliabilityScore float64

+ RetryBackoffFactor float64

+ RetrySuccessRate float64

+ RouteID string

+ RoutePriority int

+ RouteType string

+ SK string

+ ServerEndpoint string

+ StabilityScore float64

+ StateChangeTime *time.Time

+ SuccessRate float64

+ SuccessfulAttempts int64

+ TTL int64

+ TimeoutCount int64

+ TimeoutRate float64

+ TotalAttempts int64

+ TotalCostMicroCents int64

+ TotalRetries int64

+ UpdatedAt time.Time

+ WeightAdjustments int

+ func (FederationRouteMetrics) TableName() string

+ func (f *FederationRouteMetrics) AddDeliveryAttempt(success bool, latencyMs int64, errorCode string, errorMsg string, ...)

+ func (f *FederationRouteMetrics) AddRetryAttempt(delayMs int64)

+ func (f *FederationRouteMetrics) BeforeCreate() error

+ func (f *FederationRouteMetrics) BeforeUpdate() error

+ func (f *FederationRouteMetrics) GetOptimizationRecommendations() []RouteRecommendation

+ func (f *FederationRouteMetrics) GetRouteSummary() map[string]interface{}

+ func (f *FederationRouteMetrics) IsHealthy() bool

+ func (f *FederationRouteMetrics) UpdateKeys()

+ type FederationSeverance struct

+ Acknowledged bool

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ PK string

+ Reason string

+ SK string

+ SeveredAt time.Time

+ Type string

+ UserID string

+ func (FederationSeverance) TableName() string

+ func (f *FederationSeverance) UpdateKeys()

+ type FederationStats struct

+ ActiveInstances int

+ Date string

+ PK string

+ SK string

+ TTL int64

+ TotalMessages int64

+ TotalUsers int

+ UpdatedAt time.Time

+ func NewFederationStats(date string) *FederationStats

+ func (FederationStats) TableName() string

+ func (f *FederationStats) IncrementStats(activeInstances int, messages int64, users int)

+ func (f *FederationStats) UpdateKeys()

+ type FederationTier string

+ const FederationTierBasic

+ const FederationTierBlocked

+ const FederationTierEnterprise

+ const FederationTierFree

+ const FederationTierPremium

+ type FederationTimeSeries struct

+ ActivityVolume int64

+ Domain string

+ ErrorCount int64

+ GSI1PK string

+ GSI1SK string

+ Metrics map[string]interface{}

+ PK string

+ Period string

+ SK string

+ SuccessCount int64

+ TTL int64

+ Timestamp time.Time

+ func (FederationTimeSeries) TableName() string

+ func (f *FederationTimeSeries) UpdateKeys()

+ type FieldVerification struct

+ ExpiresAt time.Time

+ FieldName string

+ FieldValue string

+ PK string

+ SK string

+ Username string

+ VerifiedAt time.Time

+ VerifiedBy string

+ func (FieldVerification) TableName() string

+ func (f *FieldVerification) BeforeCreate() error

+ func (f *FieldVerification) IsExpired() bool

+ func (f *FieldVerification) UpdateKeys()

+ type Filter struct

+ CaseSensitive bool

+ Context []string

+ CreatedAt time.Time

+ ExpiresAt *time.Time

+ FilterAction string

+ ID string

+ MatchMode string

+ PK string

+ SK string

+ Severity string

+ Title string

+ UpdatedAt time.Time

+ Username string

+ func (Filter) TableName() string

+ func (f *Filter) BeforeCreate() error

+ func (f *Filter) BeforeSave() error

+ func (f *Filter) GetPK() string

+ func (f *Filter) GetSK() string

+ func (f *Filter) UpdateKeys() error

+ type FilterKeyword struct

+ ContextTypes []string

+ CreatedAt time.Time

+ FilterID string

+ ID string

+ IsRegex bool

+ Keyword string

+ MatchWeight float64

+ PK string

+ SK string

+ WholeWord bool

+ func (FilterKeyword) TableName() string

+ func (fk *FilterKeyword) BeforeCreate() error

+ func (fk *FilterKeyword) BeforeSave() error

+ func (fk *FilterKeyword) GetPK() string

+ func (fk *FilterKeyword) GetSK() string

+ func (fk *FilterKeyword) UpdateKeys() error

+ type FilterStatus struct

+ CreatedAt time.Time

+ FilterID string

+ ID string

+ PK string

+ SK string

+ StatusID string

+ func (FilterStatus) TableName() string

+ func (fs *FilterStatus) BeforeCreate() error

+ func (fs *FilterStatus) BeforeSave() error

+ func (fs *FilterStatus) GetPK() string

+ func (fs *FilterStatus) GetSK() string

+ func (fs *FilterStatus) UpdateKeys() error

+ type Flag struct

+ Actor string

+ Content string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ Object []string

+ PK string

+ Published time.Time

+ ReviewNote string

+ ReviewedAt *time.Time

+ ReviewedBy string

+ SK string

+ Status string

+ func (Flag) TableName() string

+ func (f *Flag) BeforeCreate() error

+ func (f *Flag) BeforeSave() error

+ func (f *Flag) UpdateKeys()

+ type Follow struct

+ AcceptedAt *time.Time

+ ActivityID string

+ CreatedAt time.Time

+ FollowedUsername string

+ FollowerUsername string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ PK string

+ SK string

+ State string

+ UpdatedAt time.Time

+ func NewFollow(followerUsername, followedUsername, activityID string) *Follow

+ func (Follow) TableName() string

+ func (f *Follow) Accept()

+ func (f *Follow) Reject()

+ type FollowRequestState struct

+ CreatedAt time.Time

+ PK string

+ RequesterID string

+ SK string

+ State string

+ TargetID string

+ UpdatedAt time.Time

+ func (FollowRequestState) TableName() string

+ func (f *FollowRequestState) BeforeCreate() error

+ func (f *FollowRequestState) UpdateKeys()

+ type GeographicMetric struct

+ AverageLatencyMs int64

+ BandwidthUsageMbps float64

+ CacheHitRate float64

+ PreferredQuality string

+ Region string

+ ViewerCount int64

+ ViewerPercentage float64

+ func (GeographicMetric) TableName() string

+ type GlobalMetricsWindow struct

+ ActiveRoutes int64

+ BottomRoutes string

+ GSI1PK string

+ GSI1SK string

+ HourlyVolume string

+ PK string

+ SK string

+ TTL int64

+ TopRoutes string

+ TotalBytes int64

+ TotalCost float64

+ TotalMessages int64

+ UniqueInstances int64

+ WindowSize int64

+ WindowStart time.Time

+ func (GlobalMetricsWindow) TableName() string

+ func (g *GlobalMetricsWindow) GetPK() string

+ func (g *GlobalMetricsWindow) GetSK() string

+ func (g *GlobalMetricsWindow) UpdateKeys() error

+ type Hashtag struct

+ CreatedAt time.Time

+ FirstSeen time.Time

+ GSI3PK string

+ GSI3SK string

+ LastUsed time.Time

+ Name string

+ PK string

+ SK string

+ URL string

+ UpdatedAt time.Time

+ UsageCount int64

+ func (Hashtag) TableName() string

+ func (h *Hashtag) GetPK() string

+ func (h *Hashtag) GetSK() string

+ func (h *Hashtag) UpdateKeys() error

+ type HashtagFollow struct

+ CreatedAt time.Time

+ Hashtag string

+ Muted bool

+ NotificationsEnabled bool

+ PK string

+ SK string

+ UpdatedAt time.Time

+ UserID string

+ func (HashtagFollow) TableName() string

+ func (h *HashtagFollow) GetPK() string

+ func (h *HashtagFollow) GetSK() string

+ func (h *HashtagFollow) UpdateKeys() error

+ func (h *HashtagFollow) UpdateKeysWithParams(userID, hashtag string)

+ type HashtagHistoryEntry struct

+ Date time.Time

+ UsageCount int64

+ UserCount int64

+ func NewHashtagHistoryEntry(date time.Time, usageCount, userCount int64) HashtagHistoryEntry

+ func (HashtagHistoryEntry) TableName() string

+ func (h HashtagHistoryEntry) CompareWith(other HashtagHistoryEntry) float64

+ func (h HashtagHistoryEntry) DaysSince() int

+ func (h HashtagHistoryEntry) GetEngagement() float64

+ func (h HashtagHistoryEntry) IsHighActivity(threshold int64) bool

+ type HashtagMute struct

+ CreatedAt time.Time

+ Hashtag string

+ PK string

+ SK string

+ TTL int64

+ Username string

+ func (HashtagMute) TableName() string

+ func (h *HashtagMute) UpdateKeys()

+ type HashtagNotificationSettings struct

+ CreatedAt time.Time

+ Filters []NotificationFilter

+ Hashtag string

+ Level string

+ Muted bool

+ MutedUntil *time.Time

+ PK string

+ SK string

+ UpdatedAt time.Time

+ UserID string

+ func (HashtagNotificationSettings) TableName() string

+ func (h *HashtagNotificationSettings) GetPK() string

+ func (h *HashtagNotificationSettings) GetSK() string

+ func (h *HashtagNotificationSettings) UpdateKeys() error

+ func (h *HashtagNotificationSettings) UpdateKeysWithParams(userID, hashtag string)

+ type HashtagSearchCache struct

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ HitCount int64

+ LastAccessed time.Time

+ NextCursor string

+ PK string

+ Parameters map[string]interface{}

+ Query string

+ Results []string

+ SK string

+ TTL int64

+ TotalResults int

+ func (HashtagSearchCache) TableName() string

+ func (hsc *HashtagSearchCache) UpdateKeys()

+ type HashtagSearchResult struct

+ Following *bool

+ History []*TrendingHashtag

+ Name string

+ URL string

+ func NewHashtagSearchResult(name, url string) *HashtagSearchResult

+ func (HashtagSearchResult) TableName() string

+ func (h *HashtagSearchResult) AddHistory(trend *TrendingHashtag)

+ func (h *HashtagSearchResult) GetLatestUsage() int64

+ func (h *HashtagSearchResult) GetTotalUsage() int64

+ func (h *HashtagSearchResult) HasRecentActivity() bool

+ func (h *HashtagSearchResult) IsFollowing() bool

+ func (h *HashtagSearchResult) SetFollowing(following bool)

+ type HashtagStats struct

+ FirstSeen time.Time

+ History []HashtagHistoryEntry

+ LastUsed time.Time

+ Name string

+ PK string

+ SK string

+ TotalAccounts int64

+ TotalUses int64

+ TrendingScore float64

+ UniqueUsers int64

+ UsageCount int64

+ func NewHashtagStats(name string) *HashtagStats

+ func (HashtagStats) TableName() string

+ func (h *HashtagStats) AddHistoryEntry(date time.Time, usageCount, userCount int64)

+ func (h *HashtagStats) AddUniqueUser()

+ func (h *HashtagStats) GetAverageUsage() float64

+ func (h *HashtagStats) GetGrowthRate() float64

+ func (h *HashtagStats) IncrementUsage()

+ func (h *HashtagStats) IsActive() bool

+ func (h *HashtagStats) IsTrending(threshold float64) bool

+ func (h *HashtagStats) UpdateKeys()

+ func (h *HashtagStats) UpdateTrendingScore()

+ type HashtagStatusIndex struct

+ AuthorHandle string

+ AuthorID string

+ Content string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HashtagName string

+ Language string

+ MediaCount int

+ PK string

+ Published time.Time

+ SK string

+ StatusID string

+ StatusURL string

+ TTL int64

+ Visibility string

+ func (HashtagStatusIndex) TableName() string

+ func (hsi *HashtagStatusIndex) GetPK() string

+ func (hsi *HashtagStatusIndex) GetSK() string

+ func (hsi *HashtagStatusIndex) UpdateKeys() error

+ type HashtagTrend struct

+ FirstSeen time.Time

+ GSI8PK string

+ GSI8SK string

+ LastUsed time.Time

+ Name string

+ PK string

+ SK string

+ TTL int64

+ TrendScore float64

+ URL string

+ UniqueUsers int64

+ UpdatedAt time.Time

+ UsageCount int64

+ func (HashtagTrend) TableName() string

+ func (h *HashtagTrend) GetPK() string

+ func (h *HashtagTrend) GetSK() string

+ func (h *HashtagTrend) UpdateKeys() error

+ type HashtagTrendingData struct

+ ComponentScores map[string]float64

+ CreatedAt time.Time

+ DiversityScore float64

+ EngagementRate float64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ Growth float64

+ HashtagName string

+ MomentumScore float64

+ PK string

+ Period time.Time

+ SK string

+ TTL int64

+ TimeWindow string

+ TrendScore float64

+ TrustScore float64

+ URL string

+ UniqueUsers int64

+ UpdatedAt time.Time

+ UsageCount int64

+ Velocity float64

+ func (HashtagTrendingData) TableName() string

+ func (htd *HashtagTrendingData) UpdateKeys()

+ type HashtagUsage struct

+ AuthorID string

+ CreatedAt time.Time

+ PK string

+ SK string

+ StatusID string

+ TTL int64

+ UsedAt time.Time

+ Visibility string

+ func (HashtagUsage) TableName() string

+ func (hu *HashtagUsage) GetPK() string

+ func (hu *HashtagUsage) GetSK() string

+ func (hu *HashtagUsage) UpdateKeys() error

+ func (hu *HashtagUsage) UpdateKeysWithHashtag(hashtag string)

+ type HealthCheckResult struct

+ CheckTime time.Time

+ Component string

+ ComponentType string

+ Error string

+ GSI1PK string

+ GSI1SK string

+ LatencyMs int64

+ Metadata map[string]interface{}

+ PK string

+ RequestID string

+ SK string

+ Status string

+ TTL int64

+ func NewHealthCheckResult(componentType, component, status, requestID string, checkTime time.Time, ...) *HealthCheckResult

+ func (HealthCheckResult) TableName() string

+ func (h *HealthCheckResult) UpdateKeys()

+ type HealthCheckSummaryResult struct

+ AvgLatencyMs float64

+ CriticalChecks int

+ Date string

+ GSI1PK string

+ GSI1SK string

+ HealthyChecks int

+ Hour int

+ LastUpdated time.Time

+ MaxLatencyMs int64

+ MinLatencyMs int64

+ PK string

+ SK string

+ TTL int64

+ TotalChecks int

+ UnknownChecks int

+ WarningChecks int

+ func NewHealthCheckSummaryResult(date string, hour int) *HealthCheckSummaryResult

+ func (HealthCheckSummaryResult) TableName() string

+ func (h *HealthCheckSummaryResult) AddCheckResult(status string, latencyMs int64)

+ func (h *HealthCheckSummaryResult) UpdateKeys()

+ type Import struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Error string

+ ErrorCount int

+ Errors []string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Mode string

+ PK string

+ Progress int

+ S3Key string

+ SK string

+ SkipCount int

+ Status string

+ SuccessCount int

+ TTL int64

+ Total int

+ Type string

+ UpdatedAt time.Time

+ Username string

+ func (i *Import) GetCreatedAt() time.Time

+ func (i *Import) GetStatus() string

+ func (i *Import) TableName() string

+ func (i *Import) UpdateKeys()

+ type ImportBudget struct

+ AlertSendingEnabled bool

+ AlertThresholdPercent float64

+ CombinedLimitMicroCents int64

+ CreatedAt time.Time

+ CurrentCombinedCost int64

+ CurrentExportCost int64

+ CurrentImportCost int64

+ ExportCount int64

+ ExportLimitMicroCents int64

+ GSI1PK string

+ GSI1SK string

+ ImportCount int64

+ ImportLimitMicroCents int64

+ IsActive bool

+ LastAlertSent *time.Time

+ LastExportAt *time.Time

+ LastImportAt *time.Time

+ LastResetAt *time.Time

+ NextResetAt time.Time

+ PK string

+ Period string

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ SK string

+ TTL int64

+ UpdatedAt time.Time

+ Username string

+ func (ImportBudget) TableName() string

+ func (b *ImportBudget) BeforeCreate() error

+ func (b *ImportBudget) BeforeUpdate() error

+ func (b *ImportBudget) GetCombinedUsagePercent() float64

+ func (b *ImportBudget) GetExportUsagePercent() float64

+ func (b *ImportBudget) GetImportUsagePercent() float64

+ func (b *ImportBudget) GetRemainingCombinedBudget() int64

+ func (b *ImportBudget) GetRemainingExportBudget() int64

+ func (b *ImportBudget) GetRemainingImportBudget() int64

+ func (b *ImportBudget) IsCombinedOverLimit(additionalImportCost, additionalExportCost int64) bool

+ func (b *ImportBudget) IsExportOverLimit(additionalCost int64) bool

+ func (b *ImportBudget) IsImportOverLimit(additionalCost int64) bool

+ func (b *ImportBudget) NeedsReset() bool

+ func (b *ImportBudget) Reset()

+ func (b *ImportBudget) ShouldSendAlert() bool

+ func (b *ImportBudget) UpdateKeys()

+ type ImportCostSummary struct

+ AverageCostPerImport float64

+ AverageCostPerRecord float64

+ CompletedImports int64

+ EndDate time.Time

+ FailedImports int64

+ OverallSuccessRate float64

+ Period string

+ StartDate time.Time

+ TotalCostMicroCents int64

+ TotalDynamoDBCost int64

+ TotalImports int64

+ TotalLambdaCost int64

+ TotalNetworkCost int64

+ TotalRecordsFailed int64

+ TotalRecordsProcessed int64

+ TotalRecordsSucceeded int64

+ TotalS3Cost int64

+ TypeBreakdown map[string]*ImportTypeCostStats

+ Username string

+ func (ImportCostSummary) TableName() string

+ type ImportCostTracking struct

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ DNSLookups int64

+ DataTransferBytes int64

+ DynamoDBOperations int64

+ DynamoDBReadCost int64

+ DynamoDBReadUnits float64

+ DynamoDBWriteCost int64

+ DynamoDBWriteUnits float64

+ ErrorCount int64

+ ExternalAPICallCost int64

+ ExternalAPICalls int64

+ FileSize int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HTTPRequests int64

+ ImportID string

+ LambdaDurationMs int64

+ LambdaExecutionCost int64

+ Mode string

+ NetworkBytes int64

+ PK string

+ ProcessedCount int64

+ RecordCount int64

+ S3DataTransferCost int64

+ S3GetRequestCost int64

+ S3GetRequests int64

+ S3StorageCost int64

+ SK string

+ SkipCount int64

+ StartedAt time.Time

+ Status string

+ SuccessCount int64

+ TTL int64

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ Type string

+ UpdatedAt time.Time

+ Username string

+ func (i *ImportCostTracking) BeforeCreate() error

+ func (i *ImportCostTracking) BeforeUpdate() error

+ func (i *ImportCostTracking) CalculateTotalCost()

+ func (i *ImportCostTracking) GetSuccessRate() float64

+ func (i *ImportCostTracking) GetTimestamp() time.Time

+ func (i *ImportCostTracking) GetTotalCostDollars() float64

+ func (i *ImportCostTracking) GetTotalCostMicroCents() int64

+ func (i *ImportCostTracking) TableName() string

+ func (i *ImportCostTracking) UpdateKeys()

+ type ImportTypeCostStats struct

+ AverageCostMicroCents int64

+ Count int64

+ FailedRecords int64

+ SuccessRate float64

+ SuccessfulRecords int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalRecords int64

+ Type string

+ func (ImportTypeCostStats) TableName() string

+ type InboxItem struct

+ Activity *activitypub.Activity

+ ActivityID string

+ ActorID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ Timestamp time.Time

+ func (InboxItem) TableName() string

+ func (i *InboxItem) UpdateKeys()

+ type InstanceCluster struct

+ CenterNode string

+ ClusterID string

+ Cohesion float64

+ Description string

+ GSI1PK string

+ GSI1SK string

+ Instances []string

+ Name string

+ PK string

+ SK string

+ Size int

+ UpdatedAt time.Time

+ func (InstanceCluster) TableName() string

+ func (i *InstanceCluster) UpdateKeys()

+ type InstanceConfig struct

+ ExtendedDescription string

+ PK string

+ RulesJSON string

+ SK string

+ UpdatedAt time.Time

+ func NewExtendedDescriptionConfig(description string) *InstanceConfig

+ func NewInstanceRulesConfig(rulesJSON string) *InstanceConfig

+ func (InstanceConfig) TableName() string

+ func (c *InstanceConfig) GetPK() string

+ func (c *InstanceConfig) GetSK() string

+ func (c *InstanceConfig) UpdateKeys() error

+ type InstanceConnection struct

+ ConnectionType string

+ Direction string

+ Domain string

+ GSI2PK string

+ GSI2SK string

+ LastActivity time.Time

+ PK string

+ SK string

+ Success bool

+ TargetDomain string

+ VolumeIn int64

+ VolumeOut int64

+ func (InstanceConnection) TableName() string

+ func (i *InstanceConnection) UpdateKeys()

+ type InstanceDomainBlock struct

+ CreatedAt time.Time

+ CreatedBy string

+ CreatedByID string

+ Domain string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Obfuscate bool

+ PK string

+ PrivateComment string

+ PublicComment string

+ RejectMedia bool

+ RejectReports bool

+ SK string

+ Severity string

+ Type string

+ UpdatedAt time.Time

+ func (InstanceDomainBlock) TableName() string

+ func (d *InstanceDomainBlock) GetPK() string

+ func (d *InstanceDomainBlock) GetSK() string

+ func (d *InstanceDomainBlock) UpdateKeys() error

+ type InstanceHealth struct

+ CPUUsage float64

+ CheckerVersion string

+ DiskUsage float64

+ Domain string

+ ErrorMessage string

+ ErrorRate float64

+ InboxBacklog int

+ MemoryUsage float64

+ PK string

+ ProcessingDelay time.Duration

+ Reachable bool

+ ResponseTime time.Duration

+ SK string

+ StatusCode int

+ TTL int64

+ Timestamp time.Time

+ UserAgent string

+ func NewInstanceHealth(domain string) *InstanceHealth

+ func (InstanceHealth) TableName() string

+ func (h *InstanceHealth) GetHealthScore() float64

+ func (h *InstanceHealth) GetPK() string

+ func (h *InstanceHealth) GetSK() string

+ func (h *InstanceHealth) IsCritical() bool

+ func (h *InstanceHealth) IsHealthy() bool

+ func (h *InstanceHealth) UpdateKeys() error

+ type InstanceHealthReport struct

+ Domain string

+ ErrorRate float64

+ FederationDelay float64

+ Issues []string

+ LastChecked time.Time

+ PK string

+ QueueDepth int

+ Recommendations []string

+ ResponseTime float64

+ SK string

+ Status string

+ TTL int64

+ Timestamp string

+ func NewInstanceHealthReport(domain string) *InstanceHealthReport

+ func (InstanceHealthReport) TableName() string

+ func (h *InstanceHealthReport) IsCritical() bool

+ func (h *InstanceHealthReport) IsHealthy() bool

+ func (h *InstanceHealthReport) SetHealthStatus()

+ func (h *InstanceHealthReport) UpdateKeys()

+ type InstanceHealthSummary struct

+ Availability float64

+ AvgInboxBacklog int

+ AvgResponseTime time.Duration

+ Domain string

+ ErrorRate float64

+ HealthScore float64

+ LastUpdated time.Time

+ MaxInboxBacklog int

+ MaxResponseTime time.Duration

+ PK string

+ SK string

+ SampleCount int

+ StatusCodeCounts map[string]int

+ TTL int64

+ Window time.Duration

+ func NewInstanceHealthSummary(domain string, window time.Duration) *InstanceHealthSummary

+ func (InstanceHealthSummary) TableName() string

+ func (s *InstanceHealthSummary) GetPK() string

+ func (s *InstanceHealthSummary) GetSK() string

+ func (s *InstanceHealthSummary) UpdateKeys() error

+ type InstanceHistory struct

+ ActiveInstances int64

+ ActiveUsers int64

+ DatabaseBytes int64

+ Date string

+ Delta int64

+ FederatedPosts int64

+ GSI1PK string

+ GSI1SK string

+ Granularity string

+ KnownInstances int64

+ LocalPosts int64

+ MediaBytes int64

+ MetricType string

+ NewPosts int64

+ NewUsers int64

+ PK string

+ RecordedAt time.Time

+ SK string

+ StorageBytes int64

+ TTL int64

+ TotalPosts int64

+ TotalUsers int64

+ Value int64

+ func NewDailyInstanceHistory(date string, metricType string) *InstanceHistory

+ func NewMonthlyInstanceHistory(monthStart string, metricType string) *InstanceHistory

+ func NewWeeklyInstanceHistory(weekStart string, metricType string) *InstanceHistory

+ func (i *InstanceHistory) CalculateDelta(previousValue int64)

+ func (i *InstanceHistory) GetPK() string

+ func (i *InstanceHistory) GetSK() string

+ func (i *InstanceHistory) SetFederationMetrics(knownInstances, activeInstances int64)

+ func (i *InstanceHistory) SetPostMetrics(total, newPosts, local, federated int64)

+ func (i *InstanceHistory) SetStorageMetrics(totalBytes, mediaBytes, dbBytes int64)

+ func (i *InstanceHistory) SetUserMetrics(total, active, newUsers int64)

+ func (i *InstanceHistory) TableName() string

+ func (i *InstanceHistory) UpdateKeys() error

+ type InstanceInfo struct

+ Domain string

+ FirstSeen time.Time

+ LastSeen time.Time

+ PublicKey string

+ SharedInbox string

+ Software string

+ Version string

+ func (InstanceInfo) TableName() string

+ type InstanceMetadata struct

+ AdminContact string

+ Categories []string

+ Description string

+ DisplayName string

+ Domain string

+ FederationNotes string

+ InstanceInfo string

+ Languages []string

+ LastUpdated time.Time

+ NodeInfo string

+ PK string

+ Rules []string

+ SK string

+ Software string

+ StatusCount int64

+ UserCount int64

+ Version string

+ func (InstanceMetadata) TableName() string

+ func (i *InstanceMetadata) UpdateKeys()

+ type InstanceMetrics struct

+ ActiveUsersDaily int64

+ ActiveUsersWeekly int64

+ Date string

+ Delta int64

+ FederationInbound int64

+ FederationOutbound int64

+ GSI1PK string

+ GSI1SK string

+ Logins int32

+ MetricType string

+ PK string

+ Registrations int32

+ SK string

+ Statuses int32

+ TTL int64

+ TotalMedia int64

+ TotalStatuses int64

+ TotalUsers int64

+ UpdatedAt time.Time

+ Value int64

+ Week int64

+ func (i *InstanceMetrics) GetPK() string

+ func (i *InstanceMetrics) GetSK() string

+ func (i *InstanceMetrics) TableName() string

+ func (i *InstanceMetrics) UpdateKeys() error

+ type InstanceMetricsWindow struct

+ Availability float64

+ HealthChecks int64

+ InstanceID string

+ MessageTypes string

+ PK string

+ SK string

+ TTL int64

+ TotalBytes int64

+ TotalCost float64

+ TotalMessages int64

+ WindowSize int64

+ WindowStart time.Time

+ func (InstanceMetricsWindow) TableName() string

+ func (i *InstanceMetricsWindow) GetPK() string

+ func (i *InstanceMetricsWindow) GetSK() string

+ func (i *InstanceMetricsWindow) UpdateKeys() error

+ type InstanceRule struct

+ Active bool

+ Category string

+ CreatedAt time.Time

+ CreatedBy string

+ Description string

+ EnforcedAt *time.Time

+ Examples []string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Order int

+ PK string

+ SK string

+ Severity string

+ Text string

+ UpdatedAt time.Time

+ func (InstanceRule) TableName() string

+ func (r *InstanceRule) Activate()

+ func (r *InstanceRule) Deactivate()

+ func (r *InstanceRule) GetSeverityLevel() int

+ func (r *InstanceRule) SetOrder(order int)

+ func (r *InstanceRule) UpdateKeys()

+ type InstanceState struct

+ ActivatedAt *time.Time

+ BootstrapUsername string

+ BootstrapWalletAddress string

+ CreatedAt time.Time

+ Locked bool

+ PK string

+ PrimaryAdminUsername string

+ SK string

+ UpdatedAt time.Time

+ func NewDefaultInstanceState() *InstanceState

+ func (InstanceState) TableName() string

+ func (s *InstanceState) BeforeCreate() error

+ func (s *InstanceState) BeforeUpdate() error

+ func (s *InstanceState) GetPK() string

+ func (s *InstanceState) GetSK() string

+ func (s *InstanceState) UpdateKeys() error

+ type Like struct

+ Actor string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Object string

+ PK string

+ Published time.Time

+ SK string

+ StatusAuthorID string

+ func NewLike(actor, object, statusAuthorID string) *Like

+ func (Like) TableName() string

+ func (l *Like) GetPK() string

+ func (l *Like) GetSK() string

+ func (l *Like) GetStatusAuthorID() string

+ func (l *Like) GetStatusID() string

+ func (l *Like) GetUserID() string

+ func (l *Like) UpdateKeys() error

+ type LinkMetadata struct

+ AccessCount int64

+ Author string

+ ContentType string

+ Description string

+ Domain string

+ FetchedAt time.Time

+ Image string

+ Keywords []string

+ Language string

+ LastAccessed time.Time

+ PK string

+ PublishedAt *time.Time

+ SK string

+ TTL int64

+ Title string

+ URL string

+ func NewLinkMetadata(linkURL string) *LinkMetadata

+ func (LinkMetadata) TableName() string

+ func (l *LinkMetadata) GetDisplayDomain() string

+ func (l *LinkMetadata) HasImage() bool

+ func (l *LinkMetadata) IsStale(maxAge time.Duration) bool

+ func (l *LinkMetadata) RecordAccess()

+ func (l *LinkMetadata) SanitizeMetadata()

+ func (l *LinkMetadata) SetFromOpenGraph(ogTitle, ogDescription, ogImage string)

+ func (l *LinkMetadata) SetFromTwitterCard(twitterTitle, twitterDescription, twitterImage string)

+ func (l *LinkMetadata) TruncateDescription(maxLength int)

+ func (l *LinkMetadata) UpdateKeys()

+ type LinkShare struct

+ AuthorID string

+ PK string

+ SK string

+ SharedAt time.Time

+ StatusID string

+ TTL int64

+ URL string

+ func (LinkShare) TableName() string

+ func (l *LinkShare) GetPK() string

+ func (l *LinkShare) GetSK() string

+ func (l *LinkShare) UpdateKeys() error

+ type LinkTrend struct

+ AuthorName string

+ Description string

+ GSI8PK string

+ GSI8SK string

+ Image string

+ PK string

+ SK string

+ ShareCount int64

+ TTL int64

+ Title string

+ TrendScore float64

+ Type string

+ URL string

+ UpdatedAt time.Time

+ func (LinkTrend) TableName() string

+ func (l *LinkTrend) UpdateKeys() error

+ type List struct

+ CreatedAt time.Time

+ Exclusive bool

+ GSI1PK string

+ GSI1SK string

+ ID string

+ PK string

+ RepliesPolicy string

+ SK string

+ Title string

+ UpdatedAt time.Time

+ Username string

+ func (List) TableName() string

+ func (l *List) BeforeCreate() error

+ func (l *List) BeforeUpdate() error

+ func (l *List) GetPK() string

+ func (l *List) GetSK() string

+ func (l *List) UpdateKeys() error

+ type ListMember struct

+ AccountID string

+ AddedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ListID string

+ ListUsername string

+ PK string

+ SK string

+ func (ListMember) TableName() string

+ func (lm *ListMember) BeforeCreate() error

+ func (lm *ListMember) GetPK() string

+ func (lm *ListMember) GetSK() string

+ func (lm *ListMember) UpdateKeys() error

+ type LoginAttempt struct

+ PK string

+ SK string

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ Type string

+ func NewLoginAttempt(identifier string, success bool) *LoginAttempt

+ func (LoginAttempt) TableName() string

+ func (la *LoginAttempt) GetPK() string

+ func (la *LoginAttempt) GetSK() string

+ func (la *LoginAttempt) UpdateKeys() error

+ type MLPollRequest struct

+ Attempt int

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ JobID string

+ JobName string

+ MaxAttempts int

+ NextPollAfter time.Time

+ PK string

+ SK string

+ Status string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ func (MLPollRequest) TableName() string

+ func (m *MLPollRequest) GetPK() string

+ func (m *MLPollRequest) GetSK() string

+ func (m *MLPollRequest) UpdateKeys() error

+ type MLPrediction struct

+ Confidence float64

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HumanLabel string

+ Metadata map[string]interface{}

+ ModelVersion string

+ ObjectID string

+ ObjectType string

+ PK string

+ PredictedLabel string

+ PredictionID string

+ Reviewed bool

+ ReviewedAt time.Time

+ ReviewedBy string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ UpdatedAt time.Time

+ func (MLPrediction) TableName() string

+ func (m *MLPrediction) GetPK() string

+ func (m *MLPrediction) GetSK() string

+ func (m *MLPrediction) UpdateKeys() error

+ type Marker struct

+ LastReadID string

+ PK string

+ SK string

+ Timeline string

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func (Marker) TableName() string

+ func (m *Marker) BeforeCreate() error

+ func (m *Marker) BeforeUpdate() error

+ func (m *Marker) GetPK() string

+ func (m *Marker) GetSK() string

+ func (m *Marker) UpdateKeys() error

+ type Media struct

+ Blurhash string

+ CDNUrl string

+ ContentType string

+ CreatedAt time.Time

+ Description string

+ Duration int

+ Error string

+ ExpiresAt int64

+ FileName string

+ FileSize int64

+ Focus string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ Height int

+ IsNSFW bool

+ Labels []string

+ LastUsedAt *time.Time

+ MediaCategory MediaCategory

+ MediaID string

+ ModelVersion int

+ ModerationScore float64

+ PK string

+ ProcessedAt *time.Time

+ S3Bucket string

+ S3Key string

+ SK string

+ SpoilerText string

+ Status string

+ UpdatedAt time.Time

+ UploadedAt time.Time

+ UsageCount int

+ UserID string

+ Variants map[string]MediaVariant

+ Version string

+ Width int

+ func (Media) TableName() string

+ func (m *Media) AddVariant(name string, variant MediaVariant)

+ func (m *Media) BeforeCreate() error

+ func (m *Media) BeforeUpdate() error

+ func (m *Media) GetAvailableVariants() []string

+ func (m *Media) GetBestVariant(maxWidth, maxHeight int) MediaVariant

+ func (m *Media) GetPK() string

+ func (m *Media) GetSK() string

+ func (m *Media) GetTotalSize() int64

+ func (m *Media) GetVariant(name string) (MediaVariant, bool)

+ func (m *Media) IsAudio() bool

+ func (m *Media) IsFailed() bool

+ func (m *Media) IsImage() bool

+ func (m *Media) IsProcessing() bool

+ func (m *Media) IsReady() bool

+ func (m *Media) IsVideo() bool

+ func (m *Media) MarkUsed()

+ func (m *Media) SetFailed(errorMsg string)

+ func (m *Media) SetModeration(isNSFW bool, score float64, labels []string)

+ func (m *Media) SetProcessed()

+ func (m *Media) SetProcessing()

+ func (m *Media) UpdateKeys() error

+ func (m *Media) Validate() error

+ type MediaAnalytics struct

+ CloudFrontCost int64

+ Date string

+ DominantVariant string

+ Duration float64

+ EventType string

+ Format string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ LambdaCost int64

+ MediaConvertCost int64

+ MediaID string

+ PK string

+ Quality string

+ QualityDistribution map[string]int

+ RekognitionCost int64

+ S3StorageCost int64

+ SK string

+ StreamingSessions int

+ TTL int64

+ Timestamp time.Time

+ TotalBandwidthBytes int64

+ TotalVariantCost int64

+ UserID string

+ VariantBandwidth map[string]int64

+ VariantCacheHitRate map[string]float64

+ VariantCosts map[string]MediaVariantCost

+ VariantErrorRate map[string]float64

+ VariantLatency map[string]int64

+ func (MediaAnalytics) TableName() string

+ func (m *MediaAnalytics) AddQualityViewer(quality string)

+ func (m *MediaAnalytics) AddVariantCost(resolution, codec string, bitrate int, cost MediaVariantCost)

+ func (m *MediaAnalytics) GetCostEfficiencyMetrics() map[string]interface{}

+ func (m *MediaAnalytics) GetMostPopularQuality() (string, int)

+ func (m *MediaAnalytics) GetPK() string

+ func (m *MediaAnalytics) GetSK() string

+ func (m *MediaAnalytics) RemoveQualityViewer(quality string)

+ func (m *MediaAnalytics) SetGeneralEvent(eventType, mediaID, userID string)

+ func (m *MediaAnalytics) SetManifestGeneration(mediaID, format string, duration float64)

+ func (m *MediaAnalytics) SetQualityChange(mediaID, userID, _, newQuality string)

+ func (m *MediaAnalytics) TrackVariantDelivery(variantKey string, bytes int64, latencyMs int64, cacheHit bool, success bool)

+ func (m *MediaAnalytics) UpdateKeys() error

+ type MediaAttachment struct

+ AttachedAt time.Time

+ ContentType string

+ Description string

+ EntityID string

+ EntityType string

+ FileSize int64

+ FocalPoint string

+ MediaID string

+ MediaType string

+ Order int

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func (MediaAttachment) TableName() string

+ func (m *MediaAttachment) BeforeCreate() error

+ func (m *MediaAttachment) BeforeUpdate() error

+ func (m *MediaAttachment) GetFocalPoint() (x, y float64, ok bool)

+ func (m *MediaAttachment) IsForScheduledStatus() bool

+ func (m *MediaAttachment) IsForUser() bool

+ func (m *MediaAttachment) SetFocalPoint(x, y float64)

+ func (m *MediaAttachment) UpdateKeys(entityType, entityID string)

+ func (m *MediaAttachment) Validate() error

+ type MediaCategory string

+ const MediaCategoryAudio

+ const MediaCategoryDocument

+ const MediaCategoryGifv

+ const MediaCategoryImage

+ const MediaCategoryUnknown

+ const MediaCategoryVideo

+ func DetermineMediaCategory(contentType string) MediaCategory

+ func NormalizeMediaCategory(category string) (MediaCategory, bool)

+ type MediaJob struct

+ ActualCostMicros int64

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Error string

+ EstimatedCostMicros int64

+ ExpiresAt *int64

+ FileHash string

+ FileSize int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IdempotencyKey string

+ JobID string

+ LastAttemptAt *time.Time

+ LastError string

+ MaxProcessingTime time.Duration

+ MaxRetries int

+ MediaID string

+ MimeType string

+ ModelVersion int

+ PK string

+ ProcessingStartedAt *time.Time

+ ProcessingTasks []string

+ Progress int

+ Results map[string]any

+ RetryCount int

+ RetryScheduledAt *time.Time

+ S3Key string

+ SK string

+ StartedAt *time.Time

+ Status string

+ UpdatedAt time.Time

+ Username string

+ func (MediaJob) TableName() string

+ func (mj *MediaJob) AddCost(costMicros int64)

+ func (mj *MediaJob) AddProcessingTask(task string)

+ func (mj *MediaJob) BeforeCreate() error

+ func (mj *MediaJob) BeforeUpdate() error

+ func (mj *MediaJob) CanRetry() bool

+ func (mj *MediaJob) GenerateIdempotencyKey() string

+ func (mj *MediaJob) GetPK() string

+ func (mj *MediaJob) GetProcessingDuration() time.Duration

+ func (mj *MediaJob) GetRemainingProcessingTime() time.Duration

+ func (mj *MediaJob) GetSK() string

+ func (mj *MediaJob) HasProcessingTask(task string) bool

+ func (mj *MediaJob) IsAbandoned(abandonThreshold time.Duration) bool

+ func (mj *MediaJob) IsBudgetExceeded() bool

+ func (mj *MediaJob) IsCancelled() bool

+ func (mj *MediaJob) IsCompleted() bool

+ func (mj *MediaJob) IsFailed() bool

+ func (mj *MediaJob) IsIdle() bool

+ func (mj *MediaJob) IsPending() bool

+ func (mj *MediaJob) IsProcessing() bool

+ func (mj *MediaJob) IsReadyForRetry() bool

+ func (mj *MediaJob) IsRetryableError(errorMsg string) bool

+ func (mj *MediaJob) ScheduleRetry(baseDelay time.Duration)

+ func (mj *MediaJob) SetCancelled(reason string)

+ func (mj *MediaJob) SetCompleted(results map[string]any)

+ func (mj *MediaJob) SetFailed(errorMsg string)

+ func (mj *MediaJob) SetProcessing()

+ func (mj *MediaJob) UpdateKeys() error

+ func (mj *MediaJob) UpdateProgress(progress int)

+ func (mj *MediaJob) Validate() error

+ type MediaMetadata struct

+ AudioCodec string

+ AvailableQualities []string

+ Bitrate int

+ Blurhash string

+ CreatedAt time.Time

+ Duration float64

+ FileSize int64

+ GSI1PK string

+ GSI1SK string

+ Height int

+ MediaID string

+ OriginalURL string

+ PK string

+ ProcessedAt time.Time

+ QualitySettings map[string]QualityCodecInfo

+ SK string

+ Status string

+ TTL int64

+ UpdatedAt time.Time

+ VideoCodec string

+ VideoLevel string

+ VideoProfile string

+ Width int

+ func (MediaMetadata) TableName() string

+ func (m *MediaMetadata) AddQuality(quality string)

+ func (m *MediaMetadata) BeforeCreate() error

+ func (m *MediaMetadata) BeforeUpdate() error

+ func (m *MediaMetadata) GetCodecInfo(quality string) (QualityCodecInfo, bool)

+ func (m *MediaMetadata) GetPK() string

+ func (m *MediaMetadata) GetSK() string

+ func (m *MediaMetadata) HasQuality(quality string) bool

+ func (m *MediaMetadata) IsComplete() bool

+ func (m *MediaMetadata) IsFailed() bool

+ func (m *MediaMetadata) IsPending() bool

+ func (m *MediaMetadata) IsProcessing() bool

+ func (m *MediaMetadata) SetCodecInfo(quality string, info QualityCodecInfo)

+ func (m *MediaMetadata) SetComplete()

+ func (m *MediaMetadata) SetFailed()

+ func (m *MediaMetadata) SetProcessing()

+ func (m *MediaMetadata) UpdateKeys() error

+ func (m *MediaMetadata) Validate() error

+ type MediaPopularity struct

+ BufferingEvents int64

+ CompletionCount int64

+ Date string

+ FirstViewed time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ LastViewed time.Time

+ MediaID string

+ PK string

+ Period string

+ PopularityScore float64

+ QualityViews map[string]int64

+ SK string

+ TTL int64

+ Timestamp time.Time

+ TotalWatchTime int64

+ TrendScore float64

+ UniqueViewers int64

+ ViewCount int64

+ func (MediaPopularity) TableName() string

+ func (m *MediaPopularity) AddQualityView(quality string, count int64)

+ func (m *MediaPopularity) CalculateAvgWatchTime() float64

+ func (m *MediaPopularity) CalculateCompletionRate() float64

+ func (m *MediaPopularity) GetPK() string

+ func (m *MediaPopularity) GetSK() string

+ func (m *MediaPopularity) IncrementViews(count int64)

+ func (m *MediaPopularity) SetForPeriod(mediaID string, period string, viewCount int64)

+ func (m *MediaPopularity) UpdateKeys() error

+ type MediaSession struct

+ Active bool

+ BufferHealth float64

+ BytesTransferred int64

+ CurrentQuality string

+ Duration float64

+ EndTime *time.Time

+ Format string

+ GSI1PK string

+ GSI1SK string

+ LastSegmentIndex int

+ LastUpdate *time.Time

+ MediaID string

+ PK string

+ SK string

+ SessionID string

+ StartTime time.Time

+ TTL int64

+ UserID string

+ func (MediaSession) TableName() string

+ func (m *MediaSession) GetPK() string

+ func (m *MediaSession) GetSK() string

+ func (m *MediaSession) SetTTL(ttl time.Duration)

+ func (m *MediaSession) UpdateKeys() error

+ type MediaSpending struct

+ AudioProcessingOps int64

+ BandwidthBytes int64

+ BandwidthSpendMicros int64

+ BudgetExceeded bool

+ BudgetExceededAt *time.Time

+ BudgetLimitMicros int64

+ BudgetUsagePercent float64

+ BytesProcessed int64

+ CloudFrontCostMicros int64

+ ComputeSpendMicros int64

+ ComputeTimeMs int64

+ CreatedAt time.Time

+ ErrorCostMicros int64

+ ExpiresAt *int64

+ FailedOperations int64

+ FilesProcessed int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ImageProcessingOps int64

+ LambdaCostMicros int64

+ MediaConvertCostMicros int64

+ MediaConvertMinutes int64

+ ModelVersion int

+ PK string

+ Period string

+ PeriodEndAt time.Time

+ PeriodStartAt time.Time

+ PeriodType string

+ ProcessingSpendMicros int64

+ RekognitionCostMicros int64

+ RekognitionImages int64

+ S3RequestCostMicros int64

+ S3StorageCostMicros int64

+ SK string

+ StorageBytesUsed int64

+ StorageOperations int64

+ StorageSpendMicros int64

+ ThumbnailsGenerated int64

+ TotalOperations int64

+ TotalSpendMicros int64

+ UpdatedAt time.Time

+ UserID string

+ Username string

+ VideoProcessingOps int64

+ func (MediaSpending) TableName() string

+ func (ms *MediaSpending) AddSpending(transaction *MediaSpendingTransaction)

+ func (ms *MediaSpending) BeforeCreate() error

+ func (ms *MediaSpending) BeforeUpdate() error

+ func (ms *MediaSpending) GetCostBreakdown() map[string]int64

+ func (ms *MediaSpending) GetEfficiencyMetrics() map[string]float64

+ func (ms *MediaSpending) GetPK() string

+ func (ms *MediaSpending) GetRemainingBudget() int64

+ func (ms *MediaSpending) GetSK() string

+ func (ms *MediaSpending) GetServiceBreakdown() map[string]int64

+ func (ms *MediaSpending) IsOverBudget() bool

+ func (ms *MediaSpending) UpdateKeys() error

+ func (ms *MediaSpending) Validate() error

+ type MediaSpendingTransaction struct

+ BytesProcessed int64

+ Category string

+ ContentType string

+ CostMicros int64

+ CreatedAt time.Time

+ Description string

+ ErrorMessage string

+ ExpiresAt *int64

+ FileName string

+ FileSize int64

+ GSI1PK string

+ GSI1SK string

+ IsError bool

+ JobID string

+ MediaID string

+ Operation string

+ PK string

+ ProcessingTimeMs int64

+ SK string

+ Service string

+ TransactionID string

+ UnitsConsumed int64

+ UserID string

+ Username string

+ func (MediaSpendingTransaction) TableName() string

+ func (mst *MediaSpendingTransaction) BeforeCreate() error

+ func (mst *MediaSpendingTransaction) GetPK() string

+ func (mst *MediaSpendingTransaction) GetSK() string

+ func (mst *MediaSpendingTransaction) UpdateKeys() error

+ func (mst *MediaSpendingTransaction) Validate() error

+ type MediaVariant struct

+ CDNUrl string

+ ContentType string

+ FileSize int64

+ Height int

+ Quality string

+ S3Key string

+ Width int

+ func (MediaVariant) TableName() string

+ type MediaVariantCost struct

+ AverageLatencyMs int64

+ BandwidthBytes int64

+ BandwidthCost int64

+ Bitrate int

+ CacheHitRate float64

+ Codec string

+ CompressionRatio float64

+ DeliveryCount int64

+ ErrorRate float64

+ OutputSizeBytes int64

+ PSNR float64

+ ProcessingCost int64

+ ProcessingTimeMs int64

+ Resolution string

+ SSIM float64

+ StorageCost int64

+ TotalCost int64

+ VMAF float64

+ VariantKey string

+ ViewerMinutes int64

+ func (MediaVariantCost) TableName() string

+ type Mention struct

+ Acct string

+ ID string

+ URL string

+ Username string

+ func (Mention) TableName() string

+ type MetricRecord struct

+ AggregationLevel string

+ Count int64

+ CreatedAt time.Time

+ Dimensions map[string]string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ Max float64

+ MetricID string

+ MetricType string

+ Min float64

+ P50 float64

+ P95 float64

+ P99 float64

+ PK string

+ SK string

+ ServiceName string

+ Sum float64

+ TTL int64

+ Timestamp time.Time

+ Unit string

+ UpdatedAt time.Time

+ func (MetricRecord) TableName() string

+ func (m *MetricRecord) AddDimension(key, value string)

+ func (m *MetricRecord) BeforeCreate() error

+ func (m *MetricRecord) BeforeUpdate() error

+ func (m *MetricRecord) GetPK() string

+ func (m *MetricRecord) GetSK() string

+ func (m *MetricRecord) UpdateKeys() error

+ func (m *MetricRecord) Validate() error

+ type MetricRecordBuilder struct

+ func NewMetricRecordBuilder() *MetricRecordBuilder

+ func (MetricRecordBuilder) TableName() string

+ func (mb *MetricRecordBuilder) Build() *MetricRecord

+ func (mb *MetricRecordBuilder) ForService(serviceName string) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) OfType(metricType string) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) WithAggregationLevel(level string) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) WithDimension(key, value string) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) WithStats(count int64, sum, minVal, maxVal, p50, p95, p99 float64) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) WithTimestamp(timestamp time.Time) *MetricRecordBuilder

+ func (mb *MetricRecordBuilder) WithUnit(unit string) *MetricRecordBuilder

+ type Metrics struct

+ Average float64

+ Count int64

+ CreatedAt time.Time

+ Dimensions map[string]string

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ Max float64

+ Min float64

+ PK string

+ Percentiles map[string]float64

+ Period string

+ Properties map[string]interface{}

+ ResourceID string

+ ResourceType string

+ SK string

+ Service string

+ Sum float64

+ Tags map[string]string

+ Timestamp time.Time

+ Type string

+ Unit string

+ UpdatedAt time.Time

+ Value float64

+ func (Metrics) TableName() string

+ func (m *Metrics) AddDimension(key, value string)

+ func (m *Metrics) AddTag(key, value string)

+ func (m *Metrics) BeforeCreate() error

+ func (m *Metrics) BeforeUpdate() error

+ func (m *Metrics) GetPK() string

+ func (m *Metrics) GetProperty(key string) (interface{}, bool)

+ func (m *Metrics) GetSK() string

+ func (m *Metrics) SetPercentile(percentile string, value float64)

+ func (m *Metrics) SetProperty(key string, value interface{})

+ func (m *Metrics) UpdateKeys() error

+ func (m *Metrics) Validate() error

+ type MetricsBuilder struct

+ func NewMetricsBuilder() *MetricsBuilder

+ func (MetricsBuilder) TableName() string

+ func (mb *MetricsBuilder) Build() *Metrics

+ func (mb *MetricsBuilder) ForService(service string) *MetricsBuilder

+ func (mb *MetricsBuilder) OfType(metricType string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithDimension(key, value string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithPeriod(period string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithResource(resourceID, resourceType string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithStats(count int64, sum, minVal, maxVal float64) *MetricsBuilder

+ func (mb *MetricsBuilder) WithTag(key, value string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithUnit(unit string) *MetricsBuilder

+ func (mb *MetricsBuilder) WithValue(value float64) *MetricsBuilder

+ type MetricsCompression struct

+ ActivityPattern uint32

+ CompressedAt time.Time

+ FailureCountDelta int64

+ QuantizedSuccessRate uint8

+ ResponseTimeP50 uint16

+ ResponseTimeP95 uint16

+ ResponseTimeP99 uint16

+ StateTransitions []byte

+ SuccessCountDelta int64

+ TotalAttemptsDelta int64

+ Version uint8

+ func (MetricsCompression) TableName() string

+ func (mc *MetricsCompression) ToBinary() []byte

+ type MissingReply struct

+ AttemptCount int

+ DetectedAt time.Time

+ FailureReason string

+ GSI1PK string

+ GSI1SK string

+ LastAttemptAt *time.Time

+ LastError string

+ NextRetryAt *time.Time

+ PK string

+ ParentStatusID string

+ Priority int

+ ReplyID string

+ ReplyURL string

+ ResolvedAt *time.Time

+ RootStatusID string

+ SK string

+ Status string

+ TTL int64

+ UpdatedAt time.Time

+ func NewMissingReply(rootStatusID, parentStatusID, replyID string) *MissingReply

+ func (MissingReply) TableName() string

+ func (m *MissingReply) GetPK() string

+ func (m *MissingReply) GetSK() string

+ func (m *MissingReply) IsPermanentFailure() bool

+ func (m *MissingReply) MarkFailed(errorMsg, failureReason string)

+ func (m *MissingReply) MarkFetching()

+ func (m *MissingReply) MarkResolved()

+ func (m *MissingReply) SetPriority(priority int)

+ func (m *MissingReply) ShouldRetry() bool

+ func (m *MissingReply) UpdateKeys() error

+ type ModelTrainingJob struct

+ BaseModelID string

+ CompletedAt time.Time

+ CreatedAt time.Time

+ DatasetS3Key string

+ DatasetSamples int

+ ErrorMessage string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ InitiatedBy string

+ JobID string

+ JobName string

+ Metadata map[string]interface{}

+ Metrics TrainingMetrics

+ ModelARN string

+ PK string

+ SK string

+ StartedAt time.Time

+ Status string

+ TTL int64

+ TenantID string

+ Type string

+ UpdatedAt time.Time

+ func (ModelTrainingJob) TableName() string

+ func (m *ModelTrainingJob) GetPK() string

+ func (m *ModelTrainingJob) GetSK() string

+ func (m *ModelTrainingJob) UpdateKeys() error

+ type Moderation struct

+ Action ModerationAction

+ ActionedAt *time.Time

+ ContentID string

+ ContentType ModerationContentType

+ CreatedAt time.Time

+ Evidence ModerationEvidence

+ History []ModerationHistoryEntry

+ Metadata map[string]interface{}

+ ModerationID string

+ ModeratorID string

+ ModeratorType string

+ Reason ModerationReason

+ ResolvedAt *time.Time

+ Status ModerationStatus

+ UserID string

+ func (Moderation) TableName() string

+ func (m *Moderation) AddHistoryEntry(actorID, actorType string, action ModerationAction, ...)

+ func (m *Moderation) GetPrimaryProhibitedWord() string

+ func (m *Moderation) GetRateLimitViolationSeverity() string

+ type ModerationAction string

+ const ModerationActionDismiss

+ const ModerationActionRemove

+ const ModerationActionRestore

+ const ModerationActionSilence

+ const ModerationActionSuspend

+ const ModerationActionWarning

+ type ModerationAnalysisResult struct

+ AnalysisType string

+ AnalyzedAt time.Time

+ AuthorID string

+ Confidence float64

+ ContentID string

+ ContentType string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ PK string

+ PatternMatches []interface{}

+ ProcessingTime int64

+ ReputationScore interface{}

+ Results map[string]interface{}

+ SK string

+ TTL int64

+ ThreatMatches []interface{}

+ Type string

+ func (ModerationAnalysisResult) TableName() string

+ func (m *ModerationAnalysisResult) UpdateKeys()

+ type ModerationAnalytics struct

+ AverageResolutionTime float64

+ Count int64

+ CreatedAt time.Time

+ Date string

+ GSI2PK string

+ GSI2SK string

+ Matched bool

+ ModeratorActions map[string]int64

+ PK string

+ PatternID string

+ ReportType string

+ ResolvedCount int64

+ SK string

+ TTL int64

+ Timestamp time.Time

+ UpdatedAt time.Time

+ func (ModerationAnalytics) TableName() string

+ func (m *ModerationAnalytics) GetPK() string

+ func (m *ModerationAnalytics) GetSK() string

+ func (m *ModerationAnalytics) UpdateKeys() error

+ type ModerationContentType string

+ const ModerationContentTypeMedia

+ const ModerationContentTypeReport

+ const ModerationContentTypeStatus

+ const ModerationContentTypeUser

+ type ModerationDecision struct

+ Action string

+ ConsensusScore float64

+ CreatedAt time.Time

+ Decided time.Time

+ EventID string

+ Expires *time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ Metadata map[string]interface{}

+ ObjectID string

+ PK string

+ ReviewerCount int

+ Reviews []interface{}

+ SK string

+ TTL int64

+ TrustWeightTotal float64

+ Type string

+ func (ModerationDecision) TableName() string

+ func (d *ModerationDecision) UpdateKeys()

+ type ModerationDecisionResult struct

+ Action string

+ AuthorID string

+ Confidence float64

+ ContentID string

+ CreatedAt time.Time

+ DecidedAt time.Time

+ EnforcedAt *time.Time

+ EnforcementError string

+ EnforcementStatus string

+ ExpiresAt *time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ Metadata map[string]interface{}

+ PK string

+ Reasons []interface{}

+ Recommendations []string

+ RequiresReview bool

+ ReviewPriority int

+ SK string

+ TTL int64

+ Type string

+ func (ModerationDecisionResult) TableName() string

+ func (m *ModerationDecisionResult) UpdateKeys()

+ type ModerationDecisionSample struct

+ Confidence float64

+ ContentID string

+ Date string

+ Decision string

+ GSI1PK string

+ GSI1SK string

+ PK string

+ ProcessingTime int64

+ ReasonCount int

+ RequiresReview bool

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ func (ModerationDecisionSample) TableName() string

+ func (m *ModerationDecisionSample) GetPK() string

+ func (m *ModerationDecisionSample) GetSK() string

+ func (m *ModerationDecisionSample) UpdateKeys() error

+ type ModerationEffectivenessMetric struct

+ CreatedAt time.Time

+ EndTime time.Time

+ F1Score float64

+ FalseNegatives int

+ FalsePositives int

+ GSI1PK string

+ GSI1SK string

+ PK string

+ PatternID string

+ Period string

+ Precision float64

+ Recall float64

+ SK string

+ StartTime time.Time

+ TotalReviewed int

+ TrueNegatives int

+ TruePositives int

+ Type string

+ UpdatedAt time.Time

+ func (ModerationEffectivenessMetric) TableName() string

+ func (m *ModerationEffectivenessMetric) CalculateMetrics()

+ func (m *ModerationEffectivenessMetric) GetPK() string

+ func (m *ModerationEffectivenessMetric) GetSK() string

+ func (m *ModerationEffectivenessMetric) UpdateKeys() error

+ type ModerationEvent struct

+ ActorID string

+ Category string

+ ConfidenceScore float64

+ Created time.Time

+ CreatedAt time.Time

+ EventType string

+ Evidence []any

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ ID string

+ ObjectID string

+ ObjectType string

+ PK string

+ Reason string

+ SK string

+ Severity string

+ TTL int64

+ Type string

+ Updated time.Time

+ func (ModerationEvent) TableName() string

+ func (m *ModerationEvent) GetPK() string

+ func (m *ModerationEvent) GetSK() string

+ func (m *ModerationEvent) UpdateKeys() error

+ type ModerationEvidence struct

+ AverageInterval float64

+ BurstSize int

+ ConfidenceScore float64

+ ContentHash string

+ ContentLength int

+ DuplicateCount int

+ ExternalProvider string

+ ExternalScore float64

+ FalsePositiveRisk float64

+ FollowerRatio float64

+ HashtagCount int

+ IPAddress string

+ Language string

+ LastViolationAt string

+ LinkCount int

+ MatchedPatterns []string

+ MediaFingerprint string

+ MentionCount int

+ NewAccountPosts int

+ PostFrequency float64

+ ProhibitedWords []string

+ RegistrationAge string

+ ReportCount int

+ ReporterIDs []string

+ RequestCount int

+ RequestPeriod string

+ RequiresReview bool

+ Sentiment float64

+ SpamIndicators []string

+ SpamScore float64

+ SuspiciousLinks []string

+ TextContent string

+ Toxicity float64

+ UserAgent string

+ ViolationCount int

+ func (ModerationEvidence) TableName() string

+ type ModerationFalsePositive struct

+ Confidence float64

+ ContentID string

+ Date string

+ GSI1PK string

+ GSI1SK string

+ OriginalDecision string

+ PK string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ func (ModerationFalsePositive) TableName() string

+ func (m *ModerationFalsePositive) GetPK() string

+ func (m *ModerationFalsePositive) GetSK() string

+ func (m *ModerationFalsePositive) UpdateKeys() error

+ type ModerationHistoryEntry struct

+ Action ModerationAction

+ ActorID string

+ ActorType string

+ ChangedData map[string]interface{}

+ FromStatus ModerationStatus

+ Note string

+ Timestamp time.Time

+ ToStatus ModerationStatus

+ func (ModerationHistoryEntry) TableName() string

+ type ModerationMetricsEntry struct

+ Count int64

+ CreatedAt time.Time

+ Date string

+ GSI1PK string

+ GSI1SK string

+ Hour string

+ MetricType string

+ PK string

+ SK string

+ TTL int64

+ Type string

+ func (ModerationMetricsEntry) TableName() string

+ func (m *ModerationMetricsEntry) GetPK() string

+ func (m *ModerationMetricsEntry) GetSK() string

+ func (m *ModerationMetricsEntry) UpdateKeys() error

+ type ModerationMetricsStats struct

+ ActionCounts map[AdvancedModerationAction]int64

+ AverageConfidence float64

+ CategoryCounts map[string]int64

+ FalsePositives int64

+ ResponseTime time.Duration

+ SeverityCounts map[AdvancedSeverity]int64

+ TimeRange ModerationMetricsTimeRange

+ TotalAnalyzed int64

+ TruePositives int64

+ func (ModerationMetricsStats) TableName() string

+ type ModerationMetricsTimeRange struct

+ End time.Time

+ Start time.Time

+ func (ModerationMetricsTimeRange) TableName() string

+ type ModerationModelVersion struct

+ Accuracy float64

+ CreatedAt time.Time

+ DatasetHash string

+ F1Score float64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IsActive bool

+ Metadata map[string]interface{}

+ ModelARN string

+ PK string

+ Precision float64

+ Recall float64

+ SK string

+ SamplesUsed int

+ TrainingJobID string

+ TrainingStatus string

+ TrainingTime int

+ Type string

+ UpdatedAt time.Time

+ VersionID string

+ func (ModerationModelVersion) TableName() string

+ func (m *ModerationModelVersion) GetPK() string

+ func (m *ModerationModelVersion) GetSK() string

+ func (m *ModerationModelVersion) UpdateKeys() error

+ type ModerationPattern struct

+ Active bool

+ Category string

+ CreatedAt time.Time

+ Description string

+ Flags []string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HitCount int64

+ LastHit time.Time

+ Name string

+ PK string

+ Pattern string

+ PatternID string

+ SK string

+ Severity float64

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ func (ModerationPattern) TableName() string

+ func (p *ModerationPattern) GetPK() string

+ func (p *ModerationPattern) GetSK() string

+ func (p *ModerationPattern) UpdateKeys() error

+ type ModerationPatternStats struct

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ HitCount int64

+ LastHit time.Time

+ PK string

+ PatternID string

+ PatternName string

+ SK string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ func (ModerationPatternStats) TableName() string

+ func (m *ModerationPatternStats) GetPK() string

+ func (m *ModerationPatternStats) GetSK() string

+ func (m *ModerationPatternStats) UpdateKeys() error

+ type ModerationReason string

+ const ModerationReasonCopyright

+ const ModerationReasonHarassment

+ const ModerationReasonHateSpeech

+ const ModerationReasonMisinformation

+ const ModerationReasonOther

+ const ModerationReasonProhibitedWords

+ const ModerationReasonRateLimiting

+ const ModerationReasonSpam

+ type ModerationReview struct

+ Action string

+ Confidence float64

+ Created time.Time

+ CreatedAt time.Time

+ EventID string

+ ID string

+ Metadata map[string]interface{}

+ Note string

+ PK string

+ ReviewerID string

+ ReviewerRep float64

+ SK string

+ Severity string

+ TTL int64

+ Tags []string

+ Type string

+ func (ModerationReview) TableName() string

+ func (r *ModerationReview) UpdateKeys()

+ type ModerationReviewQueue struct

+ AssignedAt *time.Time

+ AssignedTo string

+ AuthorID string

+ Category string

+ CompletedAt *time.Time

+ ContentID string

+ CreatedAt time.Time

+ Deadline *time.Time

+ Evidence map[string]interface{}

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ LastReviewedAt *time.Time

+ PK string

+ Priority int

+ Reason string

+ ReviewCount int

+ SK string

+ Severity string

+ Status string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ func (ModerationReviewQueue) TableName() string

+ func (m *ModerationReviewQueue) UpdateKeys()

+ type ModerationSample struct

+ Confidence float64

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ ID string

+ Label string

+ Metadata map[string]interface{}

+ ObjectID string

+ ObjectType string

+ PK string

+ ReviewerID string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ UpdatedAt time.Time

+ func (ModerationSample) TableName() string

+ func (m *ModerationSample) GetPK() string

+ func (m *ModerationSample) GetSK() string

+ func (m *ModerationSample) UpdateKeys() error

+ type ModerationStatus string

+ const ModerationStatusActioned

+ const ModerationStatusAppealed

+ const ModerationStatusDismissed

+ const ModerationStatusPending

+ const ModerationStatusResolved

+ const ModerationStatusReviewing

+ type Move struct

+ Actor string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ PK string

+ Published time.Time

+ SK string

+ TTL *int64

+ Target string

+ func NewMove(id, actor, target string) *Move

+ func (Move) TableName() string

+ func (m *Move) BeforeCreate() error

+ func (m *Move) ExtractActor() string

+ func (m *Move) ExtractTarget() string

+ func (m *Move) SetTTL(ttl time.Time)

+ func (m *Move) UpdateKeys()

+ type Mute struct

+ Actor string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ HideNotifications bool

+ ID string

+ Object string

+ PK string

+ Published time.Time

+ SK string

+ Type string

+ func (Mute) TableName() string

+ func (m *Mute) BeforeCreate() error

+ func (m *Mute) GetPK() string

+ func (m *Mute) GetSK() string

+ func (m *Mute) UpdateKeys() error

+ type Notification struct

+ ActorID string

+ ActorType string

+ Body string

+ CreatedAt time.Time

+ Data map[string]interface{}

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GroupCount int

+ GroupKey string

+ ID string

+ IsRead bool

+ PK string

+ PushError string

+ PushSent bool

+ PushSentAt *time.Time

+ ReadAt *time.Time

+ SK string

+ TargetID string

+ TargetType string

+ Title string

+ Type string

+ UpdatedAt time.Time

+ UserID string

+ Version int

+ func NewFavouriteNotification(userID, likerID, statusID string) *Notification

+ func NewFollowNotification(userID, followerID string) *Notification

+ func NewFollowRequestNotification(userID, requesterID string) *Notification

+ func NewMentionNotification(userID, actorID, statusID string) *Notification

+ func NewReblogNotification(userID, rebloggerID, statusID string) *Notification

+ func (Notification) TableName() string

+ func (n *Notification) BeforeCreate() error

+ func (n *Notification) BeforeUpdate() error

+ func (n *Notification) GetData(key string) (interface{}, bool)

+ func (n *Notification) GetPK() string

+ func (n *Notification) GetSK() string

+ func (n *Notification) IncrementGroupCount()

+ func (n *Notification) MarkPushFailed(errorMsg string)

+ func (n *Notification) MarkPushSent()

+ func (n *Notification) MarkRead()

+ func (n *Notification) MarkUnread()

+ func (n *Notification) SetData(key string, value interface{})

+ func (n *Notification) ShouldSendPush() bool

+ func (n *Notification) UpdateKeys() error

+ func (n *Notification) Validate() error

+ type NotificationBudget struct

+ AllowedDeliveryMethods []string

+ BlockDeliveryAt float64

+ BudgetExceeded bool

+ CreatedAt time.Time

+ Enabled bool

+ LastExceededTime time.Time

+ LastWarningTime time.Time

+ LimitDollars float64

+ LimitMicroCents int64

+ MaxNotificationsPerPeriod int64

+ NextResetTime time.Time

+ NotificationsSentThisPeriod int64

+ PK string

+ Period string

+ PeriodEnd time.Time

+ PeriodStart time.Time

+ RemainingDollars float64

+ RemainingMicroCents int64

+ SK string

+ SendWarningAt float64

+ SpentDollars float64

+ SpentMicroCents int64

+ UpdatedAt time.Time

+ Username string

+ WarningsSent int

+ func (NotificationBudget) TableName() string

+ func (n *NotificationBudget) AddSpending(costMicroCents int64) bool

+ func (n *NotificationBudget) BeforeCreate() error

+ func (n *NotificationBudget) BeforeUpdate() error

+ func (n *NotificationBudget) CalculateDollarAmounts()

+ func (n *NotificationBudget) CalculateRemaining()

+ func (n *NotificationBudget) GetPK() string

+ func (n *NotificationBudget) GetSK() string

+ func (n *NotificationBudget) IsMethodAllowed(method string) bool

+ func (n *NotificationBudget) ResetPeriod(newPeriodStart, newPeriodEnd time.Time)

+ func (n *NotificationBudget) ShouldBlockDelivery() bool

+ func (n *NotificationBudget) ShouldSendWarning() bool

+ func (n *NotificationBudget) UpdateKeys() error

+ type NotificationBuilder struct

+ func NewNotificationBuilder() *NotificationBuilder

+ func (NotificationBuilder) TableName() string

+ func (nb *NotificationBuilder) AboutTarget(targetID, targetType string) *NotificationBuilder

+ func (nb *NotificationBuilder) Build() *Notification

+ func (nb *NotificationBuilder) ForUser(userID string) *NotificationBuilder

+ func (nb *NotificationBuilder) FromActor(actorID, actorType string) *NotificationBuilder

+ func (nb *NotificationBuilder) OfType(notifType string) *NotificationBuilder

+ func (nb *NotificationBuilder) WithContent(title, body string) *NotificationBuilder

+ func (nb *NotificationBuilder) WithData(key string, value interface{}) *NotificationBuilder

+ func (nb *NotificationBuilder) WithGroupKey(groupKey string) *NotificationBuilder

+ type NotificationChannelCostStats struct

+ AverageCostDollars float64

+ AverageCostMicroCents int64

+ AverageDeliveryTimeMs float64

+ Channel string

+ Count int64

+ FailedDeliveries int64

+ SuccessRate float64

+ SuccessfulDeliveries int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ func (NotificationChannelCostStats) TableName() string

+ type NotificationCostAggregation struct

+ AverageDeliveryTimeMs float64

+ AverageProcessingTimeMs float64

+ AverageTotalTimeMs float64

+ ChannelBreakdown map[string]*NotificationChannelCostStats

+ CostPerDelivery float64

+ CreatedAt time.Time

+ DeliveryMethod string

+ FailedDeliveries int64

+ PK string

+ Period string

+ RetryRate float64

+ SK string

+ SuccessRate float64

+ SuccessfulDeliveries int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalDynamoDBCostDollars float64

+ TotalDynamoDBCostMicroCents int64

+ TotalLambdaCostDollars float64

+ TotalLambdaCostMicroCents int64

+ TotalNotifications int64

+ TotalPushCostDollars float64

+ TotalPushCostMicroCents int64

+ TotalRetries int64

+ TotalWebSocketCostDollars float64

+ TotalWebSocketCostMicroCents int64

+ TypeBreakdown map[string]*NotificationTypeCostStats

+ UpdatedAt time.Time

+ UserBreakdown map[string]*NotificationUserCostStats

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (NotificationCostAggregation) TableName() string

+ func (n *NotificationCostAggregation) BeforeCreate() error

+ func (n *NotificationCostAggregation) BeforeUpdate() error

+ func (n *NotificationCostAggregation) CalculateDollarAmounts()

+ func (n *NotificationCostAggregation) CalculateRates()

+ func (n *NotificationCostAggregation) GetPK() string

+ func (n *NotificationCostAggregation) GetSK() string

+ func (n *NotificationCostAggregation) UpdateKeys() error

+ type NotificationCostTracking struct

+ Channel string

+ CreatedAt time.Time

+ DeliveryMethod string

+ DeliveryTimeMs int64

+ DynamoDBCostDollars float64

+ DynamoDBCostMicroCents int64

+ ErrorMessage string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ ID string

+ LambdaCostDollars float64

+ LambdaCostMicroCents int64

+ LambdaFunctionName string

+ LambdaRequestID string

+ NotificationID string

+ NotificationType string

+ PK string

+ ProcessingTimeMs int64

+ Properties map[string]interface{}

+ PushCostDollars float64

+ PushCostMicroCents int64

+ RequestID string

+ ResponseCode int

+ ResponseSize int64

+ RetryCount int

+ SK string

+ ServiceName string

+ Success bool

+ Tags map[string]string

+ Timestamp time.Time

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalTimeMs int64

+ UpdatedAt time.Time

+ UserID string

+ Username string

+ WebSocketCostDollars float64

+ WebSocketCostMicroCents int64

+ func (NotificationCostTracking) TableName() string

+ func (n *NotificationCostTracking) AddCost(method string, costMicroCents int64)

+ func (n *NotificationCostTracking) BeforeCreate() error

+ func (n *NotificationCostTracking) BeforeUpdate() error

+ func (n *NotificationCostTracking) CalculateDollarAmounts()

+ func (n *NotificationCostTracking) GetPK() string

+ func (n *NotificationCostTracking) GetSK() string

+ func (n *NotificationCostTracking) SetError(errorMsg string)

+ func (n *NotificationCostTracking) SetSuccess()

+ func (n *NotificationCostTracking) UpdateKeys() error

+ type NotificationCostTrackingBuilder struct

+ func NewNotificationCostTrackingBuilder() *NotificationCostTrackingBuilder

+ func (NotificationCostTrackingBuilder) TableName() string

+ func (b *NotificationCostTrackingBuilder) Build() *NotificationCostTracking

+ func (b *NotificationCostTrackingBuilder) WithContext(requestID, serviceName, functionName, lambdaRequestID string) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithCosts(pushCost, websocketCost, lambdaCost, dynamodbCost int64) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithDelivery(method, channel string, success bool, retryCount int) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithError(errorMsg string) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithNotification(notificationID, userID, username, notificationType string) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithPerformance(processingTimeMs, deliveryTimeMs int64, responseCode int, responseSize int64) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithProperty(key string, value interface{}) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithTag(key, value string) *NotificationCostTrackingBuilder

+ func (b *NotificationCostTrackingBuilder) WithTimestamp(timestamp time.Time) *NotificationCostTrackingBuilder

+ type NotificationDelivery struct

+ AttemptCount int

+ CreatedAt time.Time

+ DeliveryMethod string

+ Error string

+ LastAttempt time.Time

+ NotificationID string

+ PK string

+ SK string

+ SentAt time.Time

+ Status string

+ TTL int64

+ UpdatedAt time.Time

+ func NewNotificationDelivery(notificationID, method string) *NotificationDelivery

+ func (NotificationDelivery) TableName() string

+ func (n *NotificationDelivery) BeforeCreate() error

+ func (n *NotificationDelivery) BeforeUpdate() error

+ func (n *NotificationDelivery) CanRetry() bool

+ func (n *NotificationDelivery) IncrementAttempt()

+ func (n *NotificationDelivery) MarkFailed(errorMsg string)

+ func (n *NotificationDelivery) MarkPending()

+ func (n *NotificationDelivery) MarkSent()

+ func (n *NotificationDelivery) UpdateKeys()

+ func (n *NotificationDelivery) Validate() error

+ type NotificationFilter struct

+ AccountID string

+ ExcludeTypes []string

+ Limit int

+ MaxID string

+ MinID string

+ SinceID string

+ Types []string

+ func (NotificationFilter) TableName() string

+ type NotificationLegacy struct

+ AccountID string

+ CreatedAt int64

+ ID string

+ PK string

+ Read bool

+ SK string

+ StatusID string

+ TTL int64

+ Type string

+ Username string

+ func NewNotificationLegacy(username, notificationType, accountID string) *NotificationLegacy

+ func (NotificationLegacy) TableName() string

+ func (n *NotificationLegacy) SetPrimaryKey(username string)

+ func (n *NotificationLegacy) SetSortKey(timestamp int64, id string)

+ func (n *NotificationLegacy) UpdateKeys() error

+ type NotificationPreferences struct

+ DigestEmail bool

+ EmailEnabled bool

+ FavoriteEnabled bool

+ FavoriteNotifications bool

+ FollowEnabled bool

+ FollowNotifications bool

+ MentionEnabled bool

+ MentionNotifications bool

+ NewFollowerNotifications bool

+ PK string

+ PollEnabled bool

+ PollNotifications bool

+ PushEnabled bool

+ ReblogEnabled bool

+ ReblogNotifications bool

+ SK string

+ UpdatedAt time.Time

+ Username string

+ func (NotificationPreferences) TableName() string

+ func (n *NotificationPreferences) BeforeCreate() error

+ func (n *NotificationPreferences) BeforeUpdate() error

+ func (n *NotificationPreferences) UpdateKeys()

+ type NotificationTypeCostStats struct

+ AverageCostDollars float64

+ AverageCostMicroCents int64

+ Count int64

+ FailedDeliveries int64

+ SuccessRate float64

+ SuccessfulDeliveries int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ Type string

+ func (NotificationTypeCostStats) TableName() string

+ type NotificationUserCostStats struct

+ AverageCostDollars float64

+ AverageCostMicroCents int64

+ Count int64

+ FailedDeliveries int64

+ SuccessRate float64

+ SuccessfulDeliveries int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ Username string

+ func (NotificationUserCostStats) TableName() string

+ type NumericIDMapping struct

+ ActorID string

+ CreatedAt time.Time

+ NumericID string

+ PK string

+ SK string

+ Type string

+ Username string

+ func (NumericIDMapping) TableName() string

+ func (n *NumericIDMapping) BeforeCreate() error

+ type OAuthApp struct

+ Active bool

+ ClientID string

+ ClientSecret string

+ CreatedAt time.Time

+ CreatedBy string

+ Description string

+ GSI1PK string

+ GSI1SK string

+ Name string

+ PK string

+ RedirectURIs []string

+ SK string

+ Scopes []string

+ UpdatedAt time.Time

+ Website string

+ func (OAuthApp) TableName() string

+ func (o *OAuthApp) HasScope(scope string) bool

+ func (o *OAuthApp) IsValidRedirectURI(uri string) bool

+ func (o *OAuthApp) UpdateKeys()

+ type OAuthAuthSession struct

+ AuthorizedAt *time.Time

+ CSRFToken string

+ ClientID string

+ CodeChallenge string

+ CodeChallengeMethod string

+ CreatedAt time.Time

+ DeviceID string

+ ExpiresAt int64

+ FlowData map[string]interface{}

+ FlowStep string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IPAddress string

+ IsAuthorized bool

+ IsSecure bool

+ LastUsedAt time.Time

+ PK string

+ RedirectURI string

+ ReturnURL string

+ SK string

+ Scopes []string

+ SessionID string

+ SessionNonce string

+ State string

+ UpdatedAt time.Time

+ UserAgent string

+ Username string

+ Version int

+ func (OAuthAuthSession) TableName() string

+ func (o *OAuthAuthSession) Authorize()

+ func (o *OAuthAuthSession) BeforeCreate() error

+ func (o *OAuthAuthSession) BeforeUpdate() error

+ func (o *OAuthAuthSession) CanAuthorize() bool

+ func (o *OAuthAuthSession) GetContext(key string) (interface{}, bool)

+ func (o *OAuthAuthSession) GetPK() string

+ func (o *OAuthAuthSession) GetSK() string

+ func (o *OAuthAuthSession) IsExpired() bool

+ func (o *OAuthAuthSession) IsValid() bool

+ func (o *OAuthAuthSession) RemainingTime() time.Duration

+ func (o *OAuthAuthSession) SetContext(key string, value interface{})

+ func (o *OAuthAuthSession) SetFlowStep(step string, data map[string]interface{})

+ func (o *OAuthAuthSession) SetUser(username string)

+ func (o *OAuthAuthSession) Touch()

+ func (o *OAuthAuthSession) UpdateKeys() error

+ func (o *OAuthAuthSession) Validate() error

+ type OAuthClient struct

+ ClientID string

+ ClientSecret string

+ Confidential bool

+ CreatedAt time.Time

+ Description string

+ GSI1PK *string

+ GSI1SK *string

+ GrantTypes []string

+ ID string

+ Name string

+ OAuthClientsPK string

+ OAuthClientsSK string

+ OwnerID string

+ PK string

+ RedirectURIs []string

+ SK string

+ Scopes []string

+ UpdatedAt time.Time

+ Website string

+ func (OAuthClient) TableName() string

+ func (o *OAuthClient) BeforeCreate() error

+ func (o *OAuthClient) BeforeUpdate() error

+ func (o *OAuthClient) GetPK() string

+ func (o *OAuthClient) GetSK() string

+ func (o *OAuthClient) UpdateKeys() error

+ type OAuthState struct

+ ClientID string

+ CodeChallenge string

+ CodeChallengeMethod string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ PK string

+ Provider string

+ RedirectURI string

+ SK string

+ Scopes []string

+ State string

+ TTL int64

+ Username string

+ func (OAuthState) TableName() string

+ func (o *OAuthState) GetPK() string

+ func (o *OAuthState) GetSK() string

+ func (o *OAuthState) UpdateKeys() error

+ type Object struct

+ AttachmentJSON string

+ AttributedTo string

+ BCC []string

+ BTo []string

+ CC []string

+ Content string

+ ContextJSON string

+ ConversationID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI6PK string

+ GSI6SK string

+ ID string

+ InReplyTo *string

+ IsRemote bool

+ Name string

+ PK string

+ Published time.Time

+ SK string

+ Sensitive bool

+ Summary string

+ TagJSON string

+ To []string

+ Type string

+ URL string

+ Updated time.Time

+ Visibility string

+ func NewObject(id, objectType, actorID string) *Object

+ func (Object) TableName() string

+ func (o *Object) GetPK() string

+ func (o *Object) GetSK() string

+ func (o *Object) UpdateGSIKeys()

+ func (o *Object) UpdateKeys() error

+ type OptimizationDecision struct

+ Decision string

+ MessageSize int64

+ PK string

+ RouteIDs []string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ func (OptimizationDecision) TableName() string

+ func (o *OptimizationDecision) GetPK() string

+ func (o *OptimizationDecision) GetSK() string

+ func (o *OptimizationDecision) UpdateKeys() error

+ type OutboxItem struct

+ Activity *activitypub.Activity

+ ActivityID string

+ ActorID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ PK string

+ Public bool

+ SK string

+ Timestamp time.Time

+ func (OutboxItem) TableName() string

+ func (o *OutboxItem) UpdateKeys()

+ type PasswordReset struct

+ CreatedAt time.Time

+ Email string

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ TTL int64

+ Token string

+ Used bool

+ UsedAt time.Time

+ Username string

+ func (PasswordReset) TableName() string

+ func (r *PasswordReset) BeforeCreate() error

+ func (r *PasswordReset) GetPK() string

+ func (r *PasswordReset) GetSK() string

+ func (r *PasswordReset) UpdateKeys() error

+ type PatternCache struct

+ CacheHits int64

+ CompilationHash string

+ CompileTime float64

+ CompiledData map[string]interface{}

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ LastUsed time.Time

+ PK string

+ PatternID string

+ PatternType string

+ SK string

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ func (PatternCache) TableName() string

+ func (c *PatternCache) GetPK() string

+ func (c *PatternCache) GetSK() string

+ func (c *PatternCache) UpdateKeys() error

+ type PatternFeedback struct

+ Confidence float64

+ ContentID string

+ ContentType string

+ FeedbackID string

+ Notes string

+ PK string

+ PatternID string

+ PatternType string

+ SK string

+ SubmittedAt time.Time

+ SubmittedBy string

+ TTL int64

+ WasFalsePositive bool

+ WasMatch bool

+ func NewPatternFeedback(patternID, contentID, submittedBy string) *PatternFeedback

+ func (PatternFeedback) TableName() string

+ func (p *PatternFeedback) GetFeedbackType() string

+ func (p *PatternFeedback) IsCorrect() bool

+ func (p *PatternFeedback) UpdateKeys()

+ type PatternPerformanceMetric struct

+ AverageMatchTime float64

+ CPUTime float64

+ CreatedAt time.Time

+ Date string

+ F1Score float64

+ FalsePositives int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ Hour int

+ MatchAttempts int64

+ MaxMatchTime float64

+ MemoryUsage int64

+ MinMatchTime float64

+ PK string

+ PatternID string

+ PatternType string

+ Precision float64

+ Recall float64

+ SK string

+ SuccessfulMatches int64

+ TTL int64

+ TotalMatchTime float64

+ TruePositives int64

+ Type string

+ UpdatedAt time.Time

+ func (PatternPerformanceMetric) TableName() string

+ func (m *PatternPerformanceMetric) CalculateQualityMetrics()

+ func (m *PatternPerformanceMetric) GetPK() string

+ func (m *PatternPerformanceMetric) GetSK() string

+ func (m *PatternPerformanceMetric) UpdateKeys() error

+ type PatternStats struct

+ HitCount int64

+ LastHit time.Time

+ PatternID string

+ PatternName string

+ func (PatternStats) TableName() string

+ type PatternTestResult struct

+ ActualResults []string

+ CreatedAt time.Time

+ Environment string

+ Errors []string

+ ExecutionTime float64

+ ExpectedResults []string

+ GSI1PK string

+ GSI1SK string

+ MemoryUsage int64

+ PK string

+ Passed bool

+ PatternID string

+ PatternType string

+ Results map[string]interface{}

+ RunAt time.Time

+ RunBy string

+ SK string

+ Score float64

+ TTL int64

+ TestData []string

+ TestDescription string

+ TestID string

+ TestParameters map[string]interface{}

+ TestType string

+ TestVersion string

+ Type string

+ func (PatternTestResult) TableName() string

+ func (t *PatternTestResult) GetPK() string

+ func (t *PatternTestResult) GetSK() string

+ func (t *PatternTestResult) GetSecurityScore() float64

+ func (t *PatternTestResult) IsSecurityTest() bool

+ func (t *PatternTestResult) UpdateKeys() error

+ type Poll struct

+ CreatedAt time.Time

+ CreatedBy string

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ HideTotals bool

+ ID string

+ Multiple bool

+ Options []string

+ PK string

+ SK string

+ StatusID string

+ TTL int64

+ UpdatedAt time.Time

+ VotersCount int

+ Votes map[string][]int

+ VotesCount int

+ func (Poll) TableName() string

+ func (p *Poll) GetPK() string

+ func (p *Poll) GetSK() string

+ func (p *Poll) UpdateKeys() error

+ type PollVote struct

+ Choices []int

+ PK string

+ SK string

+ VotedAt time.Time

+ VoterID string

+ func (PollVote) TableName() string

+ func (v *PollVote) GetPK() string

+ func (v *PollVote) GetSK() string

+ func (v *PollVote) SetPollID(pollID string)

+ func (v *PollVote) UpdateKeys() error

+ type PopularQueryCounter struct

+ AvgResults float64

+ Count int64

+ Date string

+ FirstQueried time.Time

+ GSI8PK string

+ GSI8SK string

+ LastQueried time.Time

+ PK string

+ Query string

+ QueryHash string

+ SK string

+ TTL int64

+ TimeBucket string

+ UpdatedAt time.Time

+ UserCount int64

+ func (PopularQueryCounter) TableName() string

+ func (p *PopularQueryCounter) GetPK() string

+ func (p *PopularQueryCounter) GetSK() string

+ func (p *PopularQueryCounter) UpdateKeys() error

+ type ProviderAccount struct

+ AccessToken string

+ AvatarURL string

+ CreatedAt time.Time

+ DisplayName string

+ Email string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IsActive bool

+ IsPrimary bool

+ LastUsedAt *time.Time

+ PK string

+ Provider string

+ ProviderID string

+ ProviderName string

+ RefreshToken string

+ SK string

+ TokenExpiry time.Time

+ UpdatedAt time.Time

+ UserID string

+ Username string

+ Version int

+ func (ProviderAccount) TableName() string

+ func (pa *ProviderAccount) BeforeCreate() error

+ func (pa *ProviderAccount) BeforeUpdate() error

+ func (pa *ProviderAccount) ClearPrimary()

+ func (pa *ProviderAccount) GetDisplayName() string

+ func (pa *ProviderAccount) HasValidToken() bool

+ func (pa *ProviderAccount) IsTokenExpired() bool

+ func (pa *ProviderAccount) MarkUsed()

+ func (pa *ProviderAccount) NeedsRefresh() bool

+ func (pa *ProviderAccount) SetPrimary()

+ func (pa *ProviderAccount) Validate() error

+ type PublicKeyCache struct

+ ActorURL string

+ Algorithm string

+ FailureCount int

+ FetchedAt time.Time

+ KeyID string

+ LastUsed time.Time

+ PK string

+ PublicKeyPEM string

+ SK string

+ SuccessCount int

+ TTL int64

+ func NewPublicKeyCache(actorURL, keyID, publicKeyPEM, algorithm string) *PublicKeyCache

+ func (PublicKeyCache) TableName() string

+ func (p *PublicKeyCache) ExtendTTL(duration time.Duration)

+ func (p *PublicKeyCache) GetPK() string

+ func (p *PublicKeyCache) GetPublicKeyPEM() []byte

+ func (p *PublicKeyCache) GetSK() string

+ func (p *PublicKeyCache) IsValid() bool

+ func (p *PublicKeyCache) RecordFailure()

+ func (p *PublicKeyCache) RecordSuccess()

+ func (p *PublicKeyCache) ShouldRefresh() bool

+ func (p *PublicKeyCache) UpdateKeys() error

+ type Publication struct

+ ActorID string

+ BannerURL string

+ CreatedAt time.Time

+ CustomDomain string

+ Description string

+ ID string

+ LogoURL string

+ Name string

+ PK string

+ SK string

+ Slug string

+ Tagline string

+ Theme string

+ UpdatedAt time.Time

+ func (Publication) TableName() string

+ func (p *Publication) GetPK() string

+ func (p *Publication) GetSK() string

+ func (p *Publication) UpdateKeys() error

+ type PublicationMember struct

+ Bio string

+ CreatedAt time.Time

+ DisplayName string

+ GSI1PK string

+ GSI1SK string

+ JoinedAt time.Time

+ PK string

+ PublicationID string

+ Role string

+ SK string

+ UpdatedAt time.Time

+ UserID string

+ func (PublicationMember) TableName() string

+ func (pm *PublicationMember) GetPK() string

+ func (pm *PublicationMember) GetSK() string

+ func (pm *PublicationMember) UpdateKeys() error

+ type PushSubscription struct

+ Alerts PushSubscriptionAlerts

+ Auth string

+ CreatedAt time.Time

+ Endpoint string

+ GSI1PK string

+ GSI1SK string

+ ID string

+ LastUsed time.Time

+ P256dh string

+ PK string

+ Policy string

+ SK string

+ UpdatedAt time.Time

+ UserAgent string

+ Username string

+ func (PushSubscription) TableName() string

+ func (p *PushSubscription) BeforeCreate() error

+ func (p *PushSubscription) BeforeUpdate() error

+ func (p *PushSubscription) GetPK() string

+ func (p *PushSubscription) GetSK() string

+ func (p *PushSubscription) UpdateKeys() error

+ func (p *PushSubscription) UpdateLastUsed()

+ func (p *PushSubscription) Validate() error

+ type PushSubscriptionAlerts struct

+ AdminReport bool

+ AdminSignUp bool

+ Favourite bool

+ Follow bool

+ FollowRequest bool

+ Mention bool

+ Poll bool

+ Reblog bool

+ Status bool

+ Update bool

+ func (PushSubscriptionAlerts) TableName() string

+ type QualityChange struct

+ PK string

+ Quality string

+ SK string

+ SessionID string

+ TTL int64

+ Timestamp time.Time

+ func (QualityChange) TableName() string

+ func (q *QualityChange) GetPK() string

+ func (q *QualityChange) GetSK() string

+ func (q *QualityChange) UpdateKeys() error

+ type QualityCodecInfo struct

+ AudioCodec string

+ Bandwidth int

+ Height int

+ VideoCodec string

+ Width int

+ func (QualityCodecInfo) TableName() string

+ type QualityMetric struct

+ AverageLatencyMs int64

+ BitrateUtilization float64

+ BufferingRate float64

+ ErrorRate float64

+ Quality string

+ StartupTimeMs int64

+ ViewerCount int64

+ ViewerPercentage float64

+ func (QualityMetric) TableName() string

+ type QueryCacheEntry struct

+ CacheKey string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ PK string

+ SK string

+ Size int

+ TTL int64

+ UpdatedAt time.Time

+ Value string

+ func (QueryCacheEntry) TableName() string

+ func (q *QueryCacheEntry) GetPK() string

+ func (q *QueryCacheEntry) GetSK() string

+ func (q *QueryCacheEntry) IsExpired() bool

+ func (q *QueryCacheEntry) UpdateKeys() error

+ type QuotePermissions struct

+ AllowFollowers bool

+ AllowMentioned bool

+ AllowPublic bool

+ BlockList []string

+ PK string

+ SK string

+ Username string

+ func (QuotePermissions) TableName() string

+ func (q *QuotePermissions) AddToBlockList(username string)

+ func (q *QuotePermissions) ApplyVisibilityDefaults(visibility string)

+ func (q *QuotePermissions) GetPK() string

+ func (q *QuotePermissions) GetSK() string

+ func (q *QuotePermissions) IsAllowed(quoterUsername string, isFollower bool, isMentioned bool) bool

+ func (q *QuotePermissions) RemoveFromBlockList(username string)

+ func (q *QuotePermissions) SetDefaults()

+ func (q *QuotePermissions) UpdateKeys() error

+ type QuoteRelationship struct

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ PK string

+ QuoterID string

+ QuoterNoteID string

+ SK string

+ TargetAuthorID string

+ TargetNoteID string

+ Timestamp time.Time

+ Withdrawn bool

+ WithdrawnAt *time.Time

+ func (QuoteRelationship) TableName() string

+ func (q *QuoteRelationship) GenerateID()

+ func (q *QuoteRelationship) GetPK() string

+ func (q *QuoteRelationship) GetSK() string

+ func (q *QuoteRelationship) IsActive() bool

+ func (q *QuoteRelationship) UpdateKeys() error

+ func (q *QuoteRelationship) Withdraw()

+ type RateLimitLockout struct

+ PK string

+ SK string

+ TTL int64

+ Type string

+ UnlockTime time.Time

+ func NewRateLimitLockout(identifier string, unlockTime time.Time) *RateLimitLockout

+ func (RateLimitLockout) TableName() string

+ func (rll *RateLimitLockout) GetPK() string

+ func (rll *RateLimitLockout) GetSK() string

+ func (rll *RateLimitLockout) UpdateKeys() error

+ type RateLimitViolation struct

+ Domain string

+ Endpoint string

+ PK string

+ PenaltyMinutes int

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ UserID string

+ ViolationType string

+ func NewRateLimitViolation(userID, domain, endpoint, violationType string, penaltyMinutes int) *RateLimitViolation

+ func (RateLimitViolation) TableName() string

+ func (rlv *RateLimitViolation) GetPK() string

+ func (rlv *RateLimitViolation) GetSK() string

+ func (rlv *RateLimitViolation) UpdateKeys() error

+ type Reaction struct

+ Count int

+ Me bool

+ Name string

+ StaticURL string

+ URL string

+ func (Reaction) TableName() string

+ type RealtimeStats struct

+ AllowRate float64

+ AnalysisRate float64

+ AvgResponseTime time.Duration

+ FlagRate float64

+ P95ResponseTime time.Duration

+ QuarantineRate float64

+ RemoveRate float64

+ TotalAnalyzed int64

+ Uptime time.Duration

+ func (RealtimeStats) TableName() string

+ type ReconnectionAttempt struct

+ AttemptedAt time.Time

+ Domain string

+ ErrorMessage string

+ Method string

+ PK string

+ SK string

+ Success bool

+ UserID string

+ func (ReconnectionAttempt) TableName() string

+ func (r *ReconnectionAttempt) UpdateKeys()

+ type RecoveryCode struct

+ CodeHash string

+ CreatedAt time.Time

+ PK string

+ Position int

+ SK string

+ UsedAt *time.Time

+ Username string

+ func (RecoveryCode) TableName() string

+ func (c *RecoveryCode) GetPK() string

+ func (c *RecoveryCode) GetSK() string

+ func (c *RecoveryCode) UpdateKeys() error

+ type RecoveryRequest struct

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ InitiatedAt time.Time

+ PK string

+ ReceivedVotes map[string]bool

+ RecoveryToken string

+ RequiredVotes int

+ SK string

+ Status string

+ TTL int64

+ Username string

+ func (RecoveryRequest) TableName() string

+ func (r *RecoveryRequest) GetPK() string

+ func (r *RecoveryRequest) GetSK() string

+ func (r *RecoveryRequest) UpdateKeys() error

+ type RecoveryToken struct

+ CreatedAt time.Time

+ Data map[string]any

+ PK string

+ SK string

+ TTL int64

+ func (RecoveryToken) TableName() string

+ func (t *RecoveryToken) GetPK() string

+ func (t *RecoveryToken) GetSK() string

+ func (t *RecoveryToken) UpdateKeys() error

+ type RefreshToken struct

+ ClientID string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ PK string

+ SK string

+ Scopes []string

+ TTL int64

+ Token string

+ Username string

+ func (RefreshToken) TableName() string

+ func (r *RefreshToken) BeforeCreate() error

+ func (r *RefreshToken) GetPK() string

+ func (r *RefreshToken) GetSK() string

+ func (r *RefreshToken) UpdateKeys() error

+ type RelationshipRecord struct

+ ActivityID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ Languages []string

+ Note string

+ Notifying bool

+ PK string

+ SK string

+ ShowingReblogs bool

+ State string

+ UpdatedAt time.Time

+ func NewRelationshipRecord(followerUsername, followingUsername, activityID string) *RelationshipRecord

+ func (RelationshipRecord) TableName() string

+ func (r *RelationshipRecord) Accept()

+ func (r *RelationshipRecord) BeforeCreate() error

+ func (r *RelationshipRecord) BeforeUpdate() error

+ func (r *RelationshipRecord) ExtractFollowerFromGSI() string

+ func (r *RelationshipRecord) ExtractFollowerUsername() string

+ func (r *RelationshipRecord) ExtractFollowingUsername() string

+ func (r *RelationshipRecord) GetPK() string

+ func (r *RelationshipRecord) GetSK() string

+ func (r *RelationshipRecord) Reject()

+ func (r *RelationshipRecord) UpdateKeys() error

+ type RelationshipState string

+ const StateActive

+ const StateArchived

+ const StateDormant

+ const StateExpired

+ const StateIdle

+ type Relay struct

+ Active bool

+ CreatedAt time.Time

+ Domain string

+ ErrorCount int

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ InboxURL string

+ LastSeenAt time.Time

+ PK string

+ SK string

+ Status string

+ TTL int64

+ URL string

+ func (Relay) TableName() string

+ func (r *Relay) GetPK() string

+ func (r *Relay) GetSK() string

+ func (r *Relay) UpdateKeys() error

+ type RelayBudget struct

+ BudgetExceeded bool

+ CreatedAt time.Time

+ CriticalAlertSent bool

+ CriticalThresholdPercent float64

+ CurrentUsageMicroCents int64

+ CurrentUsagePercent float64

+ Domain string

+ LastResetAt time.Time

+ LimitMicroCents int64

+ NotifyAdmin bool

+ PK string

+ PauseRelay bool

+ Period string

+ ReduceFrequency bool

+ RelayURL string

+ SK string

+ TTL int64

+ UpdatedAt time.Time

+ WarningAlertSent bool

+ WarningThresholdPercent float64

+ func (RelayBudget) TableName() string

+ func (rb *RelayBudget) BeforeCreate() error

+ func (rb *RelayBudget) BeforeUpdate() error

+ func (rb *RelayBudget) UpdateKeys()

+ type RelayCost struct

+ ActivityType string

+ DataTransferBytes int64

+ DataTransferCost int64

+ Direction string

+ Domain string

+ DynamoDBCost int64

+ DynamoDBOperations int64

+ ErrorMessage string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HTTPRequestCost int64

+ HTTPRequestCount int64

+ LambdaCost int64

+ LambdaDurationMs int64

+ OperationType string

+ PK string

+ RelayURL string

+ RequestID string

+ ResponseTimeMs int64

+ RetryCount int

+ SK string

+ SQSCost int64

+ SQSMessages int64

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ func (RelayCost) TableName() string

+ func (rc *RelayCost) BeforeCreate() error

+ func (rc *RelayCost) UpdateKeys()

+ type RelayInfo struct

+ Active bool

+ CreatedAt time.Time

+ Domain string

+ ErrorCount int

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ InboxURL string

+ LastSeenAt time.Time

+ PK string

+ SK string

+ Status string

+ TTL int64

+ URL string

+ func (RelayInfo) TableName() string

+ func (r *RelayInfo) IsExpired() bool

+ func (r *RelayInfo) SetError()

+ func (r *RelayInfo) SetSuccess()

+ func (r *RelayInfo) ShouldRetry() bool

+ func (r *RelayInfo) UpdateKeys()

+ type RelayMetrics struct

+ AverageResponseTimeMs float64

+ AverageRetryCount float64

+ BudgetExceeded bool

+ BudgetLimitMicroCents int64

+ BudgetUsedPercent float64

+ CostPerMB float64

+ CostPerOperation float64

+ CostPerSuccessfulOp float64

+ CreatedAt time.Time

+ Domain string

+ FailedOperations int64

+ GSI1PK string

+ GSI1SK string

+ OperationBreakdown map[string]*RelayOperationStats

+ PK string

+ Period string

+ RelayURL string

+ SK string

+ SuccessRate float64

+ SuccessfulOperations int64

+ TTL int64

+ TotalCostMicroCents int64

+ TotalDataTransferBytes int64

+ TotalDataTransferCost int64

+ TotalDynamoDBCost int64

+ TotalDynamoDBOps int64

+ TotalHTTPRequestCost int64

+ TotalHTTPRequests int64

+ TotalLambdaCost int64

+ TotalLambdaDurationMs int64

+ TotalOperations int64

+ TotalSQSCost int64

+ TotalSQSMessages int64

+ UpdatedAt time.Time

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (RelayMetrics) TableName() string

+ func (rm *RelayMetrics) BeforeCreate() error

+ func (rm *RelayMetrics) BeforeUpdate() error

+ func (rm *RelayMetrics) UpdateKeys()

+ type RelayOperationStats struct

+ AverageResponseTime float64

+ Count int64

+ FailureCount int64

+ OperationType string

+ SuccessCount int64

+ SuccessRate float64

+ TotalCostMicroCents int64

+ func (RelayOperationStats) TableName() string

+ type RemoteActor struct

+ Actor *activitypub.Actor

+ CachedAt time.Time

+ Domain string

+ ExpiresAt time.Time

+ Handle string

+ PK string

+ SK string

+ TTL int64

+ UpdatedAt time.Time

+ func (RemoteActor) TableName() string

+ func (r *RemoteActor) UpdateKeys()

+ type ReplySyncRecord struct

+ CreatedAt time.Time

+ FailedReplies int

+ FetchedReplies int

+ LastError string

+ NextRetryAt *time.Time

+ PK string

+ RetryCount int

+ SK string

+ StatusID string

+ SyncAttempt time.Time

+ SyncResult string

+ TTL int64

+ TotalReplies int

+ UpdatedAt time.Time

+ func NewReplySyncRecord(statusID string) *ReplySyncRecord

+ func (ReplySyncRecord) TableName() string

+ func (r *ReplySyncRecord) BeforeCreate() error

+ func (r *ReplySyncRecord) BeforeUpdate() error

+ func (r *ReplySyncRecord) IsExpired() bool

+ func (r *ReplySyncRecord) MarkFailed(errorMsg string)

+ func (r *ReplySyncRecord) MarkPartial(fetched, failed int)

+ func (r *ReplySyncRecord) MarkSuccess(fetched int)

+ func (r *ReplySyncRecord) ShouldRetry() bool

+ func (r *ReplySyncRecord) UpdateKeys()

+ type Report struct

+ ActionTaken string

+ ActionTakenAt *time.Time

+ AssignedTo string

+ Category string

+ Comment string

+ CreatedAt time.Time

+ Forwarded bool

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ ID string

+ ModerationEventID string

+ ModeratorID string

+ PK string

+ ReporterID string

+ RuleIDs []int

+ SK string

+ Status string

+ StatusIDs []string

+ TTL int64

+ TargetAccountID string

+ UpdatedAt time.Time

+ func (Report) TableName() string

+ func (r *Report) UpdateKeys()

+ type ReportStats struct

+ FalseReports int

+ LastFalseReportAt *time.Time

+ LastReportAt *time.Time

+ PK string

+ ResolvedReports int

+ SK string

+ TotalReports int

+ func (ReportStats) TableName() string

+ func (rs *ReportStats) UpdateKeys(username string)

+ type Reputation struct

+ CalculatedAt string

+ PK string

+ ReputationData string

+ SK string

+ TTL int64

+ TotalScore int

+ func (Reputation) TableName() string

+ func (r *Reputation) ToStorageReputation() (interface{}, error)

+ func (r *Reputation) UpdateKeys(actorID string, reputation interface{}) error

+ type RetryPolicy struct

+ BackoffFactor float64

+ InitialBackoff time.Duration

+ MaxBackoff time.Duration

+ MaxRetries int

+ func (RetryPolicy) TableName() string

+ type ReviewerStats struct

+ AccuracyRate float64

+ AccurateReviews int

+ BadgesEarned []string

+ ConsecutiveAccurate int

+ DisagreementRate float64

+ JoinedAt time.Time

+ LastReviewAt time.Time

+ LastTrainingCompleted *time.Time

+ MaxStreak int

+ PK string

+ RecentAccuracy float64

+ ResponseTimeAvg float64

+ ReviewerID string

+ ReviewsByCategory map[string]int

+ SK string

+ SpecializationScores map[string]float64

+ TotalReviews int

+ TrustScore float64

+ UpdatedAt time.Time

+ func NewReviewerStats(reviewerID string) *ReviewerStats

+ func (ReviewerStats) TableName() string

+ func (r *ReviewerStats) CalculateAccuracyRate()

+ func (r *ReviewerStats) CalculateTrustScore()

+ func (r *ReviewerStats) EarnBadge(badge string) bool

+ func (r *ReviewerStats) GetSpecialization() (category string, score float64)

+ func (r *ReviewerStats) IsExperienced() bool

+ func (r *ReviewerStats) IsTrusted() bool

+ func (r *ReviewerStats) NeedsTraining() bool

+ func (r *ReviewerStats) RecordReview(category string, wasAccurate bool, responseTime float64)

+ func (r *ReviewerStats) UpdateKeys()

+ func (r *ReviewerStats) UpdateSpecializationScore(category string, recentAccuracy float64)

+ type Revision struct

+ ChangeSummary string

+ ChangeType string

+ ChangedBy string

+ Content string

+ ContentHash string

+ CreatedAt time.Time

+ ID string

+ MetadataJSON string

+ ObjectID string

+ PK string

+ SK string

+ UpdatedAt time.Time

+ Version int

+ func (Revision) TableName() string

+ func (r *Revision) GetPK() string

+ func (r *Revision) GetSK() string

+ func (r *Revision) UpdateKeys() error

+ type RouteDeliveryResult struct

+ BytesSent int64

+ Cost float64

+ Duration int64

+ ErrorMessage string

+ GSI1PK string

+ GSI1SK string

+ MessageID string

+ PK string

+ RouteID string

+ SK string

+ StatusCode int

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ func (RouteDeliveryResult) TableName() string

+ func (r *RouteDeliveryResult) GetPK() string

+ func (r *RouteDeliveryResult) GetSK() string

+ func (r *RouteDeliveryResult) UpdateKeys() error

+ type RouteMetricsWindow struct

+ AvgLatency int64

+ CircuitChanges int64

+ ErrorTypes string

+ FailureCount int64

+ LatencyHistogram string

+ MessageCount int64

+ PK string

+ RouteID string

+ SK string

+ SuccessCount int64

+ TTL int64

+ TotalBytes int64

+ TotalCost float64

+ WindowSize int64

+ WindowStart time.Time

+ func (RouteMetricsWindow) TableName() string

+ func (r *RouteMetricsWindow) GetPK() string

+ func (r *RouteMetricsWindow) GetSK() string

+ func (r *RouteMetricsWindow) UpdateKeys() error

+ type RouteRecommendation struct

+ Action string

+ Description string

+ Impact string

+ Priority string

+ Title string

+ Type string

+ func (RouteRecommendation) TableName() string

+ type ScheduledJobCategoryStats struct

+ AverageCostPerExecution float64

+ Category string

+ ExecutionCount int64

+ SuccessRate float64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ func (ScheduledJobCategoryStats) TableName() string

+ type ScheduledJobCostAggregation struct

+ AverageCostPerExecution float64

+ AverageExecutionTime float64

+ AverageLambdaMemoryUsedMB float64

+ CancelledExecutions int64

+ CostEfficiencyTrend float64

+ CostPerItemProcessed float64

+ CostPerSuccessfulExecution float64

+ CostPercentiles map[string]float64

+ CreatedAt time.Time

+ EnvironmentBreakdown map[string]*ScheduledJobEnvironmentStats

+ ExecutionTimePercentiles map[string]float64

+ ExpiresAt int64

+ FailedExecutions int64

+ JobCategoryBreakdown map[string]*ScheduledJobCategoryStats

+ JobName string

+ MedianExecutionTime float64

+ P95ExecutionTime float64

+ PK string

+ Period string

+ SK string

+ Schedule string

+ ScheduleBreakdown map[string]*ScheduledJobScheduleStats

+ SuccessRate float64

+ SuccessfulExecutions int64

+ TimeoutExecutions int64

+ TotalCascadingCostMicroCents int64

+ TotalCloudWatchCostMicroCents int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalDataTransferCostMicroCents int64

+ TotalDynamoDBCapacity float64

+ TotalDynamoDBCostMicroCents int64

+ TotalDynamoDBOperations int64

+ TotalExecutions int64

+ TotalExternalAPICostMicroCents int64

+ TotalItemsErrored int64

+ TotalItemsProcessed int64

+ TotalLambdaCostMicroCents int64

+ TotalLambdaDurationMs int64

+ TotalLambdaInvocations int64

+ TotalS3CostMicroCents int64

+ TotalSQSCostMicroCents int64

+ UpdatedAt time.Time

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (ScheduledJobCostAggregation) TableName() string

+ func (sjca *ScheduledJobCostAggregation) BeforeCreate() error

+ func (sjca *ScheduledJobCostAggregation) BeforeUpdate() error

+ func (sjca *ScheduledJobCostAggregation) GetPK() string

+ func (sjca *ScheduledJobCostAggregation) GetSK() string

+ func (sjca *ScheduledJobCostAggregation) UpdateKeys() error

+ func (sjca *ScheduledJobCostAggregation) Validate() error

+ type ScheduledJobCostRecord struct

+ ActualStartDelay int64

+ BatchSize int

+ CascadingCostMicroCents int64

+ CloudWatchCostMicroCents int64

+ CloudWatchLogs int64

+ CreatedAt time.Time

+ CronPattern string

+ DataTransferBytes int64

+ DataTransferCostMicroCents int64

+ DownstreamOperations int64

+ Duration int64

+ DynamoDBCostMicroCents int64

+ DynamoDBReadCapacity float64

+ DynamoDBReadOperations int64

+ DynamoDBWriteCapacity float64

+ DynamoDBWriteOperations int64

+ EndTime time.Time

+ Environment string

+ ErrorMessage string

+ ExpiresAt int64

+ ExternalAPICostMicroCents int64

+ ExternalAPIRequests int64

+ FunctionName string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ ItemsErrored int64

+ ItemsProcessed int64

+ ItemsSkipped int64

+ JobCategory string

+ JobName string

+ JobProperties map[string]interface{}

+ LambdaCostMicroCents int64

+ LambdaDurationMs int64

+ LambdaInvocations int64

+ LambdaMemoryUsedMB int

+ LambdaRequestCount int64

+ MaxRetries int

+ NextScheduledTime time.Time

+ PK string

+ PerformanceMetrics map[string]float64

+ Priority string

+ Region string

+ RequestID string

+ RetryCount int

+ S3CostMicroCents int64

+ S3Operations int64

+ SK string

+ SQSCostMicroCents int64

+ SQSMessages int64

+ Schedule string

+ ScheduledTime time.Time

+ StartTime time.Time

+ Status string

+ Success bool

+ Tags map[string]string

+ Timestamp time.Time

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TriggeredJobs []string

+ UpdatedAt time.Time

+ func (ScheduledJobCostRecord) TableName() string

+ func (sjcr *ScheduledJobCostRecord) AddTag(key, value string)

+ func (sjcr *ScheduledJobCostRecord) BeforeCreate() error

+ func (sjcr *ScheduledJobCostRecord) BeforeUpdate() error

+ func (sjcr *ScheduledJobCostRecord) GetJobProperty(key string) (interface{}, bool)

+ func (sjcr *ScheduledJobCostRecord) GetPK() string

+ func (sjcr *ScheduledJobCostRecord) GetPerformanceMetric(key string) (float64, bool)

+ func (sjcr *ScheduledJobCostRecord) GetSK() string

+ func (sjcr *ScheduledJobCostRecord) SetJobProperty(key string, value interface{})

+ func (sjcr *ScheduledJobCostRecord) SetPerformanceMetric(key string, value float64)

+ func (sjcr *ScheduledJobCostRecord) UpdateKeys() error

+ func (sjcr *ScheduledJobCostRecord) Validate() error

+ type ScheduledJobCostRecordBuilder struct

+ func NewScheduledJobCostRecordBuilder() *ScheduledJobCostRecordBuilder

+ func (ScheduledJobCostRecordBuilder) TableName() string

+ func (builder *ScheduledJobCostRecordBuilder) Build() *ScheduledJobCostRecord

+ func (builder *ScheduledJobCostRecordBuilder) ForJob(jobName, schedule string) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithCascadingCosts(triggeredJobs []string, cascadingCost int64, downstreamOps int64) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithCategory(category, priority string) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithContext(environment, region, functionName, requestID string) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithCosts(...) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithDynamoDBUsage(readOps, writeOps int64, readCapacity, writeCapacity float64) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithError(errorMessage string, retryCount, maxRetries int) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithItemsProcessed(processed, skipped, errored int64) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithJobProperty(key string, value interface{}) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithLambdaUsage(invocations, durationMs int64, memoryMB int) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithPerformanceMetric(key string, value float64) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithStatus(status string) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithTag(key, value string) *ScheduledJobCostRecordBuilder

+ func (builder *ScheduledJobCostRecordBuilder) WithTiming(scheduledTime, startTime, endTime time.Time) *ScheduledJobCostRecordBuilder

+ type ScheduledJobEnvironmentStats struct

+ AverageCostPerExecution float64

+ Environment string

+ ExecutionCount int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ func (ScheduledJobEnvironmentStats) TableName() string

+ type ScheduledJobScheduleStats struct

+ AverageCostPerExecution float64

+ AverageExecutionTime float64

+ ExecutionCount int64

+ Schedule string

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ func (ScheduledJobScheduleStats) TableName() string

+ type ScheduledStatus struct

+ ApplicationID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ InReplyToID string

+ Language string

+ MediaIDs []string

+ PK string

+ Poll map[string]any

+ Published bool

+ PublishedAt *time.Time

+ SK string

+ ScheduledAt time.Time

+ Sensitive bool

+ SpoilerText string

+ Status string

+ UpdatedAt time.Time

+ Username string

+ Visibility string

+ func (ScheduledStatus) TableName() string

+ func (s *ScheduledStatus) GetPK() string

+ func (s *ScheduledStatus) GetSK() string

+ func (s *ScheduledStatus) UpdateKeys() error

+ type SearchAnalytics struct

+ ClickedResult *string

+ PK string

+ Query string

+ ResultCount int

+ SK string

+ SearchTime int64

+ SearchType string

+ TTL int64

+ Timestamp time.Time

+ UserID *string

+ func (SearchAnalytics) TableName() string

+ func (s *SearchAnalytics) UpdateKeys()

+ type SearchBudget struct

+ BudgetExceeded bool

+ BudgetLimitMicros int64

+ CreatedAt time.Time

+ CurrentRequests int

+ CurrentSemanticRequests int

+ IndexingBudgetMicros int64

+ IndexingUsedMicros int64

+ LastResetTime time.Time

+ LastUsageTime time.Time

+ MaxRequestsPerHour int

+ MaxSemanticPerHour int

+ PK string

+ Period string

+ PeriodDate string

+ SK string

+ SearchBudgetMicros int64

+ SearchUsedMicros int64

+ SemanticBudgetMicros int64

+ SemanticUsedMicros int64

+ TTL int64

+ Type string

+ UpdatedAt time.Time

+ UsedBudgetMicros int64

+ UserID string

+ func (SearchBudget) TableName() string

+ func (sb *SearchBudget) CanMakeRequest(operationType string, estimatedCostMicros int64) bool

+ func (sb *SearchBudget) GetPK() string

+ func (sb *SearchBudget) GetSK() string

+ func (sb *SearchBudget) RecordUsage(operationType string, costMicros int64)

+ func (sb *SearchBudget) UpdateKeys() error

+ type SearchCache struct

+ CreatedAt time.Time

+ PK string

+ Query string

+ Results map[string]interface{}

+ SK string

+ TTL int64

+ func NewSearchCache(query string) *SearchCache

+ func (SearchCache) TableName() string

+ func (s *SearchCache) InvalidateCache(reason string)

+ func (s *SearchCache) IsValid() bool

+ func (s *SearchCache) UpdateKeys()

+ type SearchClickRate struct

+ ActorID string

+ ClickCount int

+ LastClicked time.Time

+ PK string

+ Query string

+ SK string

+ func (SearchClickRate) TableName() string

+ func (c *SearchClickRate) UpdateKeys()

+ type SearchCostAggregation struct

+ AggregationType string

+ AverageCostMicros int64

+ AverageResponseTimeMs int64

+ AverageResultCount int

+ BedrockCostMicros int64

+ CacheHitRate float64

+ Date string

+ DynamoCostMicros int64

+ EndTime time.Time

+ GeneratedAt time.Time

+ HashtagSearches int64

+ IndexingOperations int64

+ LambdaCostMicros int64

+ MedianResponseTimeMs int64

+ MetricName string

+ P95ResponseTimeMs int64

+ PK string

+ SK string

+ SemanticSearches int64

+ StartTime time.Time

+ SuggestionRequests int64

+ TTL int64

+ TextSearches int64

+ TotalCostMicros int64

+ TotalRequests int64

+ Type string

+ UserSearches int64

+ func (SearchCostAggregation) TableName() string

+ func (sca *SearchCostAggregation) GetPK() string

+ func (sca *SearchCostAggregation) GetSK() string

+ func (sca *SearchCostAggregation) UpdateKeys() error

+ type SearchCostTracking struct

+ BedrockCostMicros int64

+ BedrockRequests int

+ CacheHit bool

+ CostPerResult int64

+ Date string

+ DynamoCostMicros int64

+ DynamoQueries int

+ DynamoReads int64

+ DynamoWrites int64

+ EmbeddingDimension int

+ EmbeddingTokens int

+ EstimatedSavings int64

+ FilteringTimeMs int64

+ GSIQueries int

+ IndexLookupTimeMs int64

+ LambdaCostMicros int64

+ LambdaDurationMs int64

+ LambdaMemoryMB int64

+ OperationType string

+ PK string

+ Query string

+ QueryComplexity float64

+ QueryLength int

+ RankingTimeMs int64

+ RequestID string

+ ResponseTimeMs int64

+ ResultCount int

+ SK string

+ ScanOperations int

+ SearchType string

+ TTL int64

+ Timestamp time.Time

+ TotalCostMicros int64

+ Type string

+ UserID string

+ VectorComparisons int

+ func (SearchCostTracking) TableName() string

+ func (sct *SearchCostTracking) GetPK() string

+ func (sct *SearchCostTracking) GetSK() string

+ func (sct *SearchCostTracking) UpdateKeys() error

+ type SearchEmbedding struct

+ ContentID string

+ ContentType string

+ CreatedAt time.Time

+ Embedding []float32

+ Metadata map[string]string

+ PK string

+ SK string

+ Score float64

+ func (SearchEmbedding) TableName() string

+ func (s *SearchEmbedding) GetPK() string

+ func (s *SearchEmbedding) GetSK() string

+ func (s *SearchEmbedding) UpdateKeys() error

+ type SearchHistoryEntry struct

+ ClickedIDs []string

+ PK string

+ Query string

+ ResultCount int

+ SK string

+ SearchedAt time.Time

+ UserID string

+ func NewSearchHistoryEntry(userID, query string, resultCount int) *SearchHistoryEntry

+ func (SearchHistoryEntry) TableName() string

+ func (s *SearchHistoryEntry) AddClickedID(id string)

+ func (s *SearchHistoryEntry) GetClickRate() float64

+ func (s *SearchHistoryEntry) IsRecent(duration time.Duration) bool

+ func (s *SearchHistoryEntry) UpdateKeys()

+ type SearchQuery struct

+ PK string

+ Query string

+ ResultCount int

+ SK string

+ SearchedAt time.Time

+ TTL int64

+ UserID string

+ func (SearchQuery) TableName() string

+ func (s *SearchQuery) GetPK() string

+ func (s *SearchQuery) GetSK() string

+ func (s *SearchQuery) UpdateKeys() error

+ type SearchQueryStats struct

+ AverageCostMicros float64

+ AverageResponseTimeMs float64

+ AverageResults float64

+ CacheHitCount int64

+ CacheHitRate float64

+ CostEfficiency float64

+ FirstQueried time.Time

+ LastQueried time.Time

+ MaxResponseTimeMs int64

+ MinResponseTimeMs int64

+ PK string

+ Period string

+ QueryCount int64

+ QueryHash string

+ QueryLength int

+ QueryType string

+ SK string

+ TTL int64

+ TotalCostMicros int64

+ TotalResponseTimeMs int64

+ TotalResultCount int64

+ Type string

+ UniqueUsers int

+ UpdatedAt time.Time

+ func (SearchQueryStats) TableName() string

+ func (sqs *SearchQueryStats) GetPK() string

+ func (sqs *SearchQueryStats) GetSK() string

+ func (sqs *SearchQueryStats) UpdateKeys() error

+ type SearchResults struct

+ Accounts []*activitypub.Actor

+ Hashtags []*HashtagSearchResult

+ Statuses []*StatusSearchResult

+ func NewSearchResults() *SearchResults

+ func (SearchResults) TableName() string

+ func (s *SearchResults) AddAccount(account *activitypub.Actor)

+ func (s *SearchResults) AddHashtag(hashtag *HashtagSearchResult)

+ func (s *SearchResults) AddStatus(status *StatusSearchResult)

+ func (s *SearchResults) Count() int

+ func (s *SearchResults) IsEmpty() bool

+ func (s *SearchResults) Merge(other *SearchResults)

+ func (s *SearchResults) TruncateToLimit(limit int)

+ type SearchSuggestion struct

+ CreatedAt time.Time

+ LastUsed time.Time

+ PK string

+ SK string

+ Score float64

+ Term string

+ Type string

+ UpdatedAt time.Time

+ UseCount int

+ func (SearchSuggestion) TableName() string

+ func (s *SearchSuggestion) GetPK() string

+ func (s *SearchSuggestion) GetSK() string

+ func (s *SearchSuggestion) UpdateKeys() error

+ type Series struct

+ ArticleCount int

+ AuthorID string

+ CoverImage string

+ CreatedAt time.Time

+ Description string

+ ID string

+ IsComplete bool

+ PK string

+ SK string

+ Slug string

+ Title string

+ UpdatedAt time.Time

+ func (Series) TableName() string

+ func (s *Series) GetPK() string

+ func (s *Series) GetSK() string

+ func (s *Series) UpdateKeys() error

+ type Session struct

+ AccessToken string

+ Context map[string]interface{}

+ CreatedAt time.Time

+ DeviceID string

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IPAddress string

+ IsRevoked bool

+ LastUsedAt time.Time

+ PK string

+ RefreshToken string

+ RevokeReason string

+ RevokedAt *time.Time

+ SK string

+ Scopes []string

+ SessionID string

+ UpdatedAt time.Time

+ UserAgent string

+ UserID string

+ Version int

+ func (Session) TableName() string

+ func (s *Session) BeforeCreate() error

+ func (s *Session) BeforeUpdate() error

+ func (s *Session) GetContext(key string) (interface{}, bool)

+ func (s *Session) HasScope(scope string) bool

+ func (s *Session) IsExpired() bool

+ func (s *Session) IsValid() bool

+ func (s *Session) RemainingTime() time.Duration

+ func (s *Session) Revoke(reason string)

+ func (s *Session) SetContext(key string, value interface{})

+ func (s *Session) Touch()

+ func (s *Session) Validate() error

+ func (s *Session) ValidateRequest(_, _ string) bool

+ type SetupSession struct

+ ExpiresAt time.Time

+ ID string

+ InstanceLock bool

+ IssuedAt time.Time

+ PK string

+ Purpose string

+ SK string

+ TTL int64

+ WalletAddr string

+ WalletType string

+ func (SetupSession) TableName() string

+ func (s *SetupSession) GetPK() string

+ func (s *SetupSession) GetSK() string

+ func (s *SetupSession) UpdateKeys() error

+ type SeveranceReason string

+ const SeveranceReasonDefederation

+ const SeveranceReasonDomainBlock

+ const SeveranceReasonInstanceDown

+ const SeveranceReasonOther

+ const SeveranceReasonPolicyViolation

+ type SeveranceReconnectionAttempt struct

+ AttemptedAt time.Time

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ ErrorMessages []string

+ FailureCount int

+ ID string

+ InitiatedBy string

+ Notes string

+ PK string

+ SK string

+ SeveranceID string

+ Status string

+ SuccessCount int

+ TTL int64

+ UpdatedAt time.Time

+ func NewSeveranceReconnectionAttempt(severanceID, initiatedBy string) *SeveranceReconnectionAttempt

+ func (SeveranceReconnectionAttempt) TableName() string

+ func (r *SeveranceReconnectionAttempt) GetPK() string

+ func (r *SeveranceReconnectionAttempt) GetSK() string

+ func (r *SeveranceReconnectionAttempt) MarkCompleted(successCount, failureCount int)

+ func (r *SeveranceReconnectionAttempt) MarkFailed(errorMessage string)

+ func (r *SeveranceReconnectionAttempt) MarkInProgress()

+ func (r *SeveranceReconnectionAttempt) UpdateKeys() error

+ type SeveranceStatus string

+ const SeveranceStatusAcknowledged

+ const SeveranceStatusActive

+ const SeveranceStatusRestored

+ type SeveredRelationship struct

+ AcknowledgedAt *time.Time

+ AdminNotes string

+ AffectedFollowers int

+ AffectedFollowing int

+ AutoDetected bool

+ CreatedAt time.Time

+ Details string

+ DetectedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ LocalInstance string

+ Metadata map[string]any

+ PK string

+ Reason SeveranceReason

+ ReconnectionAttempt bool

+ RemoteInstance string

+ Reversible bool

+ SK string

+ Severity string

+ Status SeveranceStatus

+ TTL int64

+ UpdatedAt time.Time

+ func NewSeveredRelationship(localInstance, remoteInstance string, reason SeveranceReason) *SeveredRelationship

+ func (SeveredRelationship) TableName() string

+ func (s *SeveredRelationship) Acknowledge()

+ func (s *SeveredRelationship) GetPK() string

+ func (s *SeveredRelationship) GetSK() string

+ func (s *SeveredRelationship) MarkReconnectionAttempt()

+ func (s *SeveredRelationship) UpdateKeys() error

+ type SocialRecoveryRequest struct

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ InitiatedAt time.Time

+ PK string

+ ReceivedVotes map[string]bool

+ RecoveryToken string

+ RequiredVotes int

+ SK string

+ Status string

+ TTL int64

+ Username string

+ func (SocialRecoveryRequest) TableName() string

+ func (s *SocialRecoveryRequest) AddVote(trusteeID string) bool

+ func (s *SocialRecoveryRequest) Cancel()

+ func (s *SocialRecoveryRequest) GetProgress() float64

+ func (s *SocialRecoveryRequest) GetVoteCount() int

+ func (s *SocialRecoveryRequest) IsActive() bool

+ func (s *SocialRecoveryRequest) IsExpired() bool

+ func (s *SocialRecoveryRequest) MarkExpired()

+ func (s *SocialRecoveryRequest) UpdateKeys()

+ type Status struct

+ AuthorID string

+ AuthorUsername string

+ BccRecipients []string

+ BoostAnnounceID string

+ BoostOfAuthorID string

+ BoostOfStatusID string

+ BtoRecipients []string

+ CcRecipients []string

+ Content string

+ ConversationID string

+ CreatedAt time.Time

+ Deleted bool

+ DeletedAt *time.Time

+ Flagged bool

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ GSI5PK string

+ GSI5SK string

+ GSI6PK string

+ GSI6SK string

+ GSI7PK string

+ GSI7SK string

+ Hashtags []string

+ InReplyToID string

+ Language string

+ LikeCount int

+ MediaCount int

+ Mentions []string

+ ModifiedAt time.Time

+ Note *activitypub.Note

+ PK string

+ PublishedAt time.Time

+ QuoteCount int

+ QuoteTargetAuthorID string

+ QuoteTargetStatusID string

+ ReblogCount int

+ ReblogOfID string

+ ReplyCount int

+ SK string

+ Sensitive bool

+ StatusID string

+ ToRecipients []string

+ URLs []string

+ UpdatedAt time.Time

+ Version int

+ Visibility string

+ func (Status) TableName() string

+ func (s *Status) BeforeCreate() error

+ func (s *Status) BeforeUpdate() error

+ func (s *Status) CanBeReblogged() bool

+ func (s *Status) CreateHashtagIndexRecords() []*StatusHashtagIndex

+ func (s *Status) DeleteHashtagIndexRecords() []map[string]interface{}

+ func (s *Status) GetAllHashtagIndexRecords() []*StatusHashtagIndex

+ func (s *Status) GetAllRecipients() []string

+ func (s *Status) GetPK() string

+ func (s *Status) GetPrivacyScore() int

+ func (s *Status) GetSK() string

+ func (s *Status) GetVisibleRecipients(requestingActorID string) []string

+ func (s *Status) HasHashtags() bool

+ func (s *Status) HasMedia() bool

+ func (s *Status) HasMentions() bool

+ func (s *Status) HasSpecificRecipients() bool

+ func (s *Status) IsConversation() bool

+ func (s *Status) IsDeleted() bool

+ func (s *Status) IsDirect() bool

+ func (s *Status) IsFlagged() bool

+ func (s *Status) IsPrivate() bool

+ func (s *Status) IsPublic() bool

+ func (s *Status) IsReblog() bool

+ func (s *Status) IsRecipient(actorID string) bool

+ func (s *Status) IsReply() bool

+ func (s *Status) IsVisibleTo(actorID string) bool

+ func (s *Status) RequiresFollowCheck() bool

+ func (s *Status) SanitizeForActor(viewerID string) *Status

+ func (s *Status) ShouldAppearInTimeline(timelineType string, viewerID string) bool

+ func (s *Status) UpdateKeys() error

+ type StatusAttachment struct

+ Height int

+ MediaType string

+ Name string

+ Type string

+ URL string

+ Width int

+ func (StatusAttachment) TableName() string

+ type StatusEngagement struct

+ EngagedAt time.Time

+ EngagementType string

+ PK string

+ SK string

+ StatusID string

+ TTL int64

+ UserID string

+ func (StatusEngagement) TableName() string

+ func (s *StatusEngagement) GetPK() string

+ func (s *StatusEngagement) GetSK() string

+ func (s *StatusEngagement) UpdateKeys() error

+ type StatusHashtagIndex struct

+ AuthorID string

+ Hashtag string

+ PK string

+ PublishedAt time.Time

+ SK string

+ StatusID string

+ TTL int64

+ Visibility string

+ func (StatusHashtagIndex) TableName() string

+ func (shi *StatusHashtagIndex) UpdateKeys()

+ type StatusMetadata struct

+ AllowQuotes bool

+ AllowReplies bool

+ ContentWarning string

+ CreatedAt time.Time

+ DisableLikes bool

+ DisableReblogs bool

+ ModerationFlags []string

+ ModerationNotes string

+ PK string

+ QuotePermissions string

+ QuoteType string

+ ReplyCount int

+ ReplyPermissions string

+ SK string

+ StatusID string

+ UpdatedAt time.Time

+ Version int

+ WithdrawnFromQuotes bool

+ func NewStatusMetadata(statusID string) *StatusMetadata

+ func (StatusMetadata) TableName() string

+ func (sm *StatusMetadata) AddModerationFlag(flag string)

+ func (sm *StatusMetadata) BeforeCreate() error

+ func (sm *StatusMetadata) BeforeUpdate() error

+ func (sm *StatusMetadata) DecrementReplyCount()

+ func (sm *StatusMetadata) HasModerationFlag(flag string) bool

+ func (sm *StatusMetadata) IncrementReplyCount()

+ func (sm *StatusMetadata) IsPubliclyQuotable() bool

+ func (sm *StatusMetadata) IsQuotable() bool

+ func (sm *StatusMetadata) RemoveModerationFlag(flag string)

+ func (sm *StatusMetadata) RestoreToQuotes()

+ func (sm *StatusMetadata) SetQuoteType(quoteType string)

+ func (sm *StatusMetadata) SetReplyCount(count int)

+ func (sm *StatusMetadata) UpdateKeys()

+ func (sm *StatusMetadata) WithdrawFromQuotes()

+ type StatusPin struct

+ CreatedAt time.Time

+ PK string

+ SK string

+ StatusID string

+ Username string

+ func (StatusPin) TableName() string

+ func (s *StatusPin) BeforeCreate() error

+ func (s *StatusPin) GetPK() string

+ func (s *StatusPin) GetSK() string

+ func (s *StatusPin) UpdateKeys() error

+ type StatusSearchOptions struct

+ AccountID string

+ FollowingOnly bool

+ Language string

+ Limit int

+ LocalOnly bool

+ MediaOnly bool

+ MinEngagement int

+ Offset int

+ TimeRange TimeRange

+ func NewStatusSearchOptions() *StatusSearchOptions

+ func (StatusSearchOptions) TableName() string

+ func (o *StatusSearchOptions) Validate() error

+ func (o *StatusSearchOptions) WithAccountID(accountID string) *StatusSearchOptions

+ func (o *StatusSearchOptions) WithFollowingOnly() *StatusSearchOptions

+ func (o *StatusSearchOptions) WithLanguage(language string) *StatusSearchOptions

+ func (o *StatusSearchOptions) WithLimit(limit int) *StatusSearchOptions

+ func (o *StatusSearchOptions) WithLocalOnly() *StatusSearchOptions

+ func (o *StatusSearchOptions) WithMediaOnly() *StatusSearchOptions

+ func (o *StatusSearchOptions) WithMinEngagement(minVal int) *StatusSearchOptions

+ func (o *StatusSearchOptions) WithOffset(offset int) *StatusSearchOptions

+ func (o *StatusSearchOptions) WithTimeRange(start, end time.Time) *StatusSearchOptions

+ type StatusSearchResult struct

+ AuthorID string

+ AuthorUsername string

+ Content string

+ Highlights map[string]string

+ Published time.Time

+ Score float64

+ StatusID string

+ URL string

+ func NewStatusSearchResult(statusID, content, url, authorID, authorUsername string, published time.Time) *StatusSearchResult

+ func (StatusSearchResult) TableName() string

+ func (s *StatusSearchResult) AddHighlight(field, highlight string)

+ func (s *StatusSearchResult) IsRecent() bool

+ func (s *StatusSearchResult) SetScore(score float64)

+ type StatusTag struct

+ Href string

+ Name string

+ Type string

+ func (StatusTag) TableName() string

+ type StatusTrend struct

+ AuthorID string

+ Content string

+ Engagements int64

+ GSI8PK string

+ GSI8SK string

+ ID string

+ PK string

+ PublishedAt time.Time

+ SK string

+ TTL int64

+ TrendScore float64

+ URL string

+ UpdatedAt time.Time

+ func (StatusTrend) TableName() string

+ func (s *StatusTrend) UpdateKeys() error

+ type StreamingCloudWatchMetrics struct

+ CacheExpiry time.Time

+ CloudWatchQueryTime time.Time

+ ConcurrentViewers ConcurrentViewerMetrics

+ DataFreshness int64

+ Date string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GeographicMetrics map[string]GeographicMetric

+ MediaID string

+ MetricType string

+ PK string

+ PerformanceMetrics StreamingPerformanceMetrics

+ QualityMetrics map[string]QualityMetric

+ SK string

+ TTL int64

+ Timestamp time.Time

+ func (StreamingCloudWatchMetrics) TableName() string

+ func (s *StreamingCloudWatchMetrics) GetBestQuality() string

+ func (s *StreamingCloudWatchMetrics) GetBestRegionQuality(region string) string

+ func (s *StreamingCloudWatchMetrics) GetPK() string

+ func (s *StreamingCloudWatchMetrics) GetSK() string

+ func (s *StreamingCloudWatchMetrics) IsExpired() bool

+ func (s *StreamingCloudWatchMetrics) SetConcurrentViewers(mediaID string, metrics ConcurrentViewerMetrics)

+ func (s *StreamingCloudWatchMetrics) SetGeographicData(mediaID string, metrics map[string]GeographicMetric)

+ func (s *StreamingCloudWatchMetrics) SetPerformanceMetrics(mediaID string, metrics StreamingPerformanceMetrics)

+ func (s *StreamingCloudWatchMetrics) SetQualityBreakdown(mediaID string, metrics map[string]QualityMetric)

+ func (s *StreamingCloudWatchMetrics) ShouldAdaptQuality(currentQuality string) (bool, string)

+ func (s *StreamingCloudWatchMetrics) UpdateFreshness()

+ func (s *StreamingCloudWatchMetrics) UpdateKeys() error

+ type StreamingEvent struct

+ CreatedAt time.Time

+ DeliveredTo []string

+ EventID string

+ EventType string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ PK string

+ Payload map[string]interface{}

+ ProcessedAt *time.Time

+ SK string

+ TTL int64

+ TargetID string

+ TargetType string

+ func (e *StreamingEvent) GetPrimaryKey() (string, string)

+ func (e *StreamingEvent) GetTableName() string

+ func (e *StreamingEvent) TableName() string

+ func (e *StreamingEvent) UpdateKeys()

+ type StreamingPerformanceMetrics struct

+ AutoQualityEvents int64

+ CDNHitRate float64

+ EdgeLocations int

+ OverallBufferingRate float64

+ OverallErrorRate float64

+ OverallLatencyMs int64

+ StartupLatencyMs int64

+ ThroughputMbps float64

+ func (StreamingPerformanceMetrics) TableName() string

+ type StreamingPreferences struct

+ AudioDescriptionEnabled *bool

+ AutoQuality bool

+ BufferSizeSeconds int

+ ClosedCaptionsEnabled *bool

+ ColorSpace string

+ DataSaverMode bool

+ DefaultQuality string

+ DeviceID string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HDREnabled *bool

+ MaxBandwidthMbps int64

+ PK string

+ PreferredCodec string

+ PreloadNext bool

+ SK string

+ SchemaVersion int

+ SubtitleEnabled *bool

+ SubtitleLanguage string

+ TTL int64

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func GetDefaultStreamingPreferences(username string) *StreamingPreferences

+ func (StreamingPreferences) TableName() string

+ func (s *StreamingPreferences) GetPK() string

+ func (s *StreamingPreferences) GetSK() string

+ func (s *StreamingPreferences) SetBackupPreference()

+ func (s *StreamingPreferences) SetCurrentPreference()

+ func (s *StreamingPreferences) SetDevicePreference(deviceID string)

+ func (s *StreamingPreferences) SetVersionedPreference()

+ func (s *StreamingPreferences) UpdateKeys() error

+ type TOCEntry struct

+ ID string

+ Level int

+ Text string

+ type ThreadContext struct

+ AuthorHandle string

+ AuthorID string

+ ConversationID string

+ CreatedAt time.Time

+ Depth int

+ GSI1PK string

+ GSI1SK string

+ LastReplyAt *time.Time

+ PK string

+ ParentID string

+ Participants []string

+ Path string

+ ReplyCount int

+ RootStatusID string

+ SK string

+ Sensitive bool

+ StatusID string

+ TTL int64

+ TotalReplies int

+ UpdatedAt time.Time

+ Visibility string

+ func (ThreadContext) TableName() string

+ func (t *ThreadContext) AddParticipant(participantID string)

+ func (t *ThreadContext) GetPathElements() []string

+ func (t *ThreadContext) IncrementReplyCount()

+ func (t *ThreadContext) IsRoot() bool

+ func (t *ThreadContext) UpdateKeys()

+ type ThreadNode struct

+ AuthorHandle string

+ AuthorID string

+ ChildIDs []string

+ Content string

+ CreatedAt time.Time

+ Depth int

+ DescendantCount int

+ FetchedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ IsLocal bool

+ LastReplyAt *time.Time

+ PK string

+ ParentID string

+ Path string

+ RemoteURL string

+ ReplyCount int

+ RootStatusID string

+ SK string

+ Sensitive bool

+ StatusID string

+ TTL int64

+ UpdatedAt time.Time

+ Visibility string

+ func NewThreadNode(rootStatusID, statusID, parentID string, depth int, authorID string) *ThreadNode

+ func (ThreadNode) TableName() string

+ func (n *ThreadNode) AddChild(childID string)

+ func (n *ThreadNode) GetPK() string

+ func (n *ThreadNode) GetSK() string

+ func (n *ThreadNode) IncrementDescendantCount(count int)

+ func (n *ThreadNode) IsLeaf() bool

+ func (n *ThreadNode) IsRoot() bool

+ func (n *ThreadNode) UpdateKeys() error

+ func (n *ThreadNode) UpdatePath(parentPath string)

+ type ThreadSync struct

+ CreatedAt time.Time

+ LastErrorMessage string

+ LastSyncAt time.Time

+ MissingReplies []string

+ PK string

+ RemoteFetched bool

+ SK string

+ StatusID string

+ SyncStatus string

+ TTL int64

+ ThreadDepth int

+ UpdatedAt time.Time

+ func NewThreadSync(statusID string) *ThreadSync

+ func (ThreadSync) TableName() string

+ func (t *ThreadSync) AddMissingReply(replyID string)

+ func (t *ThreadSync) GetPK() string

+ func (t *ThreadSync) GetSK() string

+ func (t *ThreadSync) IsRecentlyCompleted() bool

+ func (t *ThreadSync) MarkCompleted()

+ func (t *ThreadSync) MarkFailed(errorMessage string)

+ func (t *ThreadSync) MarkSyncing()

+ func (t *ThreadSync) RemoveMissingReply(replyID string)

+ func (t *ThreadSync) UpdateKeys() error

+ type ThreatIndicator struct

+ PK string

+ SK string

+ TTL int64

+ ThreatID string

+ func (ThreatIndicator) TableName() string

+ func (ti *ThreatIndicator) GetPK() string

+ func (ti *ThreatIndicator) GetSK() string

+ func (ti *ThreatIndicator) UpdateKeys(indicator, threatID string) error

+ type ThreatIntel struct

+ Confidence float64

+ Description string

+ FirstSeen time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ HitCount int64

+ ID string

+ Indicators []string

+ LastSeen time.Time

+ PK string

+ SK string

+ Severity string

+ SourceDomain string

+ TTL int64

+ ThreatType string

+ func (ThreatIntel) TableName() string

+ func (t *ThreatIntel) GetPK() string

+ func (t *ThreatIntel) GetSK() string

+ func (t *ThreatIntel) UpdateKeys() error

+ type TimeRange struct

+ End time.Time

+ Start time.Time

+ func (TimeRange) TableName() string

+ type Timeline struct

+ ActorHandle string

+ ActorID string

+ BoostedBy string

+ Content string

+ ContentType string

+ CreatedAt time.Time

+ EntryID string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ HasMedia bool

+ InReplyTo string

+ IsBoost bool

+ IsReply bool

+ Language string

+ ModifiedAt time.Time

+ PK string

+ PostID string

+ SK string

+ Sensitive bool

+ SpoilerText string

+ TTL int64

+ TimelineAt time.Time

+ TimelineID string

+ TimelineType string

+ Version int

+ Visibility string

+ func (Timeline) TableName() string

+ func (t *Timeline) BeforeCreate() error

+ func (t *Timeline) BeforeUpdate() error

+ func (t *Timeline) GetPK() string

+ func (t *Timeline) GetSK() string

+ func (t *Timeline) GetSortKey() string

+ func (t *Timeline) GetTimelineKey() string

+ func (t *Timeline) IsDirect() bool

+ func (t *Timeline) IsDirectTimeline() bool

+ func (t *Timeline) IsExpired() bool

+ func (t *Timeline) IsHashtagTimeline() bool

+ func (t *Timeline) IsHomeTimeline() bool

+ func (t *Timeline) IsListTimeline() bool

+ func (t *Timeline) IsPrivate() bool

+ func (t *Timeline) IsPublic() bool

+ func (t *Timeline) IsPublicTimeline() bool

+ func (t *Timeline) IsUnlisted() bool

+ func (t *Timeline) SetTTL(expiresAt time.Time)

+ func (t *Timeline) UpdateKeys() error

+ type TimelineEntry struct

+ ActorHandle string

+ ActorID string

+ BoostedBy string

+ Content string

+ ContentType string

+ CreatedAt time.Time

+ EntryID string

+ ExpiresAt time.Time

+ GSI1PK string

+ GSI1SK string

+ HasMedia bool

+ InReplyTo string

+ IsBoost bool

+ IsReply bool

+ Language string

+ PK string

+ PostID string

+ SK string

+ Sensitive bool

+ SpoilerText string

+ TTL int64

+ TimelineAt time.Time

+ TimelineID string

+ TimelineType string

+ Visibility string

+ func (TimelineEntry) TableName() string

+ func (e *TimelineEntry) IsExpired() bool

+ func (e *TimelineEntry) SetEntryID()

+ func (e *TimelineEntry) UpdateKeys()

+ type TimelineMarker struct

+ LastReadID string

+ PK string

+ SK string

+ Timeline string

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func (TimelineMarker) TableName() string

+ func (m *TimelineMarker) BeforeCreate() error

+ func (m *TimelineMarker) BeforeUpdate() error

+ func (m *TimelineMarker) GetPK() string

+ func (m *TimelineMarker) GetSK() string

+ func (m *TimelineMarker) UpdateKeys() error

+ type Tombstone struct

+ CreatedAt time.Time

+ Deleted time.Time

+ DeletedBy string

+ FormerType string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ PK string

+ SK string

+ Summary string

+ TTL int64

+ Type string

+ func (Tombstone) TableName() string

+ func (t *Tombstone) BeforeCreate() error

+ func (t *Tombstone) GetDeletedBy() string

+ func (t *Tombstone) GetFormerType() string

+ func (t *Tombstone) GetOriginalID() string

+ func (t *Tombstone) GetPK() string

+ func (t *Tombstone) GetSK() string

+ func (t *Tombstone) IsTombstone() bool

+ func (t *Tombstone) ShouldCleanup() bool

+ func (t *Tombstone) UpdateKeys() error

+ type TrainingMetrics struct

+ Accuracy float64

+ F1Score float64

+ Precision float64

+ Recall float64

+ TrainingTime int

+ func (TrainingMetrics) TableName() string

+ type TranscodingJob struct

+ AnalysisEnabled bool

+ CompletedAt *time.Time

+ CompressionRatio float64

+ CostBreakdown map[string]int64

+ CostPerMB float64

+ CostVariance int64

+ CreatedAt time.Time

+ ErrorMessage string

+ EstimatedCostMicros int64

+ ExpiresAt *int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ InputDuration int64

+ InputFormat string

+ InputResolution string

+ InputSize int64

+ JobID string

+ JobType string

+ LambdaCostMicros int64

+ MediaConvertCostMicros int64

+ MediaConvertJobID string

+ MediaID string

+ ModelVersion int

+ OutputSizes map[string]int64

+ OutputVariants map[string]string

+ PK string

+ ProcessingSpeedMBps float64

+ ProcessingTimeMs int64

+ QualityLevels []string

+ RekognitionCostMicros int64

+ S3Keys []string

+ S3RequestCostMicros int64

+ S3StorageCostMicros int64

+ SK string

+ StartedAt time.Time

+ Status string

+ ThumbnailCount int

+ TotalCostMicros int64

+ TotalOutputSize int64

+ UpdatedAt time.Time

+ UserID string

+ Username string

+ func (TranscodingJob) TableName() string

+ func (tj *TranscodingJob) AddCost(service string, costMicros int64)

+ func (tj *TranscodingJob) AddOutputVariant(quality, format string, size int64, s3Key string)

+ func (tj *TranscodingJob) BeforeCreate() error

+ func (tj *TranscodingJob) BeforeUpdate() error

+ func (tj *TranscodingJob) Duration() time.Duration

+ func (tj *TranscodingJob) GetCostEfficiency() map[string]float64

+ func (tj *TranscodingJob) GetPK() string

+ func (tj *TranscodingJob) GetQualityBreakdown() map[string]map[string]interface{}

+ func (tj *TranscodingJob) GetSK() string

+ func (tj *TranscodingJob) GetServiceCostBreakdown() map[string]int64

+ func (tj *TranscodingJob) IsCompleted() bool

+ func (tj *TranscodingJob) SetCompleted()

+ func (tj *TranscodingJob) SetFailed(errorMessage string)

+ func (tj *TranscodingJob) UpdateKeys() error

+ func (tj *TranscodingJob) Validate() error

+ type TrendingHashtag struct

+ Date string

+ GSI8PK string

+ GSI8SK string

+ Hashtag string

+ History []float64

+ PK string

+ SK string

+ Score float64

+ TTL int64

+ UpdatedAt time.Time

+ UseCount int64

+ UserCount int64

+ func (TrendingHashtag) TableName() string

+ func (t *TrendingHashtag) GetPK() string

+ func (t *TrendingHashtag) GetSK() string

+ func (t *TrendingHashtag) UpdateKeys() error

+ type TrendingLink struct

+ AuthorName string

+ CreatedAt time.Time

+ Date string

+ Description string

+ Domain string

+ Image string

+ ImageURL string

+ LinkID string

+ PK string

+ Rank int

+ SK string

+ ShareCount int64

+ TTL int64

+ Title string

+ TrendingScore float64

+ Type string

+ URL string

+ UserID string

+ func NewTrendingLink(date string, link *TrendingLink) *TrendingLink

+ func (TrendingLink) TableName() string

+ func (t *TrendingLink) CalculateTrendingScore()

+ func (t *TrendingLink) FormatTrendingSummary() string

+ func (t *TrendingLink) GetDisplayTitle() string

+ func (t *TrendingLink) UpdateKeys()

+ type TrendingStatus struct

+ AuthorID string

+ Boosts int

+ Content string

+ CreatedAt time.Time

+ Date string

+ Engagements int64

+ ID string

+ Likes int

+ PK string

+ PublishedAt time.Time

+ Rank int

+ Replies int

+ SK string

+ TTL int64

+ TrendingScore float64

+ URL string

+ func NewTrendingStatus(date string, status *TrendingStatus) *TrendingStatus

+ func (TrendingStatus) TableName() string

+ func (t *TrendingStatus) CalculateTrendingScore()

+ func (t *TrendingStatus) FormatTrendingSummary() string

+ func (t *TrendingStatus) UpdateKeys()

+ type TrustCategory string

+ const TrustCategoryBehavior

+ const TrustCategoryContent

+ const TrustCategoryGeneral

+ const TrustCategoryTechnical

+ type TrustEvidence struct

+ Description string

+ Score float64

+ Timestamp time.Time

+ Type string

+ func (TrustEvidence) TableName() string

+ type TrustRelationship struct

+ Category TrustCategory

+ Confidence float64

+ Created time.Time

+ Evidence []TrustEvidence

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ PK string

+ SK string

+ Score float64

+ TTL int64

+ TrusteeID string

+ TrusterID string

+ Type string

+ Updated time.Time

+ func (TrustRelationship) TableName() string

+ func (tr *TrustRelationship) GetPK() string

+ func (tr *TrustRelationship) GetSK() string

+ func (tr *TrustRelationship) UpdateKeys() error

+ type TrustScore struct

+ ActorID string

+ CacheTTL time.Time

+ Category TrustCategory

+ CategoryScores map[string]float64

+ Confidence float64

+ DirectScore float64

+ LastCalculated time.Time

+ PK string

+ PropagatedScore float64

+ SK string

+ Score float64

+ TTL int64

+ TrusterCount int

+ Type string

+ func (TrustScore) TableName() string

+ func (ts *TrustScore) GetPK() string

+ func (ts *TrustScore) GetSK() string

+ func (ts *TrustScore) UpdateKeys() error

+ type TrustUpdate struct

+ ActorID string

+ Category TrustCategory

+ Delta float64

+ EventID string

+ PK string

+ Reason string

+ SK string

+ TTL int64

+ Timestamp time.Time

+ Type string

+ func (TrustUpdate) TableName() string

+ func (tu *TrustUpdate) GetPK() string

+ func (tu *TrustUpdate) GetSK() string

+ func (tu *TrustUpdate) UpdateKeys() error

+ type Trustee struct

+ ActorID string

+ AddedAt time.Time

+ Confirmed bool

+ PK string

+ SK string

+ Username string

+ func (Trustee) TableName() string

+ func (t *Trustee) GetPK() string

+ func (t *Trustee) GetSK() string

+ func (t *Trustee) UpdateKeys() error

+ type TrusteeConfig struct

+ ActorID string

+ AddedAt time.Time

+ Category string

+ Confirmed bool

+ ConfirmedAt *time.Time

+ LastUsed *time.Time

+ Notes string

+ PK string

+ Permissions []string

+ RecoveryPriority int

+ SK string

+ TrustLevel string

+ UpdatedAt time.Time

+ UsageCount int

+ Username string

+ func NewTrusteeConfig(username, actorID, category string) *TrusteeConfig

+ func (TrusteeConfig) TableName() string

+ func (t *TrusteeConfig) AddPermission(permission string) bool

+ func (t *TrusteeConfig) CanPerformAction(action string) bool

+ func (t *TrusteeConfig) Confirm()

+ func (t *TrusteeConfig) FormatDisplayName() string

+ func (t *TrusteeConfig) GetTrustLevelPriority() int

+ func (t *TrusteeConfig) IsActive() bool

+ func (t *TrusteeConfig) IsModerationTrustee() bool

+ func (t *TrusteeConfig) IsRecoveryTrustee() bool

+ func (t *TrusteeConfig) RecordUsage()

+ func (t *TrusteeConfig) RemovePermission(permission string) bool

+ func (t *TrusteeConfig) SetPermissions(permissions []string)

+ func (t *TrusteeConfig) UpdateKeys()

+ type UpdateHistory struct

+ CreatedAt time.Time

+ ObjectID string

+ PK string

+ PreviousState string

+ SK string

+ Summary string

+ TTL int64

+ UpdatedAt time.Time

+ UpdatedBy string

+ Version int

+ func (UpdateHistory) TableName() string

+ func (h *UpdateHistory) UpdateKeys()

+ type User struct

+ AgentCapabilities *agents.Capabilities

+ AgentCreatedBy string

+ AgentKeyType string

+ AgentOwner string

+ AgentPublicKey string

+ AgentType string

+ AgentVersion string

+ AllowNSFW bool

+ Approved bool

+ Avatar string

+ CreatedAt time.Time

+ Discoverable bool

+ DisplayName string

+ Email string

+ Fields []map[string]string

+ GSI1PK string

+ GSI1SK string

+ GSI3PK string

+ GSI3SK string

+ GSI4PK string

+ GSI4SK string

+ GSI5PK string

+ GSI5SK string

+ GSI6PK string

+ GSI6SK string

+ Header string

+ IsAgent bool

+ Locale string

+ Locked bool

+ Metadata map[string]interface{}

+ Note string

+ PK string

+ PasswordHash string

+ RecoveryMethods []string

+ RequireNSFWWarning bool

+ Role string

+ SK string

+ Silenced bool

+ Suspended bool

+ URL string

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func (User) TableName() string

+ func (u *User) BeforeCreate() error

+ func (u *User) BeforeUpdate() error

+ func (u *User) GetPK() string

+ func (u *User) GetSK() string

+ func (u *User) HasEmail() bool

+ func (u *User) HasPassword() bool

+ func (u *User) IsActive() bool

+ func (u *User) IsAdmin() bool

+ func (u *User) IsModerator() bool

+ func (u *User) UpdateKeys() error

+ type UserAppConsent struct

+ Active bool

+ AppID string

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ PK string

+ RevokedAt *time.Time

+ SK string

+ Scopes []string

+ UpdatedAt time.Time

+ UserID string

+ func (UserAppConsent) TableName() string

+ func (c *UserAppConsent) GetPK() string

+ func (c *UserAppConsent) GetSK() string

+ func (c *UserAppConsent) HasScope(scope string) bool

+ func (c *UserAppConsent) IsValid() bool

+ func (c *UserAppConsent) Revoke()

+ func (c *UserAppConsent) UpdateKeys() error

+ type UserDomainBlock struct

+ CreatedAt time.Time

+ Domain string

+ PK string

+ SK string

+ Username string

+ func (UserDomainBlock) TableName() string

+ func (d *UserDomainBlock) GetPK() string

+ func (d *UserDomainBlock) GetSK() string

+ func (d *UserDomainBlock) UpdateKeys() error

+ type UserLogin struct

+ IPAddress string

+ PK string

+ SK string

+ Success bool

+ TTL int64

+ Timestamp time.Time

+ UserAgent string

+ Username string

+ func (UserLogin) TableName() string

+ func (l *UserLogin) BeforeCreate() error

+ func (l *UserLogin) GetPK() string

+ func (l *UserLogin) GetSK() string

+ func (l *UserLogin) UpdateKeys() error

+ type UserMediaConfig struct

+ AllowedAudioTypes []string

+ AllowedImageTypes []string

+ AllowedVideoTypes []string

+ AudioProcessingEnabled bool

+ AutoRejectNSFW bool

+ BandwidthBudgetMicros int64

+ BlockedLabels []string

+ ContentModerationEnabled bool

+ CreatedAt time.Time

+ CurrentMonthlyUsage int64

+ CurrentStorageUsage int64

+ DailyBudgetMicros int64

+ EnableBlurhash bool

+ EnableThumbnails bool

+ ImageQuality string

+ IsTrialUser bool

+ LastResetAt time.Time

+ MaxAudioSize int64

+ MaxBandwidthPerMonth int64

+ MaxDailyUploads int

+ MaxFileSize int64

+ MaxImageSize int64

+ MaxMonthlyUploads int

+ MaxStorageUsage int64

+ MaxVideoDuration int

+ MaxVideoSize int64

+ ModelVersion int

+ ModerationThreshold float64

+ MonthlyBudgetMicros int64

+ PK string

+ PlanExpiresAt *time.Time

+ PlanTier string

+ ProcessingBudgetMicros int64

+ RequiredLabels []string

+ SK string

+ StorageBudgetMicros int64

+ TrialExpiresAt *time.Time

+ UpdatedAt time.Time

+ UserID string

+ Username string

+ VideoProcessingEnabled bool

+ VideoQuality string

+ VideoThumbnailsEnabled bool

+ func (UserMediaConfig) TableName() string

+ func (umc *UserMediaConfig) AddMonthlyUsage(bytes int64)

+ func (umc *UserMediaConfig) BeforeCreate() error

+ func (umc *UserMediaConfig) BeforeUpdate() error

+ func (umc *UserMediaConfig) CanAfford(costMicros int64, costType string) bool

+ func (umc *UserMediaConfig) GetMaxSizeForType(contentType string) int64

+ func (umc *UserMediaConfig) GetPK() string

+ func (umc *UserMediaConfig) GetSK() string

+ func (umc *UserMediaConfig) IsAllowedContentType(contentType string) bool

+ func (umc *UserMediaConfig) IsExpired() bool

+ func (umc *UserMediaConfig) IsTrialExpired() bool

+ func (umc *UserMediaConfig) IsWithinStorageLimit(additionalBytes int64) bool

+ func (umc *UserMediaConfig) ResetMonthlyCounters()

+ func (umc *UserMediaConfig) ShouldResetCounters() bool

+ func (umc *UserMediaConfig) UpdateKeys() error

+ func (umc *UserMediaConfig) UpdateStorageUsage(deltaBytes int64)

+ func (umc *UserMediaConfig) UpgradePlan(newTier string, expiresAt *time.Time) error

+ func (umc *UserMediaConfig) Validate() error

+ type UserPreference struct

+ Key string

+ PK string

+ SK string

+ UpdatedAt time.Time

+ Username string

+ Value string

+ func (UserPreference) TableName() string

+ func (p *UserPreference) BeforeCreate() error

+ func (p *UserPreference) UpdateKeys()

+ type UserPreferences struct

+ AutoplayGifs bool

+ DefaultMediaSensitive bool

+ DefaultPostingVisibility string

+ ExpandMedia string

+ ExpandSpoilers bool

+ Language string

+ PK string

+ PersonalizedSearchEnabled bool

+ PreferredTimelineOrder string

+ ReblogFilters map[string]bool

+ SK string

+ SearchSuggestionsEnabled bool

+ ShowFollowCounts bool

+ StreamingAutoQuality bool

+ StreamingDataSaver bool

+ StreamingDefaultQuality string

+ StreamingPreloadNext bool

+ UpdatedAt time.Time

+ Username string

+ func (UserPreferences) TableName() string

+ func (up *UserPreferences) FromStorage(username string, prefs *UserPreferencesStorage)

+ func (up *UserPreferences) ToStorage() *UserPreferencesStorage

+ func (up *UserPreferences) UpdateKeys()

+ type UserPreferencesStorage struct

+ AutoplayGifs bool

+ DefaultMediaSensitive bool

+ DefaultPostingVisibility string

+ ExpandMedia string

+ ExpandSpoilers bool

+ Language string

+ PersonalizedSearchEnabled bool

+ PreferredTimelineOrder string

+ ReblogFilters map[string]bool

+ SearchSuggestionsEnabled bool

+ ShowFollowCounts bool

+ StreamingAutoQuality bool

+ StreamingDataSaver bool

+ StreamingDefaultQuality string

+ StreamingPreloadNext bool

+ func GetDefaultPreferences() *UserPreferencesStorage

+ func (UserPreferencesStorage) TableName() string

+ type VAPIDKeyRecord struct

+ Data interface{}

+ PK string

+ SK string

+ UpdatedAt time.Time

+ func (VAPIDKeyRecord) TableName() string

+ func (v *VAPIDKeyRecord) GetPK() string

+ func (v *VAPIDKeyRecord) GetSK() string

+ func (v *VAPIDKeyRecord) UpdateKeys() error

+ type Vouch struct

+ Active bool

+ CreatedAt time.Time

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ PK string

+ SK string

+ VouchData string

+ func (Vouch) TableName() string

+ func (v *Vouch) UpdateKeys(vouchID, fromActorID, toActorID string, active bool, ...)

+ type WalletChallenge struct

+ Address string

+ ChainID int

+ ExpiresAt time.Time

+ ID string

+ IssuedAt time.Time

+ Message string

+ Nonce string

+ PK string

+ SK string

+ Spent bool

+ TTL int64

+ Used bool

+ Username string

+ func (WalletChallenge) TableName() string

+ func (w *WalletChallenge) BeforeCreate() error

+ func (w *WalletChallenge) GetPK() string

+ func (w *WalletChallenge) GetSK() string

+ func (w *WalletChallenge) UpdateKeys() error

+ type WalletCredential struct

+ Address string

+ ChainID int

+ ENS string

+ LastUsed time.Time

+ LinkedAt time.Time

+ PK string

+ SK string

+ Type string

+ Username string

+ func (WalletCredential) TableName() string

+ func (w *WalletCredential) BeforeCreate() error

+ func (w *WalletCredential) BeforeUpdate() error

+ func (w *WalletCredential) GetPK() string

+ func (w *WalletCredential) GetSK() string

+ func (w *WalletCredential) UpdateKeys() error

+ type WalletIndex struct

+ Address string

+ PK string

+ SK string

+ Username string

+ WalletType string

+ func (WalletIndex) TableName() string

+ func (w *WalletIndex) BeforeCreate() error

+ func (w *WalletIndex) GetPK() string

+ func (w *WalletIndex) GetSK() string

+ func (w *WalletIndex) UpdateKeys(walletType, address, username string)

+ type WebAuthnChallenge struct

+ Challenge string

+ ExpiresAt time.Time

+ ItemType string

+ PK string

+ SK string

+ SessionData []byte

+ TTL int64

+ Type string

+ UserID string

+ func (WebAuthnChallenge) TableName() string

+ func (w *WebAuthnChallenge) BeforeCreate() error

+ func (w *WebAuthnChallenge) GetPK() string

+ func (w *WebAuthnChallenge) GetSK() string

+ func (w *WebAuthnChallenge) UpdateKeys() error

+ type WebAuthnCredential struct

+ AAGUID []byte

+ AttestationType string

+ BackupEligible bool

+ BackupState bool

+ CloneWarning bool

+ CreatedAt time.Time

+ GSI1PK string

+ GSI1SK string

+ ID string

+ LastUsedAt time.Time

+ Name string

+ PK string

+ PublicKey []byte

+ SK string

+ SignCount uint32

+ Type string

+ UserID string

+ func (WebAuthnCredential) TableName() string

+ func (w *WebAuthnCredential) BeforeCreate() error

+ func (w *WebAuthnCredential) BeforeUpdate() error

+ func (w *WebAuthnCredential) GetPK() string

+ func (w *WebAuthnCredential) GetSK() string

+ func (w *WebAuthnCredential) UpdateKeys() error

+ type WebSocketConnection struct

+ CloseCode int

+ CloseReason string

+ ConnectionID string

+ CurrentRate int

+ Established time.Time

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ IdleTimeout time.Duration

+ Info ConnectionInfo

+ LastActivity time.Time

+ MaxMessageSize int64

+ MaxRetries int

+ Metrics ConnectionMetrics

+ PK string

+ RateLimit int

+ RateLimitReset time.Time

+ RetryCount int

+ SK string

+ State ConnectionState

+ StateChangedAt time.Time

+ Streams []string

+ TTL int64

+ UserID string

+ Username string

+ func (w *WebSocketConnection) CalculateConnectionQuality() float64

+ func (w *WebSocketConnection) GetPK() string

+ func (w *WebSocketConnection) GetSK() string

+ func (w *WebSocketConnection) IncrementError(errorMsg string)

+ func (w *WebSocketConnection) IsActive(threshold time.Duration) bool

+ func (w *WebSocketConnection) IsHealthy() bool

+ func (w *WebSocketConnection) RecordMessage(sent bool, bytes int64)

+ func (w *WebSocketConnection) RecordPing()

+ func (w *WebSocketConnection) RecordPong()

+ func (w *WebSocketConnection) ShouldRetry() bool

+ func (w *WebSocketConnection) TableName() string

+ func (w *WebSocketConnection) UpdateKeys() error

+ func (w *WebSocketConnection) UpdateState(newState ConnectionState)

+ type WebSocketCostAggregation struct

+ AverageConnectionDuration float64

+ AverageMemoryUsage float64

+ AverageMessageSize float64

+ AverageProcessingTime float64

+ AverageResponseLatency float64

+ ConnectionDurationPercentiles map[string]float64

+ CostByTier map[string]*WebSocketTierCostStats

+ CostPerConnection float64

+ CostPerMessage float64

+ CostPerMinute float64

+ CostPerUser float64

+ CostPercentiles map[string]float64

+ CreatedAt time.Time

+ DroppedConnections int64

+ ErrorRate float64

+ ExpiresAt int64

+ FailedConnections int64

+ GSI1PK string

+ GSI1SK string

+ LatencyPercentiles map[string]float64

+ MaxConcurrentConnections int

+ MessageDeliveryFailures int64

+ MessageThroughputPerSec float64

+ OperationType string

+ PK string

+ Period string

+ SK string

+ StreamPopularity map[string]int64

+ StreamTypeBreakdown map[string]int64

+ TopUsers []string

+ TotalAPIGatewayConnectionCost int64

+ TotalAPIGatewayMessageCost int64

+ TotalConnectionMinutes int64

+ TotalConnections int64

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ TotalDataTransferCost int64

+ TotalDynamoDBCost int64

+ TotalLambdaExecutionCost int64

+ TotalMessageBytes int64

+ TotalMessagesIn int64

+ TotalMessagesOut int64

+ TotalStreamSubscriptions int64

+ UniqueStreamsUsed int64

+ UniqueUsers int64

+ UpdatedAt time.Time

+ UserBehaviorPatterns map[string]float64

+ UserEngagementScore float64

+ UserID string

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (WebSocketCostAggregation) TableName() string

+ func (w *WebSocketCostAggregation) BeforeCreate() error

+ func (w *WebSocketCostAggregation) BeforeUpdate() error

+ func (w *WebSocketCostAggregation) GetPK() string

+ func (w *WebSocketCostAggregation) GetSK() string

+ func (w *WebSocketCostAggregation) UpdateKeys() error

+ func (w *WebSocketCostAggregation) Validate() error

+ type WebSocketCostBreakdown struct

+ APIGatewayConnectionCost int64

+ APIGatewayMessageCost int64

+ DataTransferCost int64

+ LambdaExecutionCost int64

+ OperationType string

+ TotalCostMicroCents int64

+ func CalculateWebSocketCosts(operationType string, connectionMinutes, messageCount int64, dataMB float64, ...) *WebSocketCostBreakdown

+ func (WebSocketCostBreakdown) TableName() string

+ type WebSocketCostBudget struct

+ ActiveConnections int

+ AlertThresholds []int

+ AlertsSent []string

+ BillingTier string

+ BudgetMicroCents int64

+ ConnectionMinutesUsed int64

+ ConnectionsPerMinute int

+ CreatedAt time.Time

+ ExpiresAt int64

+ GSI1PK string

+ GSI1SK string

+ LastAlertSent time.Time

+ MaxConcurrentConnections int

+ MessagesPerMinute int

+ MessagesUsed int64

+ PK string

+ Period string

+ RemainingMicroCents int64

+ SK string

+ Status string

+ SuspendAt int

+ UpdatedAt time.Time

+ UsagePercent float64

+ UsedMicroCents int64

+ UserID string

+ Username string

+ WindowEnd time.Time

+ WindowStart time.Time

+ func (WebSocketCostBudget) TableName() string

+ func (w *WebSocketCostBudget) BeforeCreate() error

+ func (w *WebSocketCostBudget) BeforeUpdate() error

+ func (w *WebSocketCostBudget) GetPK() string

+ func (w *WebSocketCostBudget) GetSK() string

+ func (w *WebSocketCostBudget) UpdateKeys() error

+ func (w *WebSocketCostBudget) Validate() error

+ type WebSocketCostRecord struct

+ APIGatewayConnectionCost int64

+ APIGatewayMessageCost int64

+ ActiveStreams []string

+ AuthMethod string

+ ClientIP string

+ ConnectionDurationMs int64

+ ConnectionID string

+ ConnectionMinuteCost int64

+ ConnectionSource string

+ CreatedAt time.Time

+ DataTransferCost int64

+ DynamoDBCost int64

+ EstimatedCostDollars float64

+ ExpiresAt int64

+ FunctionName string

+ FunctionVersion string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ ID string

+ IdleTimeMs int64

+ LambdaExecutionCost int64

+ MemoryUsedMB float64

+ MessageCount int

+ MessageProcessingCost int64

+ MessageSizeBytes int64

+ OperationType string

+ PK string

+ ProcessingTimeMs int64

+ Properties map[string]interface{}

+ RequestID string

+ ResponseLatencyMs int64

+ SK string

+ ServiceName string

+ StreamCount int

+ StreamTypes []string

+ SubscriptionCost int64

+ Tags map[string]string

+ Timestamp time.Time

+ TotalCostMicroCents int64

+ UpdatedAt time.Time

+ UserAgent string

+ UserID string

+ Username string

+ func (WebSocketCostRecord) TableName() string

+ func (w *WebSocketCostRecord) AddTag(key, value string)

+ func (w *WebSocketCostRecord) BeforeCreate() error

+ func (w *WebSocketCostRecord) BeforeUpdate() error

+ func (w *WebSocketCostRecord) GetPK() string

+ func (w *WebSocketCostRecord) GetProperty(key string) (interface{}, bool)

+ func (w *WebSocketCostRecord) GetSK() string

+ func (w *WebSocketCostRecord) SetProperty(key string, value interface{})

+ func (w *WebSocketCostRecord) UpdateKeys() error

+ func (w *WebSocketCostRecord) Validate() error

+ type WebSocketCostRecordBuilder struct

+ func NewWebSocketCostRecordBuilder() *WebSocketCostRecordBuilder

+ func (WebSocketCostRecordBuilder) TableName() string

+ func (b *WebSocketCostRecordBuilder) Build() *WebSocketCostRecord

+ func (b *WebSocketCostRecordBuilder) ForOperation(operationType string) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithClient(clientIP, userAgent, source, authMethod string) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithConnection(connectionID, userID, username string) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithCosts(breakdown *WebSocketCostBreakdown) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithDuration(durationMs int64) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithMessages(count int, sizeBytes int64) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithPerformance(processingTimeMs, responseLatencyMs int64, memoryMB float64) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithProperty(key string, value interface{}) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithService(serviceName, functionName, requestID string) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithStreams(activeStreams, streamTypes []string) *WebSocketCostRecordBuilder

+ func (b *WebSocketCostRecordBuilder) WithTag(key, value string) *WebSocketCostRecordBuilder

+ type WebSocketEventConnection struct

+ ConnectedAt time.Time

+ ConnectionID string

+ GSI1PK string

+ GSI1SK string

+ LastSeen time.Time

+ PK string

+ SK string

+ TTL int64

+ UserID string

+ func (WebSocketEventConnection) TableName() string

+ func (w *WebSocketEventConnection) GetPK() string

+ func (w *WebSocketEventConnection) GetSK() string

+ func (w *WebSocketEventConnection) UpdateKeys() error

+ type WebSocketEventSubscription struct

+ ConnectionID string

+ CreatedAt time.Time

+ Filter map[string]any

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ SubscriptionType string

+ TTL int64

+ func (WebSocketEventSubscription) TableName() string

+ func (w *WebSocketEventSubscription) GetPK() string

+ func (w *WebSocketEventSubscription) GetSK() string

+ func (w *WebSocketEventSubscription) UpdateKeys() error

+ type WebSocketSubscription struct

+ ConnectionID string

+ GSI1PK string

+ GSI1SK string

+ PK string

+ SK string

+ Stream string

+ SubscribedAt time.Time

+ TTL int64

+ UserID string

+ func (w *WebSocketSubscription) GetPK() string

+ func (w *WebSocketSubscription) GetSK() string

+ func (w *WebSocketSubscription) TableName() string

+ func (w *WebSocketSubscription) UpdateKeys() error

+ type WebSocketTierCostStats struct

+ AverageCostPerUser float64

+ ConnectionMinutes int64

+ MessageCount int64

+ TierName string

+ TotalCostDollars float64

+ TotalCostMicroCents int64

+ UserCount int64

+ func (WebSocketTierCostStats) TableName() string

+ type WebhookDelivery struct

+ AlertID string

+ AttemptNumber int

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ DeliveryID string

+ Duration int64

+ ErrorMessage string

+ ErrorType string

+ GSI1PK string

+ GSI1SK string

+ GSI2PK string

+ GSI2SK string

+ Headers map[string]string

+ InsecureSkipTLSVerify bool

+ MaxAttempts int

+ NextRetryAt *time.Time

+ PK string

+ RequestBody string

+ ResponseBody string

+ ResponseCode int

+ ResponseHeaders map[string]string

+ RetryInterval int

+ SK string

+ ScheduledAt time.Time

+ SecretToken string

+ StartedAt *time.Time

+ Status string

+ TTL int64

+ Timeout int

+ URL string

+ UpdatedAt time.Time

+ WebhookID string

+ func (WebhookDelivery) TableName() string

+ func (w *WebhookDelivery) CanRetry() bool

+ func (w *WebhookDelivery) GetPK() string

+ func (w *WebhookDelivery) GetSK() string

+ func (w *WebhookDelivery) IsComplete() bool

+ func (w *WebhookDelivery) MarkFailed(errorMessage, errorType string, responseCode int, responseBody string, ...)

+ func (w *WebhookDelivery) MarkStarted()

+ func (w *WebhookDelivery) MarkSuccess(responseCode int, responseBody string, responseHeaders map[string]string, ...)

+ func (w *WebhookDelivery) ShouldRetry() bool

+ func (w *WebhookDelivery) UpdateKeys() error

+ type WeeklyActivity struct

+ Logins int64

+ PK string

+ Registrations int64

+ SK string

+ Statuses int64

+ UserID string

+ Week int64

+ func NewUserWeeklyActivity(userID string, week time.Time) *WeeklyActivity

+ func NewWeeklyActivity(week time.Time) *WeeklyActivity

+ func (WeeklyActivity) TableName() string

+ func (w *WeeklyActivity) GetAverageDaily() float64

+ func (w *WeeklyActivity) GetPK() string

+ func (w *WeeklyActivity) GetSK() string

+ func (w *WeeklyActivity) GetTotalActivity() int64

+ func (w *WeeklyActivity) GetWeekEnd() time.Time

+ func (w *WeeklyActivity) GetWeekStart() time.Time

+ func (w *WeeklyActivity) IncrementLogins(count int64)

+ func (w *WeeklyActivity) IncrementRegistrations(count int64)

+ func (w *WeeklyActivity) IncrementStatuses(count int64)

+ func (w *WeeklyActivity) IsActive() bool

+ func (w *WeeklyActivity) Merge(other *WeeklyActivity)

+ func (w *WeeklyActivity) UpdateKeys() error

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