Documentation
¶
Overview ¶
Package graph implements the GraphQL API schema and resolvers.
Index ¶
- Constants
- Variables
- func ApplyPaginationToResults[T any](results []T, opts *PaginationOptions, getID func(T) string, ...) ([]T, bool, bool, error)
- func BuildPageInfo(edges []interface{}, hasPreviousPage bool, hasNextPage bool, ...) *model.PageInfo
- func ConvertToDynamORMPagination(opts *PaginationOptions) (*repositories.PaginationOptions, error)
- func CreateAffectedRelationshipEdges[T any](items []T, ...) ([]*model.AffectedRelationshipEdge, error)
- func CreateHashtagEdges[T any](items []T, convertToHashtag func(T) (*model.Hashtag, error), ...) ([]*model.HashtagEdge, error)
- func CreateNotificationEdges[T any](items []T, convertToNotification func(T) (*model.Notification, error), ...) ([]*model.NotificationEdge, error)
- func CreateObjectEdges[T any](items []T, convertToObject func(T) (*model.Object, error), ...) ([]*model.ObjectEdge, error)
- func CreateSeveredRelationshipEdges[T any](items []T, ...) ([]*model.SeveredRelationshipEdge, error)
- func EncodeGraphQLCursor(data *CursorData) model.Cursor
- func ErrFailedToConvertAffectedRelationship(itemIndex int, err error) *errors.AppError
- func ErrFailedToConvertHashtag(itemIndex int, err error) *errors.AppError
- func ErrFailedToConvertItem(itemIndex int, err error) *errors.AppError
- func ErrFailedToConvertNotification(itemIndex int, err error) *errors.AppError
- func ErrFailedToConvertSeveredRelationship(itemIndex int, err error) *errors.AppError
- func ErrGetUpdatedListFailedWithContext(err error) *errors.AppError
- func ErrInvalidAfterCursorWithContext(err error) *errors.AppError
- func ErrInvalidBeforeCursorWithContext(err error) *errors.AppError
- func ErrInvalidCursorDataWithContext(err error) *errors.AppError
- func ErrInvalidCursorFormatWithContext(err error) *errors.AppError
- func ErrInvalidURLFormatWithValue(url string) *errors.AppError
- func ErrListMembershipFailedWithAction(actionName string) *errors.AppError
- func ErrModerationPatternNotFoundWithID(patternID string) *errors.AppError
- func ErrNoDomainFoundInURL(url string) *errors.AppError
- func ErrSocialActionFailedWithContext(actionName string, err error) *errors.AppError
- func ErrSocialUndoFailedWithContext(actionName string, err error) *errors.AppError
- func ErrUnsupportedTimelineTypeWithValue(timelineType interface{}) *errors.AppError
- func GetUserID(ctx context.Context) string
- func LoadActor(ctx context.Context, username string) (*activitypub.Actor, error)
- func LoadObject(ctx context.Context, id string) (any, error)
- func LoadQuoteTargetStatus(ctx context.Context, statusID string) (*models.Status, error)
- func LoadTrustScore(ctx context.Context, actorID, category string) (any, error)
- func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
- func QuoteLoaderMetrics(ctx context.Context) (hits, misses int64)
- func WithConnectionID(ctx context.Context, connectionID string) context.Context
- func WithLoaders(ctx context.Context, loaders *Loaders) context.Context
- type ActivityResolver
- type ActorResolver
- type AttachmentResolver
- type ComplexityRoot
- type Config
- type CursorData
- type DirectiveRoot
- type DriverResolver
- type EventConverter
- func (ec *EventConverter) ConvertToAIAnalysis(event *streaming.InternalEvent) *model.AIAnalysis
- func (ec *EventConverter) ConvertToBudgetAlert(event *streaming.InternalEvent) *model.BudgetAlert
- func (ec *EventConverter) ConvertToConversation(event *streaming.InternalEvent) *model.Conversation
- func (ec *EventConverter) ConvertToCostAlert(event *streaming.InternalEvent, thresholdUSD float64) *model.CostAlert
- func (ec *EventConverter) ConvertToCostUpdate(event *streaming.InternalEvent) *model.CostUpdate
- func (ec *EventConverter) ConvertToFederationHealthUpdate(event *streaming.InternalEvent) *model.FederationHealthUpdate
- func (ec *EventConverter) ConvertToHashtagActivity(event *streaming.InternalEvent) *model.HashtagActivityUpdate
- func (ec *EventConverter) ConvertToInfrastructureEvent(event *streaming.InternalEvent) *model.InfrastructureEvent
- func (ec *EventConverter) ConvertToListUpdate(event *streaming.InternalEvent) *model.ListUpdate
- func (ec *EventConverter) ConvertToMetricsUpdate(event *streaming.InternalEvent) *model.MetricsUpdate
- func (ec *EventConverter) ConvertToModerationAlert(event *streaming.InternalEvent, severity *model.ModerationSeverity) *model.ModerationAlert
- func (ec *EventConverter) ConvertToModerationDecision(event *streaming.InternalEvent) *moderation.ModerationDecision
- func (ec *EventConverter) ConvertToNotification(event *streaming.InternalEvent) *model.Notification
- func (ec *EventConverter) ConvertToObject(event *streaming.InternalEvent) *model.Object
- func (ec *EventConverter) ConvertToPerformanceAlert(event *streaming.InternalEvent) *model.PerformanceAlert
- func (ec *EventConverter) ConvertToQuoteActivity(event *streaming.InternalEvent) *model.QuoteActivityUpdate
- func (ec *EventConverter) ConvertToRelationshipUpdate(event *streaming.InternalEvent) *model.RelationshipUpdate
- func (ec *EventConverter) ConvertToThreatAlert(event *streaming.InternalEvent) *model.ThreatAlert
- func (ec *EventConverter) ConvertToTrustEdge(event *streaming.InternalEvent) *trust.TrustEdge
- type GraphQLSubscription
- type GraphQLSubscriptionManager
- func (sm *GraphQLSubscriptionManager) GetStats() map[string]interface{}
- func (sm *GraphQLSubscriptionManager) IsRunning() bool
- func (sm *GraphQLSubscriptionManager) Start(ctx context.Context) error
- func (sm *GraphQLSubscriptionManager) Stop() error
- func (sm *GraphQLSubscriptionManager) SubscribeToAIAnalysis(ctx context.Context, objectID *string) (<-chan *model.AIAnalysis, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToBudgetAlerts(ctx context.Context, username string, domain *string) (<-chan *model.BudgetAlert, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToConversation(ctx context.Context, username string) (<-chan *model.Conversation, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToCostAlerts(ctx context.Context, username string, thresholdUSD float64) (<-chan *model.CostAlert, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToCostUpdates(ctx context.Context, username string, threshold *int) (<-chan *model.CostUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToFederationHealth(ctx context.Context, username string, domain *string) (<-chan *model.FederationHealthUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToHashtagActivity(ctx context.Context, username string, hashtags []string) (<-chan *model.HashtagActivityUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToInfrastructureEvents(ctx context.Context, username string) (<-chan *model.InfrastructureEvent, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToListActivity(ctx context.Context, username string, listID string) (<-chan *model.ListUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToMetricsUpdates(ctx context.Context, username string, categories []string, services []string, ...) (<-chan *model.MetricsUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToModerationAlerts(ctx context.Context, username string, severity *model.ModerationSeverity) (<-chan *model.ModerationAlert, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToModerationEvents(ctx context.Context, actorID *string) (<-chan *moderation.ModerationDecision, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToModerationQueueUpdate(ctx context.Context, username string, priority *model.Priority) (<-chan *model.ModerationItem, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToNotifications(ctx context.Context, username string) (<-chan *model.Notification, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToPerformanceAlerts(ctx context.Context, username string, severity model.AlertSeverity) (<-chan *model.PerformanceAlert, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToQuoteActivity(ctx context.Context, username string, noteID string) (<-chan *model.QuoteActivityUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToRelationshipUpdates(ctx context.Context, username string, actorID *string) (<-chan *model.RelationshipUpdate, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToThreatIntelligence(ctx context.Context, username string) (<-chan *model.ThreatAlert, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToTimeline(ctx context.Context, username string, timelineType model.TimelineType) (<-chan *model.Object, error)
- func (sm *GraphQLSubscriptionManager) SubscribeToTrustUpdates(ctx context.Context, actorID string) (<-chan *trust.TrustEdge, error)
- type ImageAnalysisResolver
- type Loaders
- type ModerationDecisionResolver
- type ModerationFilterResolver
- type ModerationLabelResolver
- type ModerationPatternResolver
- type MutationResolver
- type ObjectResolver
- type PaginationOptions
- type QueryResolver
- type QuoteContextResolver
- type Resolver
- func (r *Resolver) Activity() ActivityResolver
- func (r *Resolver) Actor() ActorResolver
- func (r *Resolver) Attachment() AttachmentResolver
- func (r *Resolver) Driver() DriverResolver
- func (r *Resolver) ImageAnalysis() ImageAnalysisResolver
- func (r *Resolver) ModerationDecision() ModerationDecisionResolver
- func (r *Resolver) ModerationFilter() ModerationFilterResolver
- func (r *Resolver) ModerationLabel() ModerationLabelResolver
- func (r *Resolver) ModerationPattern() ModerationPatternResolver
- func (r *Resolver) Mutation() MutationResolver
- func (r *Resolver) Object() ObjectResolver
- func (r *Resolver) Query() QueryResolver
- func (r *Resolver) QuoteContext() QuoteContextResolver
- func (r *Resolver) Subscription() SubscriptionResolver
- func (r *Resolver) Tag() TagResolver
- func (r *Resolver) TextAnalysis() TextAnalysisResolver
- func (r *Resolver) TrustEdge() TrustEdgeResolver
- type ResolverRoot
- type SubscriptionManager
- func (sm *SubscriptionManager) GetStats() map[string]interface{}
- func (sm *SubscriptionManager) IsRunning() bool
- func (sm *SubscriptionManager) Start(ctx context.Context) error
- func (sm *SubscriptionManager) Stop() error
- func (sm *SubscriptionManager) SubscribeToAIAnalysisUpdates(ctx context.Context, objectID *string) (<-chan *model.AIAnalysis, error)
- func (sm *SubscriptionManager) SubscribeToActivityStream(ctx context.Context, username string, activityTypes []model.ActivityType) (<-chan *activitypub.Activity, error)
- func (sm *SubscriptionManager) SubscribeToBudgetAlerts(ctx context.Context, username string, domain *string) (<-chan *model.BudgetAlert, error)
- func (sm *SubscriptionManager) SubscribeToConversation(ctx context.Context, username string) (<-chan *model.Conversation, error)
- func (sm *SubscriptionManager) SubscribeToCostAlerts(ctx context.Context, username string, thresholdUSD float64) (<-chan *model.CostAlert, error)
- func (sm *SubscriptionManager) SubscribeToCostUpdates(ctx context.Context, username string, threshold *int) (<-chan *model.CostUpdate, error)
- func (sm *SubscriptionManager) SubscribeToFederationHealth(ctx context.Context, username string, domain *string) (<-chan *model.FederationHealthUpdate, error)
- func (sm *SubscriptionManager) SubscribeToHashtagActivity(ctx context.Context, username string, hashtags []string) (<-chan *model.HashtagActivityUpdate, error)
- func (sm *SubscriptionManager) SubscribeToInfrastructureEvents(ctx context.Context, username string) (<-chan *model.InfrastructureEvent, error)
- func (sm *SubscriptionManager) SubscribeToListActivity(ctx context.Context, username string, listID string) (<-chan *model.ListUpdate, error)
- func (sm *SubscriptionManager) SubscribeToMetricsUpdates(ctx context.Context, username string, categories []string, services []string, ...) (<-chan *model.MetricsUpdate, error)
- func (sm *SubscriptionManager) SubscribeToModerationAlerts(ctx context.Context, username string, severity *model.ModerationSeverity) (<-chan *model.ModerationAlert, error)
- func (sm *SubscriptionManager) SubscribeToModerationEvents(ctx context.Context, actorID *string) (<-chan *moderation.ModerationDecision, error)
- func (sm *SubscriptionManager) SubscribeToModerationQueueUpdate(ctx context.Context, username string, priority *model.Priority) (<-chan *model.ModerationItem, error)
- func (sm *SubscriptionManager) SubscribeToNotifications(ctx context.Context, username string) (<-chan *model.Notification, error)
- func (sm *SubscriptionManager) SubscribeToPerformanceAlerts(ctx context.Context, username string, severity model.AlertSeverity) (<-chan *model.PerformanceAlert, error)
- func (sm *SubscriptionManager) SubscribeToQuoteActivity(ctx context.Context, username string, noteID string) (<-chan *model.QuoteActivityUpdate, error)
- func (sm *SubscriptionManager) SubscribeToRelationshipUpdates(ctx context.Context, username string, actorID *string) (<-chan *model.RelationshipUpdate, error)
- func (sm *SubscriptionManager) SubscribeToThreatIntelligence(ctx context.Context, username string) (<-chan *model.ThreatAlert, error)
- func (sm *SubscriptionManager) SubscribeToTimelineUpdates(ctx context.Context, username string, timelineType model.TimelineType) (<-chan *model.Object, error)
- func (sm *SubscriptionManager) SubscribeToTrustUpdates(ctx context.Context, actorID string) (<-chan *trust.TrustEdge, error)
- type SubscriptionResolver
- type TagResolver
- type TextAnalysisResolver
- type TrustEdgeResolver
Constants ¶
const ( ContentTypeSpam = "spam" ContentTypeNote = "note" ContentType = "content" ContentTypeArticle = "article" ContentTypeImage = "image" ContentTypeEvent = "event" ContentTypeVideo = "video" )
Content type constants
const ( HealthStatusHealthy = "healthy" HealthStatusWarning = "warning" HealthStatusCritical = "critical" HealthStatusError = "error" HealthStatusUnknown = "unknown" )
Health status constants
const ( ServiceTypeTimeline = "timeline" ServiceTypeSearch = "search" ServiceTypeNotifications = "notifications" ServiceTypeTrust = "trust" )
Service type constants
const ( MetricTypeServiceStatus = "service_status" MetricTypePerformanceMetric = "performance_metric" )
Metric type constants
const ( SoftwareMastodon = "mastodon" SoftwarePleroma = "pleroma" SoftwareLemmy = "lemmy" SoftwarePeertube = "peertube" SoftwarePixelfed = "pixelfed" )
Federation software constants
const ( UserStatusSuspended = "suspended" UserStatusActive = "active" )
User status constants
const ( RelationshipFollowing = "following" RelationshipFollower = "follower" )
Relationship constants
const ( ActivityTypeMention = "Mention" ActivityTypeQuoteCreated = "quote_created" )
Activity type constants
const ( ModerationActionFlag = "flag" ModerationActionReview = "review" ModerationActionReject = "reject" ModerationActionApprove = "approve" )
Moderation action constants
const ( AdminAccountActionSensitive = "sensitive" AdminAccountActionUnsensitive = "unsensitive" AdminAccountActionSilence = "silence" AdminAccountActionSuspend = "suspend" )
Admin account action constants (Mastodon admin compatibility)
const ( DomainBlockSeveritySilence = "silence" DomainBlockSeveritySuspend = "suspend" )
Instance domain block severities
const ( QueryTypeActor = "actor" QueryTypeAll = "all" )
Query type constants
const ( PatternTypeRegex = "regex" PatternTypeKeyword = "keyword" PatternTypePhrase = "phrase" )
Pattern type constants
const ( SeverityHigh = "high" SeverityLow = "low" )
Severity constants
const ( SubscriptionTypeMetrics = "metrics" EventTypeFollowers = "followers" EventTypeCost = "cost" VisibilityPublic = "public" VisibilityUnlisted = "unlisted" VisibilityDisabled = "disabled" TagTypeMention = "Mention" )
Subscription and event type constants
const ( TimelineTypeHashtag = "hashtag" TimelineTypeList = "list" TimelineTypeHome = "home" TimelineTypeDirect = "direct" TimelineTypeUser = adminRoleUser TimelineTypeStatus = "status" )
Timeline and stream type constants
const ( AlertLevelLow = "LOW" AlertLevelMedium = "MEDIUM" AlertLevelHigh = "HIGH" AlertLevelCritical = "CRITICAL" )
Alert level constants
const ( ModerationActionHide = "hide" ModerationActionRemove = "remove" )
Moderation action constants
const ( VisibilityPrivate = "private" SeverityMedium = "medium" )
Visibility and severity constants
const ( VoteTypeHelpful = "helpful" VoteTypeNotHelpful = "not_helpful" )
Vote type constants
const ( JobStatusCompleted = "completed" JobStatusProcessing = "processing" JobStatusStatus = "status" )
Job status constants
const ( DynamoOperationRead = "read" DynamoOperationQuery = "query" )
DynamoDB operation constants
const (
AccountType = "account"
)
Account type constants
const (
DomainLocalhost = "localhost"
)
Domain constants
const (
EventTypeFlagged = "flagged"
)
Event type constants
const (
MockPublicKey = `-----BEGIN PUBLIC KEY-----
MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8A...
-----END PUBLIC KEY-----`
)
Public key constant
const (
NoneValue = "none"
)
None constant
const (
ObjectTypeStatus = "status"
)
Object type constants
const (
QuoteType = "quote"
)
Quote type constants
const (
RSAPublicKeyEnd = "-----END PUBLIC KEY-----"
)
RSA key markers
const (
StreamNamePublic = "public"
)
Stream name constants
const (
TextType = "text"
)
Text type constants
Variables ¶
var ( // Authentication and authorization errors ErrAuthenticationRequired = errors.NewAuthError(errors.CodeUnauthorized, "authentication required") ErrAccessDenied = errors.AccessDeniedForResource("resource", "unknown") ErrAdminPrivilegesRequired = errors.InsufficientPermissions("admin operation") ErrModeratorPrivilegesRequired = errors.InsufficientPermissions("admin or moderator operation") // Validation errors ErrEitherIDOrUsernameRequired = errors.NewValidationError("identifier", "either id or username must be provided") ErrHashtagParameterRequired = errors.NewValidationError("hashtag", "parameter required for hashtag timeline") ErrListIDParameterRequired = errors.NewValidationError("listId", "parameter required for list timeline") ErrActorIDParameterRequired = errors.NewValidationError("actorId", "parameter required for ACTOR timeline") ErrTrusteeIDRequired = errors.NewValidationError("trustee_id", "required") ErrObjectIDRequired = errors.NewValidationError("objectId", "required") ErrReasonRequired = errors.NewValidationError("reason", "required") ErrActorIDRequired = errors.NewValidationError("actorID", "required") ErrEmptyURL = errors.NewValidationError("url", "cannot be empty") // Business logic validation errors ErrTrustScoreRange = errors.NewValidationError("trust_score", "must be between -1.0 and 1.0") ErrCannotTrustYourself = errors.OperationNotAllowedOnSelf("trust") ErrScheduledTimeMinimum = errors.NewValidationError("scheduled_time", "must be at least 5 minutes in the future") ErrScheduledTimeMaximum = errors.NewValidationError("scheduled_time", "cannot be more than 1 year in the future") ErrAuthorsCannotVote = errors.OperationNotAllowedOnSelf("vote on note") ErrOwnerOnlyOperation = errors.InsufficientPermissions("owner only operation") // Timeline type errors ErrUnsupportedTimelineType = errors.UnsupportedTimelineType("unknown") ErrAuthRequiredForHome = errors.NewAuthError(errors.CodeUnauthorized, "authentication required for home timeline") ErrAuthRequiredForDirect = errors.NewAuthError(errors.CodeUnauthorized, "authentication required for direct timeline") // Service unavailability errors // Repository unavailability errors // Not found errors ErrObjectNotFound = errors.NewAppError(errors.CodeNotFound, errors.CategoryBusiness, "object not found") ErrCommunityNoteNotFound = errors.NewAppError(errors.CodeNotFound, errors.CategoryBusiness, "community note not found") ErrListNotFoundOrAccessDenied = errors.NewAppError(errors.CodeNotFound, errors.CategoryAuth, "list not found or access denied") ErrModerationPatternNotFound = errors.NewAppError(errors.CodeNotFound, errors.CategoryBusiness, "moderation pattern not found") // Format and parsing errors ErrInvalidURLFormat = errors.NewValidationError("url", "invalid format") ErrInvalidMediaURLFormat = errors.NewValidationError("media_url", "invalid format") ErrInvalidMediaURLSegments = errors.NewValidationError("media_url", "not enough path segments") ErrInvalidMediaURLMissingPrefix = errors.NewValidationError("media_url", "missing 'media' prefix") ErrInvalidMediaURLMissingID = errors.NewValidationError("media_url", "missing media ID") ErrInvalidMediaIDFormat = errors.NewValidationError("media_id", "invalid format") ErrInvalidTrustScoreKey = errors.NewValidationError("trust_score_key", "invalid format") ErrNoDomainInURL = errors.NewValidationError("url", "no domain found") // Content processing errors ErrUnableToConvertObject = errors.ProcessingFailed("object conversion", stdErrors.New("failed to convert object")) ErrStatusIsNotNote = errors.NewValidationError("status_type", "is not a note") ErrCannotDetermineOwnership = errors.ProcessingFailed("ownership determination", stdErrors.New("failed to determine ownership")) ErrUnexpectedStatsType = errors.NewValidationError("stats_type", "unexpected type from AI service") ErrCacheMiss = errors.NewAppError(errors.CodeNotFound, errors.CategoryInternal, "cache miss") ErrNoteCreationReturnedNoNote = errors.ProcessingFailed("note creation", stdErrors.New("note creation returned no note")) ErrFederationFetchRepliesUnavailable = errors.ServiceUnavailable("federation fetch replies") // Helper operation errors ErrSocialActionFailed = errors.ProcessingFailed("social action", stdErrors.New("social action failed")) ErrSocialUndoFailed = errors.ProcessingFailed("social undo action", stdErrors.New("social undo action failed")) ErrListMembershipFailed = errors.ProcessingFailed("list membership operation", stdErrors.New("list membership operation failed")) ErrNoAccountsProcessed = errors.ProcessingFailed("account processing", stdErrors.New("no accounts processed")) ErrGetUpdatedListFailed = errors.ProcessingFailed("get updated list", stdErrors.New("failed to get updated list")) // Subscription manager errors ErrSubscriptionManagerAlreadyRunning = errors.InvalidStateForOperation("not running", "start subscription manager") ErrSubscriptionManagerNotRunning = errors.InvalidStateForOperation("running", "stop subscription manager") ErrAtLeastOneHashtagRequired = errors.NewValidationError("hashtags", "at least one must be specified") ErrNoteIDCannotBeEmpty = errors.NewValidationError("noteID", "cannot be empty") ErrUsernameCannotBeEmpty = errors.NewValidationError("username", "cannot be empty") ErrListIDCannotBeEmpty = errors.NewValidationError("listID", "cannot be empty") // Pagination errors ErrPaginationMixedParams = errors.NewValidationError("pagination", "cannot use first/after with last/before") ErrFirstMustBePositive = errors.NewValidationError("first", "must be positive") ErrLastMustBePositive = errors.NewValidationError("last", "must be positive") ErrInvalidCursorFormat = errors.NewValidationError("cursor", "invalid format") ErrInvalidCursorData = errors.NewValidationError("cursor", "invalid data") ErrInvalidAfterCursor = errors.NewValidationError("after_cursor", "invalid") ErrInvalidBeforeCursor = errors.NewValidationError("before_cursor", "invalid") )
GraphQL resolver errors
var ( ErrThreadsServiceUnavailable = errors.New("threads service is not available") )
Functions ¶
func ApplyPaginationToResults ¶
func ApplyPaginationToResults[T any]( results []T, opts *PaginationOptions, getID func(T) string, getTimestamp func(T) time.Time, getScore func(T) float64, ) ([]T, bool, bool, error)
ApplyPaginationToResults applies pagination logic to results and returns proper hasNextPage/hasPreviousPage
func BuildPageInfo ¶
func BuildPageInfo(
edges []interface{},
hasPreviousPage bool,
hasNextPage bool,
getCursor func(interface{}) model.Cursor,
) *model.PageInfo
BuildPageInfo creates PageInfo for GraphQL connections
func ConvertToDynamORMPagination ¶
func ConvertToDynamORMPagination(opts *PaginationOptions) (*repositories.PaginationOptions, error)
ConvertToDynamORMPagination converts GraphQL pagination to DynamORM pagination
func CreateAffectedRelationshipEdges ¶
func CreateAffectedRelationshipEdges[T any]( items []T, convertToAffectedRelationship func(T) (*model.AffectedRelationship, error), getID func(T) string, getTimestamp func(T) time.Time, ) ([]*model.AffectedRelationshipEdge, error)
CreateAffectedRelationshipEdges creates AffectedRelationshipEdge array
func CreateHashtagEdges ¶
func CreateHashtagEdges[T any]( items []T, convertToHashtag func(T) (*model.Hashtag, error), getID func(T) string, getTimestamp func(T) time.Time, ) ([]*model.HashtagEdge, error)
CreateHashtagEdges creates HashtagEdge array from hashtags
func CreateNotificationEdges ¶
func CreateNotificationEdges[T any]( items []T, convertToNotification func(T) (*model.Notification, error), getID func(T) string, getTimestamp func(T) time.Time, ) ([]*model.NotificationEdge, error)
CreateNotificationEdges creates NotificationEdge array from notifications
func CreateObjectEdges ¶
func CreateObjectEdges[T any]( items []T, convertToObject func(T) (*model.Object, error), getID func(T) string, getTimestamp func(T) time.Time, getScore func(T) float64, ) ([]*model.ObjectEdge, error)
CreateObjectEdges creates ObjectEdge array from objects
func CreateSeveredRelationshipEdges ¶
func CreateSeveredRelationshipEdges[T any]( items []T, convertToSeveredRelationship func(T) (*model.SeveredRelationship, error), getID func(T) string, getTimestamp func(T) time.Time, ) ([]*model.SeveredRelationshipEdge, error)
CreateSeveredRelationshipEdges creates SeveredRelationshipEdge array
func EncodeGraphQLCursor ¶
func EncodeGraphQLCursor(data *CursorData) model.Cursor
EncodeGraphQLCursor creates an opaque cursor from cursor data
func ErrFailedToConvertAffectedRelationship ¶
ErrFailedToConvertAffectedRelationship returns an error for when affected relationship conversion fails at a specific index.
func ErrFailedToConvertHashtag ¶
ErrFailedToConvertHashtag returns an error for when hashtag conversion fails at a specific index.
func ErrFailedToConvertItem ¶
ErrFailedToConvertItem returns an error for when item conversion fails at a specific index.
func ErrFailedToConvertNotification ¶
ErrFailedToConvertNotification returns an error for when notification conversion fails at a specific index.
func ErrFailedToConvertSeveredRelationship ¶
ErrFailedToConvertSeveredRelationship returns an error for when severed relationship conversion fails at a specific index.
func ErrGetUpdatedListFailedWithContext ¶
ErrGetUpdatedListFailedWithContext returns an error for when getting an updated list fails with additional context.
func ErrInvalidAfterCursorWithContext ¶
ErrInvalidAfterCursorWithContext returns an error for invalid after cursor with additional context.
func ErrInvalidBeforeCursorWithContext ¶
ErrInvalidBeforeCursorWithContext returns an error for invalid before cursor with additional context.
func ErrInvalidCursorDataWithContext ¶
ErrInvalidCursorDataWithContext returns an error for invalid cursor data with additional context.
func ErrInvalidCursorFormatWithContext ¶
ErrInvalidCursorFormatWithContext returns an error for invalid cursor format with additional context.
func ErrInvalidURLFormatWithValue ¶
ErrInvalidURLFormatWithValue returns an error for invalid URL formats with the specific URL value.
func ErrListMembershipFailedWithAction ¶
ErrListMembershipFailedWithAction returns an error for when list membership operations fail with a specific action.
func ErrModerationPatternNotFoundWithID ¶
ErrModerationPatternNotFoundWithID returns an error for when a moderation pattern is not found with the given ID.
func ErrNoDomainFoundInURL ¶
ErrNoDomainFoundInURL returns an error when no domain is found in the given URL.
func ErrSocialActionFailedWithContext ¶
ErrSocialActionFailedWithContext returns an error for when a social action fails with additional context.
func ErrSocialUndoFailedWithContext ¶
ErrSocialUndoFailedWithContext returns an error for when a social undo action fails with additional context.
func ErrUnsupportedTimelineTypeWithValue ¶
ErrUnsupportedTimelineTypeWithValue returns an error for unsupported timeline types with the specific value.
func LoadObject ¶
LoadObject loads an object using DataLoader
func LoadQuoteTargetStatus ¶
LoadQuoteTargetStatus loads a quote target status using the dedicated DataLoader
func LoadTrustScore ¶
LoadTrustScore loads a trust score using DataLoader
func NewExecutableSchema ¶
func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.
func QuoteLoaderMetrics ¶
QuoteLoaderMetrics exposes aggregated loader cache metrics for logging/monitoring.
func WithConnectionID ¶
WithConnectionID adds connection ID to context
Types ¶
type ActivityResolver ¶
type ActivityResolver interface {
Type(ctx context.Context, obj *activitypub.Activity) (model.ActivityType, error)
Actor(ctx context.Context, obj *activitypub.Activity) (*activitypub.Actor, error)
Object(ctx context.Context, obj *activitypub.Activity) (*model.Object, error)
Target(ctx context.Context, obj *activitypub.Activity) (*model.Object, error)
Published(ctx context.Context, obj *activitypub.Activity) (*model.Time, error)
Cost(ctx context.Context, obj *activitypub.Activity) (int, error)
}
type ActorResolver ¶
type ActorResolver interface {
Username(ctx context.Context, obj *activitypub.Actor) (string, error)
Domain(ctx context.Context, obj *activitypub.Actor) (*string, error)
DisplayName(ctx context.Context, obj *activitypub.Actor) (*string, error)
Avatar(ctx context.Context, obj *activitypub.Actor) (*string, error)
Header(ctx context.Context, obj *activitypub.Actor) (*string, error)
Followers(ctx context.Context, obj *activitypub.Actor) (int, error)
Following(ctx context.Context, obj *activitypub.Actor) (int, error)
StatusesCount(ctx context.Context, obj *activitypub.Actor) (int, error)
Bot(ctx context.Context, obj *activitypub.Actor) (bool, error)
Locked(ctx context.Context, obj *activitypub.Actor) (bool, error)
CreatedAt(ctx context.Context, obj *activitypub.Actor) (*model.Time, error)
UpdatedAt(ctx context.Context, obj *activitypub.Actor) (*model.Time, error)
Fields(ctx context.Context, obj *activitypub.Actor) ([]*model.Field, error)
TipAddress(ctx context.Context, obj *activitypub.Actor) (*string, error)
TipChainID(ctx context.Context, obj *activitypub.Actor) (*int, error)
TrustScore(ctx context.Context, obj *activitypub.Actor) (float64, error)
Reputation(ctx context.Context, obj *activitypub.Actor) (*model.Reputation, error)
Vouches(ctx context.Context, obj *activitypub.Actor) ([]*model.Vouch, error)
}
type AttachmentResolver ¶
type AttachmentResolver interface {
ID(ctx context.Context, obj *activitypub.Attachment) (string, error)
Preview(ctx context.Context, obj *activitypub.Attachment) (*string, error)
Description(ctx context.Context, obj *activitypub.Attachment) (*string, error)
Blurhash(ctx context.Context, obj *activitypub.Attachment) (*string, error)
Duration(ctx context.Context, obj *activitypub.Attachment) (*float64, error)
}
type ComplexityRoot ¶
type ComplexityRoot struct {
AIAnalysis struct {
AiDetection func(childComplexity int) int
AnalyzedAt func(childComplexity int) int
Confidence func(childComplexity int) int
ID func(childComplexity int) int
ImageAnalysis func(childComplexity int) int
ModerationAction func(childComplexity int) int
ObjectID func(childComplexity int) int
ObjectType func(childComplexity int) int
OverallRisk func(childComplexity int) int
SpamAnalysis func(childComplexity int) int
TextAnalysis func(childComplexity int) int
}
AIAnalysisRequest struct {
EstimatedTime func(childComplexity int) int
Message func(childComplexity int) int
ObjectID func(childComplexity int) int
}
AICapabilities struct {
AiDetection func(childComplexity int) int
CostPerAnalysis func(childComplexity int) int
ImageAnalysis func(childComplexity int) int
ModerationActions func(childComplexity int) int
TextAnalysis func(childComplexity int) int
}
AIDetection struct {
AiGeneratedProbability func(childComplexity int) int
GenerationModel func(childComplexity int) int
PatternConsistency func(childComplexity int) int
SemanticCoherence func(childComplexity int) int
StyleDeviation func(childComplexity int) int
SuspiciousPatterns func(childComplexity int) int
}
AIDetectionCapabilities struct {
AiGeneratedContent func(childComplexity int) int
PatternAnalysis func(childComplexity int) int
StyleConsistency func(childComplexity int) int
}
AIStats struct {
AiContentRate func(childComplexity int) int
AiGenerated func(childComplexity int) int
ModerationActions func(childComplexity int) int
NsfwContent func(childComplexity int) int
NsfwRate func(childComplexity int) int
Period func(childComplexity int) int
PiiDetected func(childComplexity int) int
SpamDetected func(childComplexity int) int
SpamRate func(childComplexity int) int
TotalAnalyses func(childComplexity int) int
ToxicContent func(childComplexity int) int
ToxicityRate func(childComplexity int) int
}
AccessLog struct {
Cost func(childComplexity int) int
Operation func(childComplexity int) int
Timestamp func(childComplexity int) int
}
AccountQuotePermissions struct {
AllowFollowers func(childComplexity int) int
AllowMentioned func(childComplexity int) int
AllowPublic func(childComplexity int) int
BlockList func(childComplexity int) int
Username func(childComplexity int) int
}
AccountSuggestion struct {
Account func(childComplexity int) int
Reason func(childComplexity int) int
Source func(childComplexity int) int
}
AcknowledgePayload struct {
Acknowledged func(childComplexity int) int
SeveredRelationship func(childComplexity int) int
Success func(childComplexity int) int
}
Activity struct {
Actor func(childComplexity int) int
Cost func(childComplexity int) int
ID func(childComplexity int) int
Object func(childComplexity int) int
Published func(childComplexity int) int
Target func(childComplexity int) int
Type func(childComplexity int) int
}
Actor struct {
Avatar func(childComplexity int) int
Bot func(childComplexity int) int
CreatedAt func(childComplexity int) int
DisplayName func(childComplexity int) int
Domain func(childComplexity int) int
Fields func(childComplexity int) int
Followers func(childComplexity int) int
Following func(childComplexity int) int
Header func(childComplexity int) int
ID func(childComplexity int) int
Locked func(childComplexity int) int
Reputation func(childComplexity int) int
StatusesCount func(childComplexity int) int
Summary func(childComplexity int) int
TipAddress func(childComplexity int) int
TipChainID func(childComplexity int) int
TrustScore func(childComplexity int) int
UpdatedAt func(childComplexity int) int
Username func(childComplexity int) int
Vouches func(childComplexity int) int
}
ActorListPage struct {
Actors func(childComplexity int) int
NextCursor func(childComplexity int) int
TotalCount func(childComplexity int) int
}
AdminAccount struct {
Actor func(childComplexity int) int
Approved func(childComplexity int) int
Confirmed func(childComplexity int) int
CreatedAt func(childComplexity int) int
Disabled func(childComplexity int) int
ID func(childComplexity int) int
IP func(childComplexity int) int
Ips func(childComplexity int) int
Locale func(childComplexity int) int
ReportsCount func(childComplexity int) int
ResolvedReportsCount func(childComplexity int) int
Role func(childComplexity int) int
Silenced func(childComplexity int) int
Suspended func(childComplexity int) int
Username func(childComplexity int) int
}
AdminAccountConnection struct {
Accounts func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminDomainAllow struct {
CreatedAt func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
}
AdminDomainAllowConnection struct {
Allows func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminDomainBlock struct {
CreatedAt func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
Obfuscate func(childComplexity int) int
PrivateComment func(childComplexity int) int
PublicComment func(childComplexity int) int
RejectMedia func(childComplexity int) int
RejectReports func(childComplexity int) int
Severity func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
AdminDomainBlockConnection struct {
Blocks func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminEmailDomainBlock struct {
CreatedAt func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
}
AdminEmailDomainBlockConnection struct {
Blocks func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminFederationInstance struct {
DetailsJSON func(childComplexity int) int
Instance func(childComplexity int) int
}
AdminFederationInstanceConnection struct {
Instances func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminFederationInstanceInfo struct {
ActiveUsers func(childComplexity int) int
Domain func(childComplexity int) int
FirstSeen func(childComplexity int) int
IsSilenced func(childComplexity int) int
IsSuspended func(childComplexity int) int
LastSeen func(childComplexity int) int
Software func(childComplexity int) int
TotalMessages func(childComplexity int) int
TrustScore func(childComplexity int) int
Version func(childComplexity int) int
}
AdminFederationStatistics struct {
ActiveInstances func(childComplexity int) int
TimeRange func(childComplexity int) int
TotalMessages func(childComplexity int) int
TotalUsers func(childComplexity int) int
}
AdminFederationStatisticsTimeRange struct {
End func(childComplexity int) int
Start func(childComplexity int) int
}
AdminIP struct {
IP func(childComplexity int) int
UsedAt func(childComplexity int) int
}
AdminModerationEvent struct {
ActorID func(childComplexity int) int
Category func(childComplexity int) int
ConfidenceScore func(childComplexity int) int
CreatedAt func(childComplexity int) int
EventType func(childComplexity int) int
EvidenceJSON func(childComplexity int) int
ID func(childComplexity int) int
ObjectID func(childComplexity int) int
ObjectType func(childComplexity int) int
Reason func(childComplexity int) int
Severity func(childComplexity int) int
}
AdminModerationEventConnection struct {
Events func(childComplexity int) int
NextCursor func(childComplexity int) int
}
AdminModerationEventOverrideResult struct {
Action func(childComplexity int) int
Admin func(childComplexity int) int
Decision func(childComplexity int) int
EventID func(childComplexity int) int
Override func(childComplexity int) int
Reason func(childComplexity int) int
}
AdminReport struct {
ActionTaken func(childComplexity int) int
ActionTakenAt func(childComplexity int) int
ActionTakenBy func(childComplexity int) int
AssignedAccount func(childComplexity int) int
Category func(childComplexity int) int
Comment func(childComplexity int) int
CreatedAt func(childComplexity int) int
Forwarded func(childComplexity int) int
ID func(childComplexity int) int
Reporter func(childComplexity int) int
Statuses func(childComplexity int) int
Target func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
AdminReportConnection struct {
NextCursor func(childComplexity int) int
Reports func(childComplexity int) int
}
AdminReviewer struct {
AccuracyRate func(childComplexity int) int
AccurateReviews func(childComplexity int) int
ID func(childComplexity int) int
LastReviewAt func(childComplexity int) int
Role func(childComplexity int) int
TotalReviews func(childComplexity int) int
Username func(childComplexity int) int
}
AdminReviewerRoleResult struct {
NewRole func(childComplexity int) int
UpdatedBy func(childComplexity int) int
UserID func(childComplexity int) int
Username func(childComplexity int) int
}
AdminRole struct {
ID func(childComplexity int) int
Name func(childComplexity int) int
Permissions func(childComplexity int) int
}
AdminStatusConnection struct {
NextCursor func(childComplexity int) int
Statuses func(childComplexity int) int
}
AdminTrustGraph struct {
Edges func(childComplexity int) int
Nodes func(childComplexity int) int
Stats func(childComplexity int) int
}
AdminTrustGraphEdge struct {
CreatedAt func(childComplexity int) int
From func(childComplexity int) int
To func(childComplexity int) int
Trust func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
AdminTrustGraphNode struct {
ID func(childComplexity int) int
Type func(childComplexity int) int
}
AdminTrustGraphStats struct {
TotalEdges func(childComplexity int) int
TotalNodes func(childComplexity int) int
}
AdminUpdateTrustResult struct {
Category func(childComplexity int) int
FromActorID func(childComplexity int) int
Reason func(childComplexity int) int
ToActorID func(childComplexity int) int
Trust func(childComplexity int) int
UpdatedAt func(childComplexity int) int
UpdatedBy func(childComplexity int) int
}
AffectedRelationship struct {
Actor func(childComplexity int) int
EstablishedAt func(childComplexity int) int
LastInteraction func(childComplexity int) int
RelationshipType func(childComplexity int) int
}
AffectedRelationshipConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
AffectedRelationshipEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
Agent struct {
ActivityCount func(childComplexity int) int
Capabilities func(childComplexity int) int
CreatedAt func(childComplexity int) int
DisplayName func(childComplexity int) int
ID func(childComplexity int) int
Owner func(childComplexity int) int
Type func(childComplexity int) int
Username func(childComplexity int) int
Version func(childComplexity int) int
}
AgentActivityEvent struct {
Action func(childComplexity int) int
AgentUsername func(childComplexity int) int
EventID func(childComplexity int) int
MetadataJSON func(childComplexity int) int
TargetID func(childComplexity int) int
Timestamp func(childComplexity int) int
}
AgentCapabilities struct {
CanBoost func(childComplexity int) int
CanDM func(childComplexity int) int
CanFollow func(childComplexity int) int
CanPost func(childComplexity int) int
CanReply func(childComplexity int) int
MaxPostsPerHour func(childComplexity int) int
RequiresApproval func(childComplexity int) int
RestrictedDomains func(childComplexity int) int
}
AgentConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
AgentEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
Announcement struct {
AllDay func(childComplexity int) int
Content func(childComplexity int) int
EndsAt func(childComplexity int) int
ID func(childComplexity int) int
PublishedAt func(childComplexity int) int
Reactions func(childComplexity int) int
Read func(childComplexity int) int
StartsAt func(childComplexity int) int
Text func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
AnnouncementReaction struct {
Count func(childComplexity int) int
Me func(childComplexity int) int
Name func(childComplexity int) int
StaticURL func(childComplexity int) int
URL func(childComplexity int) int
}
Article struct {
Author func(childComplexity int) int
CanonicalURL func(childComplexity int) int
Categories func(childComplexity int) int
Content func(childComplexity int) int
ContentFormat func(childComplexity int) int
CreatedAt func(childComplexity int) int
EditorNotes func(childComplexity int) int
Excerpt func(childComplexity int) int
FeaturedImage func(childComplexity int) int
ID func(childComplexity int) int
OGImage func(childComplexity int) int
PublishedAt func(childComplexity int) int
ReadingTimeMinutes func(childComplexity int) int
ReviewStatus func(childComplexity int) int
SEODescription func(childComplexity int) int
SEOTitle func(childComplexity int) int
Series func(childComplexity int) int
SeriesOrder func(childComplexity int) int
Slug func(childComplexity int) int
Subtitle func(childComplexity int) int
TableOfContents func(childComplexity int) int
Title func(childComplexity int) int
UpdatedAt func(childComplexity int) int
WordCount func(childComplexity int) int
}
ArticleConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
ArticleEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
Attachment struct {
Blurhash func(childComplexity int) int
Description func(childComplexity int) int
Duration func(childComplexity int) int
Height func(childComplexity int) int
ID func(childComplexity int) int
Preview func(childComplexity int) int
Type func(childComplexity int) int
URL func(childComplexity int) int
Width func(childComplexity int) int
}
BandwidthReport struct {
AvgMbps func(childComplexity int) int
ByHour func(childComplexity int) int
ByQuality func(childComplexity int) int
Cost func(childComplexity int) int
PeakMbps func(childComplexity int) int
Period func(childComplexity int) int
TotalGb func(childComplexity int) int
}
Bitrate struct {
BitsPerSecond func(childComplexity int) int
Codec func(childComplexity int) int
Height func(childComplexity int) int
Quality func(childComplexity int) int
Width func(childComplexity int) int
}
BudgetAlert struct {
AlertLevel func(childComplexity int) int
BudgetUsd func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
PercentUsed func(childComplexity int) int
ProjectedOverspend func(childComplexity int) int
SpentUsd func(childComplexity int) int
Timestamp func(childComplexity int) int
}
Category struct {
ArticleCount func(childComplexity int) int
Children func(childComplexity int) int
Color func(childComplexity int) int
CreatedAt func(childComplexity int) int
Description func(childComplexity int) int
ID func(childComplexity int) int
Name func(childComplexity int) int
Order func(childComplexity int) int
Parent func(childComplexity int) int
Slug func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
CategoryStats struct {
Accuracy func(childComplexity int) int
Category func(childComplexity int) int
Count func(childComplexity int) int
}
Celebrity struct {
Confidence func(childComplexity int) int
Name func(childComplexity int) int
Urls func(childComplexity int) int
}
CommunityNote struct {
Author func(childComplexity int) int
Content func(childComplexity int) int
CreatedAt func(childComplexity int) int
Helpful func(childComplexity int) int
ID func(childComplexity int) int
NotHelpful func(childComplexity int) int
}
CommunityNoteConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
CommunityNoteEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
CommunityNotePayload struct {
Note func(childComplexity int) int
Object func(childComplexity int) int
}
ContentMap struct {
Content func(childComplexity int) int
Language func(childComplexity int) int
}
Conversation struct {
Accounts func(childComplexity int) int
CreatedAt func(childComplexity int) int
ID func(childComplexity int) int
LastStatus func(childComplexity int) int
Unread func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
Coordinates struct {
X func(childComplexity int) int
Y func(childComplexity int) int
}
CostAlert struct {
Amount func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
Message func(childComplexity int) int
Threshold func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
CostBreakdown struct {
Breakdown func(childComplexity int) int
DataTransferCost func(childComplexity int) int
DynamoDBCost func(childComplexity int) int
LambdaCost func(childComplexity int) int
Period func(childComplexity int) int
S3StorageCost func(childComplexity int) int
TotalCost func(childComplexity int) int
}
CostItem struct {
Cost func(childComplexity int) int
Count func(childComplexity int) int
Operation func(childComplexity int) int
}
CostOptimizationResult struct {
Actions func(childComplexity int) int
Optimized func(childComplexity int) int
SavedMonthlyUsd func(childComplexity int) int
}
CostProjection struct {
CurrentCost func(childComplexity int) int
Period func(childComplexity int) int
ProjectedCost func(childComplexity int) int
Recommendations func(childComplexity int) int
TopDrivers func(childComplexity int) int
Variance func(childComplexity int) int
}
CostUpdate struct {
DailyTotal func(childComplexity int) int
MonthlyProjection func(childComplexity int) int
OperationCost func(childComplexity int) int
}
CreateNotePayload struct {
Activity func(childComplexity int) int
Cost func(childComplexity int) int
Object func(childComplexity int) int
}
CustomEmoji struct {
Category func(childComplexity int) int
CreatedAt func(childComplexity int) int
Domain func(childComplexity int) int
ID func(childComplexity int) int
Shortcode func(childComplexity int) int
StaticURL func(childComplexity int) int
URL func(childComplexity int) int
UpdatedAt func(childComplexity int) int
VisibleInPicker func(childComplexity int) int
}
DatabaseStatus struct {
Connections func(childComplexity int) int
Latency func(childComplexity int) int
Name func(childComplexity int) int
Status func(childComplexity int) int
Throughput func(childComplexity int) int
Type func(childComplexity int) int
}
DelegationPayload struct {
AccessToken func(childComplexity int) int
Agent func(childComplexity int) int
CreatedAt func(childComplexity int) int
Scope func(childComplexity int) int
TokenType func(childComplexity int) int
}
DiscoveryPreferences struct {
PersonalizedSearchEnabled func(childComplexity int) int
SearchSuggestionsEnabled func(childComplexity int) int
ShowFollowCounts func(childComplexity int) int
}
DomainBlockPage struct {
Domains func(childComplexity int) int
NextCursor func(childComplexity int) int
TotalCount func(childComplexity int) int
}
Draft struct {
Author func(childComplexity int) int
AutosaveVersion func(childComplexity int) int
Content func(childComplexity int) int
ContentFormat func(childComplexity int) int
ContentType func(childComplexity int) int
CreatedAt func(childComplexity int) int
ID func(childComplexity int) int
LastSavedAt func(childComplexity int) int
ObjectID func(childComplexity int) int
ScheduledAt func(childComplexity int) int
Slug func(childComplexity int) int
Status func(childComplexity int) int
Title func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
DraftConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
DraftEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
Driver struct {
Cost func(childComplexity int) int
Domain func(childComplexity int) int
PercentOfTotal func(childComplexity int) int
Trend func(childComplexity int) int
Type func(childComplexity int) int
}
Entity struct {
Score func(childComplexity int) int
Text func(childComplexity int) int
Type func(childComplexity int) int
}
ExportJob struct {
CreatedAt func(childComplexity int) int
DownloadURL func(childComplexity int) int
Error func(childComplexity int) int
ExpiresAt func(childComplexity int) int
FileSize func(childComplexity int) int
Format func(childComplexity int) int
ID func(childComplexity int) int
RecordCount func(childComplexity int) int
Status func(childComplexity int) int
Type func(childComplexity int) int
}
ExportJobConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
ExportJobEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
FederationCost struct {
Breakdown func(childComplexity int) int
Domain func(childComplexity int) int
EgressBytes func(childComplexity int) int
ErrorRate func(childComplexity int) int
HealthScore func(childComplexity int) int
IngressBytes func(childComplexity int) int
LastUpdated func(childComplexity int) int
MonthlyCostUsd func(childComplexity int) int
Recommendation func(childComplexity int) int
RequestCount func(childComplexity int) int
}
FederationCostConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
FederationCostEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
FederationEdge struct {
Bidirectional func(childComplexity int) int
ErrorRate func(childComplexity int) int
HealthScore func(childComplexity int) int
Latency func(childComplexity int) int
Source func(childComplexity int) int
Target func(childComplexity int) int
VolumePerDay func(childComplexity int) int
Weight func(childComplexity int) int
}
FederationFlow struct {
CostByInstance func(childComplexity int) int
TopDestinations func(childComplexity int) int
TopSources func(childComplexity int) int
VolumeByHour func(childComplexity int) int
}
FederationGraph struct {
Clusters func(childComplexity int) int
Edges func(childComplexity int) int
HealthScore func(childComplexity int) int
Nodes func(childComplexity int) int
}
FederationHealthUpdate struct {
CurrentStatus func(childComplexity int) int
Domain func(childComplexity int) int
Issues func(childComplexity int) int
PreviousStatus func(childComplexity int) int
Timestamp func(childComplexity int) int
}
FederationLimit struct {
Active func(childComplexity int) int
CreatedAt func(childComplexity int) int
Domain func(childComplexity int) int
EgressLimitMb func(childComplexity int) int
IngressLimitMb func(childComplexity int) int
MonthlyBudgetUsd func(childComplexity int) int
RequestsPerMinute func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
FederationManagementStatus struct {
Domain func(childComplexity int) int
Limits func(childComplexity int) int
Metrics func(childComplexity int) int
PausedUntil func(childComplexity int) int
Reason func(childComplexity int) int
Status func(childComplexity int) int
}
FederationMetrics struct {
AverageResponseTime func(childComplexity int) int
CurrentMonthBandwidthMb func(childComplexity int) int
CurrentMonthCostUsd func(childComplexity int) int
CurrentMonthRequests func(childComplexity int) int
ErrorRate func(childComplexity int) int
}
FederationRecommendation struct {
Action func(childComplexity int) int
Domain func(childComplexity int) int
PotentialImpact func(childComplexity int) int
Priority func(childComplexity int) int
Reason func(childComplexity int) int
Type func(childComplexity int) int
}
FederationStatus struct {
Domain func(childComplexity int) int
LastContact func(childComplexity int) int
PublicKey func(childComplexity int) int
Reachable func(childComplexity int) int
SharedInbox func(childComplexity int) int
Software func(childComplexity int) int
Version func(childComplexity int) int
}
Field struct {
Name func(childComplexity int) int
Value func(childComplexity int) int
VerifiedAt func(childComplexity int) int
}
Filter struct {
Context func(childComplexity int) int
ExpiresAt func(childComplexity int) int
FilterAction func(childComplexity int) int
ID func(childComplexity int) int
Keywords func(childComplexity int) int
Statuses func(childComplexity int) int
Title func(childComplexity int) int
}
FilterKeyword struct {
ID func(childComplexity int) int
Keyword func(childComplexity int) int
WholeWord func(childComplexity int) int
}
FilterStatus struct {
ID func(childComplexity int) int
StatusID func(childComplexity int) int
}
FilterTestPayload struct {
Content func(childComplexity int) int
MatchedCount func(childComplexity int) int
Results func(childComplexity int) int
TotalFilters func(childComplexity int) int
}
FilterTestResult struct {
Action func(childComplexity int) int
FilterID func(childComplexity int) int
FilterTitle func(childComplexity int) int
MatchScore func(childComplexity int) int
MatchedRules func(childComplexity int) int
Severity func(childComplexity int) int
}
FlagPayload struct {
ModerationID func(childComplexity int) int
Queued func(childComplexity int) int
}
FlowNode struct {
AvgMessageSize func(childComplexity int) int
Domain func(childComplexity int) int
Percentage func(childComplexity int) int
Trend func(childComplexity int) int
Volume func(childComplexity int) int
}
GroupedNotificationGroup struct {
AllNotificationIds func(childComplexity int) int
Count func(childComplexity int) int
EarliestCreatedAt func(childComplexity int) int
GroupKey func(childComplexity int) int
ID func(childComplexity int) int
LatestCreatedAt func(childComplexity int) int
MostRecentNotificationID func(childComplexity int) int
Read func(childComplexity int) int
SampleActorIds func(childComplexity int) int
SampleActors func(childComplexity int) int
Summary func(childComplexity int) int
TargetStatusID func(childComplexity int) int
Type func(childComplexity int) int
}
Hashtag struct {
Analytics func(childComplexity int) int
DisplayName func(childComplexity int) int
FollowedAt func(childComplexity int) int
FollowerCount func(childComplexity int) int
IsFollowing func(childComplexity int) int
Name func(childComplexity int) int
NotificationSettings func(childComplexity int) int
PostCount func(childComplexity int) int
Posts func(childComplexity int, first *int, after *string) int
RelatedHashtags func(childComplexity int) int
TrendingScore func(childComplexity int) int
URL func(childComplexity int) int
}
HashtagActivityUpdate struct {
Author func(childComplexity int) int
Hashtag func(childComplexity int) int
Post func(childComplexity int) int
Timestamp func(childComplexity int) int
}
HashtagAnalytics struct {
DailyPosts func(childComplexity int) int
Engagement func(childComplexity int) int
HourlyPosts func(childComplexity int) int
Sentiment func(childComplexity int) int
TopPosters func(childComplexity int) int
}
HashtagConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
HashtagEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
HashtagFollowPayload struct {
Hashtag func(childComplexity int) int
Success func(childComplexity int) int
}
HashtagNotificationSettings struct {
Filters func(childComplexity int) int
Level func(childComplexity int) int
Muted func(childComplexity int) int
MutedUntil func(childComplexity int) int
}
HashtagSuggestion struct {
Hashtag func(childComplexity int) int
Reason func(childComplexity int) int
Score func(childComplexity int) int
}
HealthIssue struct {
Description func(childComplexity int) int
DetectedAt func(childComplexity int) int
Impact func(childComplexity int) int
Severity func(childComplexity int) int
Type func(childComplexity int) int
}
HourlyBandwidth struct {
Hour func(childComplexity int) int
PeakMbps func(childComplexity int) int
TotalGb func(childComplexity int) int
}
HourlyVolume struct {
AvgLatency func(childComplexity int) int
Errors func(childComplexity int) int
Hour func(childComplexity int) int
Inbound func(childComplexity int) int
Outbound func(childComplexity int) int
}
ImageAnalysis struct {
CelebrityFaces func(childComplexity int) int
DeepfakeScore func(childComplexity int) int
DetectedText func(childComplexity int) int
IsNsfw func(childComplexity int) int
ModerationLabels func(childComplexity int) int
NsfwConfidence func(childComplexity int) int
TextToxicity func(childComplexity int) int
ViolenceScore func(childComplexity int) int
WeaponsDetected func(childComplexity int) int
}
ImageAnalysisCapabilities struct {
CelebrityRecognition func(childComplexity int) int
DeepfakeDetection func(childComplexity int) int
NsfwDetection func(childComplexity int) int
TextExtraction func(childComplexity int) int
ViolenceDetection func(childComplexity int) int
}
ImportJob struct {
CreatedAt func(childComplexity int) int
Errors func(childComplexity int) int
ID func(childComplexity int) int
Processed func(childComplexity int) int
Results func(childComplexity int) int
Status func(childComplexity int) int
Total func(childComplexity int) int
Type func(childComplexity int) int
}
ImportJobConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
ImportJobEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
ImportResults struct {
Failed func(childComplexity int) int
Skipped func(childComplexity int) int
Success func(childComplexity int) int
}
InfrastructureAlert struct {
ID func(childComplexity int) int
Message func(childComplexity int) int
Resolved func(childComplexity int) int
Service func(childComplexity int) int
Severity func(childComplexity int) int
Timestamp func(childComplexity int) int
}
InfrastructureEvent struct {
Description func(childComplexity int) int
ID func(childComplexity int) int
Impact func(childComplexity int) int
Service func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
InfrastructureStatus struct {
Alerts func(childComplexity int) int
Databases func(childComplexity int) int
Healthy func(childComplexity int) int
Queues func(childComplexity int) int
Services func(childComplexity int) int
}
InstanceActivityEntry struct {
Logins func(childComplexity int) int
Registrations func(childComplexity int) int
Statuses func(childComplexity int) int
Week func(childComplexity int) int
}
InstanceBudget struct {
AlertThreshold func(childComplexity int) int
AutoLimit func(childComplexity int) int
CurrentSpendUsd func(childComplexity int) int
Domain func(childComplexity int) int
MonthlyBudgetUsd func(childComplexity int) int
Period func(childComplexity int) int
ProjectedOverspend func(childComplexity int) int
RemainingBudgetUsd func(childComplexity int) int
}
InstanceCluster struct {
AvgHealthScore func(childComplexity int) int
Commonality func(childComplexity int) int
Description func(childComplexity int) int
ID func(childComplexity int) int
Members func(childComplexity int) int
Name func(childComplexity int) int
TotalVolume func(childComplexity int) int
}
InstanceConnection struct {
ConnectionType func(childComplexity int) int
Domain func(childComplexity int) int
LastActivity func(childComplexity int) int
SharedUsers func(childComplexity int) int
Strength func(childComplexity int) int
VolumeIn func(childComplexity int) int
VolumeOut func(childComplexity int) int
}
InstanceCost struct {
Breakdown func(childComplexity int) int
CostUsd func(childComplexity int) int
Domain func(childComplexity int) int
Percentage func(childComplexity int) int
}
InstanceDomainBlock struct {
Comment func(childComplexity int) int
Digest func(childComplexity int) int
Domain func(childComplexity int) int
Severity func(childComplexity int) int
}
InstanceHealthMetrics struct {
CostEfficiency func(childComplexity int) int
ErrorRate func(childComplexity int) int
FederationDelay func(childComplexity int) int
QueueDepth func(childComplexity int) int
ResponseTime func(childComplexity int) int
}
InstanceHealthReport struct {
Domain func(childComplexity int) int
Issues func(childComplexity int) int
LastChecked func(childComplexity int) int
Metrics func(childComplexity int) int
Recommendations func(childComplexity int) int
Status func(childComplexity int) int
}
InstanceInfo struct {
ApprovalRequired func(childComplexity int) int
ContactAccount func(childComplexity int) int
Description func(childComplexity int) int
Domain func(childComplexity int) int
DomainCount func(childComplexity int) int
Email func(childComplexity int) int
InvitesEnabled func(childComplexity int) int
Languages func(childComplexity int) int
RegistrationsOpen func(childComplexity int) int
Rules func(childComplexity int) int
ShortDescription func(childComplexity int) int
SourceURL func(childComplexity int) int
StatusCount func(childComplexity int) int
StreamingURL func(childComplexity int) int
ThumbnailURL func(childComplexity int) int
Tips func(childComplexity int) int
Title func(childComplexity int) int
UserCount func(childComplexity int) int
Version func(childComplexity int) int
}
InstanceMetadata struct {
ApprovalRequired func(childComplexity int) int
Description func(childComplexity int) int
FirstSeen func(childComplexity int) int
LastActivity func(childComplexity int) int
MonthlyActiveUsers func(childComplexity int) int
PrimaryLanguage func(childComplexity int) int
RegistrationsOpen func(childComplexity int) int
}
InstanceMetrics struct {
ActiveUsers func(childComplexity int) int
AverageLatencyMs func(childComplexity int) int
EstimatedMonthlyCost func(childComplexity int) int
LastUpdated func(childComplexity int) int
RequestsPerMinute func(childComplexity int) int
StorageUsedGb func(childComplexity int) int
}
InstanceNode struct {
Coordinates func(childComplexity int) int
DisplayName func(childComplexity int) int
Domain func(childComplexity int) int
FederatingWith func(childComplexity int) int
HealthStatus func(childComplexity int) int
Metadata func(childComplexity int) int
Software func(childComplexity int) int
StatusCount func(childComplexity int) int
UserCount func(childComplexity int) int
Version func(childComplexity int) int
}
InstanceRelations struct {
BlockedBy func(childComplexity int) int
Blocking func(childComplexity int) int
DirectConnections func(childComplexity int) int
Domain func(childComplexity int) int
FederationScore func(childComplexity int) int
IndirectConnections func(childComplexity int) int
Recommendations func(childComplexity int) int
}
InstanceRule struct {
ID func(childComplexity int) int
Text func(childComplexity int) int
}
List struct {
AccountCount func(childComplexity int) int
Accounts func(childComplexity int) int
CreatedAt func(childComplexity int) int
Exclusive func(childComplexity int) int
ID func(childComplexity int) int
RepliesPolicy func(childComplexity int) int
Title func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
ListUpdate struct {
Account func(childComplexity int) int
List func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
Marker struct {
LastReadID func(childComplexity int) int
UpdatedAt func(childComplexity int) int
Version func(childComplexity int) int
}
MarkerSet struct {
Home func(childComplexity int) int
Notifications func(childComplexity int) int
}
Media struct {
Blurhash func(childComplexity int) int
CreatedAt func(childComplexity int) int
Description func(childComplexity int) int
Duration func(childComplexity int) int
Height func(childComplexity int) int
ID func(childComplexity int) int
MediaCategory func(childComplexity int) int
MimeType func(childComplexity int) int
PreviewURL func(childComplexity int) int
Sensitive func(childComplexity int) int
Size func(childComplexity int) int
SpoilerText func(childComplexity int) int
Type func(childComplexity int) int
URL func(childComplexity int) int
UploadedBy func(childComplexity int) int
Width func(childComplexity int) int
}
MediaConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
MediaEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
MediaStream struct {
Bitrates func(childComplexity int) int
DashManifestURL func(childComplexity int) int
Duration func(childComplexity int) int
ExpiresAt func(childComplexity int) int
HlsPlaylistURL func(childComplexity int) int
ID func(childComplexity int) int
ThumbnailURL func(childComplexity int) int
URL func(childComplexity int) int
}
Mention struct {
Domain func(childComplexity int) int
ID func(childComplexity int) int
URL func(childComplexity int) int
Username func(childComplexity int) int
}
MetricsDimension struct {
Key func(childComplexity int) int
Value func(childComplexity int) int
}
MetricsUpdate struct {
AggregationLevel func(childComplexity int) int
Average func(childComplexity int) int
Count func(childComplexity int) int
Dimensions func(childComplexity int) int
InstanceDomain func(childComplexity int) int
Max func(childComplexity int) int
MetricID func(childComplexity int) int
MetricType func(childComplexity int) int
Min func(childComplexity int) int
P50 func(childComplexity int) int
P95 func(childComplexity int) int
P99 func(childComplexity int) int
ServiceName func(childComplexity int) int
SubscriptionCategory func(childComplexity int) int
Sum func(childComplexity int) int
TenantID func(childComplexity int) int
Timestamp func(childComplexity int) int
TotalCostMicrocents func(childComplexity int) int
Unit func(childComplexity int) int
UserCostMicrocents func(childComplexity int) int
UserID func(childComplexity int) int
}
ModerationActionCounts struct {
Flag func(childComplexity int) int
Hide func(childComplexity int) int
None func(childComplexity int) int
Remove func(childComplexity int) int
Review func(childComplexity int) int
ShadowBan func(childComplexity int) int
}
ModerationAlert struct {
Confidence func(childComplexity int) int
Content func(childComplexity int) int
Handled func(childComplexity int) int
ID func(childComplexity int) int
MatchedText func(childComplexity int) int
Pattern func(childComplexity int) int
Severity func(childComplexity int) int
SuggestedAction func(childComplexity int) int
Timestamp func(childComplexity int) int
}
ModerationConsensusResult struct {
Category func(childComplexity int) int
ConfidenceScore func(childComplexity int) int
ConsensusScore func(childComplexity int) int
DecidedAt func(childComplexity int) int
Decision func(childComplexity int) int
EventID func(childComplexity int) int
ObjectID func(childComplexity int) int
ReviewerCount func(childComplexity int) int
Reviews func(childComplexity int) int
Severity func(childComplexity int) int
}
ModerationConsensusReview struct {
Action func(childComplexity int) int
Confidence func(childComplexity int) int
ReviewedAt func(childComplexity int) int
ReviewerDomain func(childComplexity int) int
ReviewerID func(childComplexity int) int
TrustWeight func(childComplexity int) int
}
ModerationDashboard struct {
AverageResponseTime func(childComplexity int) int
FalsePositiveRate func(childComplexity int) int
PendingReviews func(childComplexity int) int
RecentDecisions func(childComplexity int) int
ThreatTrends func(childComplexity int) int
TopPatterns func(childComplexity int) int
}
ModerationDecision struct {
Confidence func(childComplexity int) int
Decision func(childComplexity int) int
Evidence func(childComplexity int) int
ID func(childComplexity int) int
Object func(childComplexity int) int
Reviewers func(childComplexity int) int
Timestamp func(childComplexity int) int
}
ModerationEffectiveness struct {
F1Score func(childComplexity int) int
FalsePositives func(childComplexity int) int
MatchCount func(childComplexity int) int
MissedCount func(childComplexity int) int
PatternID func(childComplexity int) int
Precision func(childComplexity int) int
Recall func(childComplexity int) int
TruePositives func(childComplexity int) int
}
ModerationHistoryDecision struct {
Action func(childComplexity int) int
ConsensusScore func(childComplexity int) int
DecidedAt func(childComplexity int) int
EventID func(childComplexity int) int
ID func(childComplexity int) int
ObjectID func(childComplexity int) int
ReviewerCount func(childComplexity int) int
TrustWeightTotal func(childComplexity int) int
}
ModerationHistoryEvent struct {
ActorID func(childComplexity int) int
Category func(childComplexity int) int
ConfidenceScore func(childComplexity int) int
CreatedAt func(childComplexity int) int
EventType func(childComplexity int) int
ID func(childComplexity int) int
ObjectID func(childComplexity int) int
ObjectType func(childComplexity int) int
Reason func(childComplexity int) int
Severity func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
ModerationHistoryResult struct {
CurrentStatus func(childComplexity int) int
Decisions func(childComplexity int) int
Events func(childComplexity int) int
LastUpdated func(childComplexity int) int
ObjectID func(childComplexity int) int
Timeline func(childComplexity int) int
}
ModerationHistoryTimelineEntry struct {
Decision func(childComplexity int) int
Event func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
ModerationItem struct {
AssignedTo func(childComplexity int) int
Content func(childComplexity int) int
Deadline func(childComplexity int) int
ID func(childComplexity int) int
Priority func(childComplexity int) int
ReportCount func(childComplexity int) int
Severity func(childComplexity int) int
}
ModerationLabel struct {
Confidence func(childComplexity int) int
Name func(childComplexity int) int
ParentName func(childComplexity int) int
}
ModerationPattern struct {
Active func(childComplexity int) int
CreatedAt func(childComplexity int) int
CreatedBy func(childComplexity int) int
FalsePositiveRate func(childComplexity int) int
ID func(childComplexity int) int
MatchCount func(childComplexity int) int
Pattern func(childComplexity int) int
Severity func(childComplexity int) int
Type func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
ModerationReviewResult struct {
Action func(childComplexity int) int
EventID func(childComplexity int) int
ReviewID func(childComplexity int) int
ReviewedAt func(childComplexity int) int
}
ModerationTrustScore struct {
ActorDomain func(childComplexity int) int
ActorID func(childComplexity int) int
CalculatedAt func(childComplexity int) int
OverallScore func(childComplexity int) int
Scores func(childComplexity int) int
TrusterCount func(childComplexity int) int
}
ModeratorStats struct {
Accuracy func(childComplexity int) int
AvgResponseTime func(childComplexity int) int
Categories func(childComplexity int) int
DecisionsCount func(childComplexity int) int
ModeratorID func(childComplexity int) int
Overturned func(childComplexity int) int
Period func(childComplexity int) int
}
Mutation struct {
AcceptFollowRequest func(childComplexity int, accountID string) int
AcknowledgeSeverance func(childComplexity int, id string) int
AddAccountsToList func(childComplexity int, id string, accountIds []string) int
AddAnnouncementReaction func(childComplexity int, id string, name string) int
AddArticleToCategory func(childComplexity int, categoryID string, articleID string) int
AddArticleToSeries func(childComplexity int, seriesID string, articleID string, order *int) int
AddCommunityNote func(childComplexity int, input model.CommunityNoteInput) int
AddDomainBlock func(childComplexity int, domain string) int
AddFilterKeyword func(childComplexity int, filterID string, input model.AddFilterKeywordInput) int
AddFilterStatus func(childComplexity int, filterID string, statusID string) int
AdminAccountAction func(childComplexity int, input model.AdminAccountActionInput) int
AdminCreateAnnouncement func(childComplexity int, input model.AdminCreateAnnouncementInput) int
AdminCreateDomainAllow func(childComplexity int, domain string) int
AdminCreateDomainBlock func(childComplexity int, input model.AdminDomainBlockCreateInput) int
AdminCreateEmailDomainBlock func(childComplexity int, domain string) int
AdminCreateUser func(childComplexity int, input model.AdminCreateUserInput) int
AdminDeleteDomainAllow func(childComplexity int, id string) int
AdminDeleteDomainBlock func(childComplexity int, id string) int
AdminDeleteEmailDomainBlock func(childComplexity int, id string) int
AdminDeleteStatus func(childComplexity int, id string) int
AdminDemoteReviewer func(childComplexity int, id string) int
AdminOverrideModerationEvent func(childComplexity int, input model.AdminModerationEventOverrideInput) int
AdminPromoteReviewer func(childComplexity int, id string) int
AdminReportAction func(childComplexity int, id string, action model.AdminReportAction) int
AdminSetStatusSensitive func(childComplexity int, id string, sensitive bool) int
AdminUpdateDomainBlock func(childComplexity int, id string, input model.AdminDomainBlockUpdateInput) int
AdminUpdateTrust func(childComplexity int, input model.AdminUpdateTrustInput) int
AttemptReconnection func(childComplexity int, id string) int
AutosaveDraft func(childComplexity int, id string, content string) int
BlockActor func(childComplexity int, id string) int
BookmarkObject func(childComplexity int, id string) int
CancelImport func(childComplexity int, id string) int
CancelScheduledDraft func(childComplexity int, id string) int
CancelScheduledStatus func(childComplexity int, id string) int
ClearNotifications func(childComplexity int) int
CreateArticle func(childComplexity int, input model.CreateArticleInput) int
CreateCategory func(childComplexity int, input model.CreateCategoryInput) int
CreateDraft func(childComplexity int, input model.CreateDraftInput) int
CreateEmoji func(childComplexity int, input model.CreateEmojiInput) int
CreateExport func(childComplexity int, input model.CreateExportInput) int
CreateFilter func(childComplexity int, input model.CreateFilterInput) int
CreateImport func(childComplexity int, input model.CreateImportInput) int
CreateList func(childComplexity int, input model.CreateListInput) int
CreateModerationPattern func(childComplexity int, input model.ModerationPatternInput) int
CreateNote func(childComplexity int, input model.CreateNoteInput) int
CreatePublication func(childComplexity int, input model.CreatePublicationInput) int
CreateQuoteNote func(childComplexity int, input model.CreateQuoteNoteInput) int
CreateReport func(childComplexity int, input model.CreateReportInput) int
CreateSeries func(childComplexity int, input model.CreateSeriesInput) int
CreateVouch func(childComplexity int, input model.CreateVouchInput) int
DelegateToAgent func(childComplexity int, input model.DelegateToAgentInput) int
DeleteArticle func(childComplexity int, id string) int
DeleteCategory func(childComplexity int, id string) int
DeleteConversation func(childComplexity int, id string) int
DeleteDraft func(childComplexity int, id string) int
DeleteEmoji func(childComplexity int, shortcode string) int
DeleteFilter func(childComplexity int, id string) int
DeleteFilterKeyword func(childComplexity int, filterID string, keywordID string) int
DeleteFilterStatus func(childComplexity int, filterID string, filterStatusID string) int
DeleteList func(childComplexity int, id string) int
DeleteModerationPattern func(childComplexity int, id string) int
DeleteObject func(childComplexity int, id string) int
DeletePushSubscription func(childComplexity int) int
DeleteSeries func(childComplexity int, id string) int
DismissAnnouncement func(childComplexity int, id string) int
DismissNotification func(childComplexity int, id string) int
ExportReputation func(childComplexity int) int
FlagObject func(childComplexity int, input model.FlagInput) int
FollowActor func(childComplexity int, id string) int
FollowHashtag func(childComplexity int, hashtag string, notifyLevel *model.NotificationLevel) int
ImportReputation func(childComplexity int, document string) int
InvitePublicationMember func(childComplexity int, publicationID string, userID string, role model.PublicationRole) int
LikeObject func(childComplexity int, id string) int
MarkConversationAsRead func(childComplexity int, id string) int
MarkNotificationGroupAsRead func(childComplexity int, groupID string) int
MuteActor func(childComplexity int, id string, notifications *bool) int
MuteHashtag func(childComplexity int, hashtag string, until *model.Time) int
MuteStatus func(childComplexity int, id string, durationSeconds *int) int
OptimizeFederationCosts func(childComplexity int, threshold float64) int
PauseFederation func(childComplexity int, domain string, reason string, until *model.Time) int
PinObject func(childComplexity int, id string) int
PreloadMedia func(childComplexity int, mediaIds []string) int
PublishDraft func(childComplexity int, id string) int
RegisterAccount func(childComplexity int, input model.RegisterAccountInput) int
RegisterAgent func(childComplexity int, input model.RegisterAgentInput) int
RegisterPushSubscription func(childComplexity int, input model.RegisterPushSubscriptionInput) int
RejectFollowRequest func(childComplexity int, accountID string) int
RemoveAccountsFromList func(childComplexity int, id string, accountIds []string) int
RemoveAnnouncementReaction func(childComplexity int, id string, name string) int
RemoveArticleFromCategory func(childComplexity int, categoryID string, articleID string) int
RemoveArticleFromSeries func(childComplexity int, seriesID string, articleID string) int
RemoveDomainBlock func(childComplexity int, domain string) int
RemovePublicationMember func(childComplexity int, publicationID string, userID string) int
ReorderSeriesArticles func(childComplexity int, seriesID string, articleIds []string) int
ReportStreamingQuality func(childComplexity int, input model.StreamingQualityInput) int
RequestAIAnalysis func(childComplexity int, objectID string, objectType *string, force *bool) int
RequestStreamingURL func(childComplexity int, mediaID string, quality *model.StreamQuality) int
RestoreRevision func(childComplexity int, objectID string, version int) int
ResumeFederation func(childComplexity int, domain string) int
RevokeAgentToken func(childComplexity int, username string) int
RevokeVouch func(childComplexity int, id string) int
SaveMarkers func(childComplexity int, input []*model.SaveMarkerInput) int
ScheduleDraft func(childComplexity int, id string, scheduledAt model.Time) int
ScheduleStatus func(childComplexity int, input model.ScheduleStatusInput) int
SetFederationLimit func(childComplexity int, domain string, limit model.FederationLimitInput) int
SetInstanceBudget func(childComplexity int, domain string, monthlyUsd float64, autoLimit *bool) int
ShareObject func(childComplexity int, id string) int
SubmitModerationReview func(childComplexity int, input model.ModerationReviewInput) int
SyncMissingReplies func(childComplexity int, noteID string) int
SyncThread func(childComplexity int, noteURL string, depth *int) int
TestFilters func(childComplexity int, input model.FilterTestInput) int
TrainModerationModel func(childComplexity int, samples []*model.ModerationSampleInput, options *model.BedrockTrainingOptions) int
UnblockActor func(childComplexity int, id string) int
UnbookmarkObject func(childComplexity int, id string) int
UnfollowActor func(childComplexity int, id string) int
UnfollowHashtag func(childComplexity int, hashtag string) int
UnlikeObject func(childComplexity int, id string) int
UnmuteActor func(childComplexity int, id string) int
UnmuteStatus func(childComplexity int, id string) int
UnpinObject func(childComplexity int, id string) int
UnshareObject func(childComplexity int, id string) int
UpdateAccountQuotePermissions func(childComplexity int, input model.UpdateAccountQuotePermissionsInput) int
UpdateAgent func(childComplexity int, username string, input model.UpdateAgentInput) int
UpdateArticle func(childComplexity int, id string, input model.UpdateArticleInput) int
UpdateCategory func(childComplexity int, id string, input model.UpdateCategoryInput) int
UpdateDraft func(childComplexity int, id string, input model.UpdateDraftInput) int
UpdateEmoji func(childComplexity int, shortcode string, input model.UpdateEmojiInput) int
UpdateFilter func(childComplexity int, id string, input model.UpdateFilterInput) int
UpdateHashtagNotifications func(childComplexity int, hashtag string, settings model.HashtagNotificationSettingsInput) int
UpdateList func(childComplexity int, id string, input model.UpdateListInput) int
UpdateMedia func(childComplexity int, id string, input model.UpdateMediaInput) int
UpdateModerationPattern func(childComplexity int, id string, input model.ModerationPatternInput) int
UpdateProfile func(childComplexity int, input model.UpdateProfileInput) int
UpdatePublication func(childComplexity int, id string, input model.UpdatePublicationInput) int
UpdatePublicationMemberRole func(childComplexity int, publicationID string, userID string, role model.PublicationRole) int
UpdatePushSubscription func(childComplexity int, input model.UpdatePushSubscriptionInput) int
UpdateQuotePermissions func(childComplexity int, noteID string, quoteable bool, permission model.QuotePermission) int
UpdateRelationship func(childComplexity int, id string, input model.UpdateRelationshipInput) int
UpdateScheduledStatus func(childComplexity int, id string, input model.UpdateScheduledStatusInput) int
UpdateSeries func(childComplexity int, id string, input model.UpdateSeriesInput) int
UpdateStatus func(childComplexity int, id string, input model.UpdateStatusInput) int
UpdateStreamingPreferences func(childComplexity int, input model.StreamingPreferencesInput) int
UpdateTrust func(childComplexity int, input model.TrustInput) int
UpdateUserPreferences func(childComplexity int, input model.UpdateUserPreferencesInput) int
UploadMedia func(childComplexity int, input model.UploadMediaInput) int
VerifyReputation func(childComplexity int, document string) int
VoteCommunityNote func(childComplexity int, id string, helpful bool) int
WithdrawFromQuotes func(childComplexity int, noteID string) int
}
MuteHashtagPayload struct {
Hashtag func(childComplexity int) int
MutedUntil func(childComplexity int) int
Success func(childComplexity int) int
}
Notification struct {
Account func(childComplexity int) int
CreatedAt func(childComplexity int) int
ID func(childComplexity int) int
Read func(childComplexity int) int
Status func(childComplexity int) int
Type func(childComplexity int) int
}
NotificationConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
NotificationEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
NotificationFilter struct {
Type func(childComplexity int) int
Value func(childComplexity int) int
}
NotificationPreferences struct {
Digest func(childComplexity int) int
Email func(childComplexity int) int
InApp func(childComplexity int) int
Push func(childComplexity int) int
}
Object struct {
Actor func(childComplexity int) int
Attachments func(childComplexity int) int
Boosted func(childComplexity int) int
BoostedObject func(childComplexity int) int
CommunityNotes func(childComplexity int) int
Content func(childComplexity int) int
ContentHash func(childComplexity int) int
ContentMap func(childComplexity int) int
CreatedAt func(childComplexity int) int
EstimatedCost func(childComplexity int) int
ID func(childComplexity int) int
InReplyTo func(childComplexity int) int
LikesCount func(childComplexity int) int
Mentions func(childComplexity int) int
ModerationScore func(childComplexity int) int
Poll func(childComplexity int) int
QuoteContext func(childComplexity int) int
QuoteCount func(childComplexity int) int
QuotePermissions func(childComplexity int) int
QuoteURL func(childComplexity int) int
Quoteable func(childComplexity int) int
Quotes func(childComplexity int, first *int, after *string) int
RelationshipType func(childComplexity int) int
RepliesCount func(childComplexity int) int
Sensitive func(childComplexity int) int
SharesCount func(childComplexity int) int
SpoilerText func(childComplexity int) int
Tags func(childComplexity int) int
Type func(childComplexity int) int
UpdatedAt func(childComplexity int) int
ViewerBookmarked func(childComplexity int) int
ViewerFavourited func(childComplexity int) int
ViewerPinned func(childComplexity int) int
Visibility func(childComplexity int) int
}
ObjectConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
ObjectEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
ObjectExplanation struct {
AccessPattern func(childComplexity int) int
Object func(childComplexity int) int
SizeBytes func(childComplexity int) int
StorageCost func(childComplexity int) int
StorageLocation func(childComplexity int) int
}
OptimizationAction struct {
Action func(childComplexity int) int
Domain func(childComplexity int) int
Impact func(childComplexity int) int
SavingsUsd func(childComplexity int) int
}
PageInfo struct {
EndCursor func(childComplexity int) int
HasNextPage func(childComplexity int) int
HasPreviousPage func(childComplexity int) int
StartCursor func(childComplexity int) int
}
PatternStats struct {
Accuracy func(childComplexity int) int
LastMatch func(childComplexity int) int
MatchCount func(childComplexity int) int
Pattern func(childComplexity int) int
Trend func(childComplexity int) int
}
PerformanceAlert struct {
ActualValue func(childComplexity int) int
ID func(childComplexity int) int
Metric func(childComplexity int) int
Service func(childComplexity int) int
Severity func(childComplexity int) int
Threshold func(childComplexity int) int
Timestamp func(childComplexity int) int
}
PerformanceReport struct {
ColdStarts func(childComplexity int) int
ErrorRate func(childComplexity int) int
P50Latency func(childComplexity int) int
P95Latency func(childComplexity int) int
P99Latency func(childComplexity int) int
Period func(childComplexity int) int
Service func(childComplexity int) int
Throughput func(childComplexity int) int
}
Poll struct {
Expired func(childComplexity int) int
ExpiresAt func(childComplexity int) int
HideTotals func(childComplexity int) int
ID func(childComplexity int) int
Multiple func(childComplexity int) int
Options func(childComplexity int) int
OwnVotes func(childComplexity int) int
Voted func(childComplexity int) int
VotersCount func(childComplexity int) int
VotesCount func(childComplexity int) int
}
PollOption struct {
Title func(childComplexity int) int
VotesCount func(childComplexity int) int
}
PollParams struct {
ExpiresIn func(childComplexity int) int
HideTotals func(childComplexity int) int
Multiple func(childComplexity int) int
Options func(childComplexity int) int
}
PortableReputation struct {
Actor func(childComplexity int) int
Context func(childComplexity int) int
ExpiresAt func(childComplexity int) int
IssuedAt func(childComplexity int) int
Issuer func(childComplexity int) int
IssuerProof func(childComplexity int) int
Reputation func(childComplexity int) int
Type func(childComplexity int) int
Vouches func(childComplexity int) int
}
PostConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
PostEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
PostingPreferences struct {
DefaultLanguage func(childComplexity int) int
DefaultSensitive func(childComplexity int) int
DefaultVisibility func(childComplexity int) int
}
PrivacyPreferences struct {
DefaultVisibility func(childComplexity int) int
Indexable func(childComplexity int) int
ShowOnlineStatus func(childComplexity int) int
}
ProfileDirectory struct {
Accounts func(childComplexity int) int
TotalCount func(childComplexity int) int
}
Publication struct {
Actor func(childComplexity int) int
BannerURL func(childComplexity int) int
CreatedAt func(childComplexity int) int
CustomDomain func(childComplexity int) int
Description func(childComplexity int) int
ID func(childComplexity int) int
LogoURL func(childComplexity int) int
Members func(childComplexity int) int
Name func(childComplexity int) int
Slug func(childComplexity int) int
Tagline func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
PublicationMember struct {
Bio func(childComplexity int) int
DisplayName func(childComplexity int) int
JoinedAt func(childComplexity int) int
Role func(childComplexity int) int
User func(childComplexity int) int
}
PushSubscription struct {
Alerts func(childComplexity int) int
CreatedAt func(childComplexity int) int
Endpoint func(childComplexity int) int
ID func(childComplexity int) int
Keys func(childComplexity int) int
Policy func(childComplexity int) int
ServerKey func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
PushSubscriptionAlerts struct {
AdminReport func(childComplexity int) int
AdminSignUp func(childComplexity int) int
Favourite func(childComplexity int) int
Follow func(childComplexity int) int
FollowRequest func(childComplexity int) int
Mention func(childComplexity int) int
Poll func(childComplexity int) int
Reblog func(childComplexity int) int
Status func(childComplexity int) int
Update func(childComplexity int) int
}
PushSubscriptionKeys struct {
Auth func(childComplexity int) int
P256dh func(childComplexity int) int
}
QualityBandwidth struct {
Percentage func(childComplexity int) int
Quality func(childComplexity int) int
TotalGb func(childComplexity int) int
}
QualityStats struct {
AvgBandwidth func(childComplexity int) int
Percentage func(childComplexity int) int
Quality func(childComplexity int) int
ViewCount func(childComplexity int) int
}
Query struct {
AccountQuotePermissions func(childComplexity int, username string) int
Actor func(childComplexity int, id *string, username *string) int
AdminAccount func(childComplexity int, id string) int
AdminAccounts func(childComplexity int, first *int, after *model.Cursor) int
AdminDomainAllows func(childComplexity int, first *int, after *model.Cursor) int
AdminDomainBlock func(childComplexity int, id string) int
AdminDomainBlocks func(childComplexity int, first *int, after *model.Cursor) int
AdminEmailDomainBlocks func(childComplexity int, first *int, after *model.Cursor) int
AdminFederationInstance func(childComplexity int, domain string) int
AdminFederationInstances func(childComplexity int, first *int, after *model.Cursor) int
AdminFederationStatistics func(childComplexity int, start *model.Time, end *model.Time) int
AdminModerationEvents func(childComplexity int, filter *model.AdminModerationEventFilter, first *int, after *model.Cursor) int
AdminModerationReviewers func(childComplexity int) int
AdminReport func(childComplexity int, id string) int
AdminReports func(childComplexity int, status *model.AdminReportStatus, first *int, after *model.Cursor) int
AdminStatus func(childComplexity int, id string) int
AdminStatuses func(childComplexity int, filter *model.AdminStatusFilter, first *int, after *model.Cursor) int
AdminTrustGraph func(childComplexity int, limit *int) int
AffectedRelationships func(childComplexity int, severedRelationshipID string) int
Agent func(childComplexity int, username string) int
AgentMemorySearch func(childComplexity int, query string, tags []string, dateRange *model.DateRangeInput, first *int, after *model.Cursor) int
Agents func(childComplexity int, first *int, after *model.Cursor, typeArg *model.AgentType) int
AiAnalysis func(childComplexity int, objectID string) int
AiCapabilities func(childComplexity int) int
AiStats func(childComplexity int, period model.Period) int
AllSeries func(childComplexity int, authorID *string, first *int, after *model.Cursor) int
Announcements func(childComplexity int) int
Article func(childComplexity int, id string) int
ArticleBySlug func(childComplexity int, slug string) int
Articles func(childComplexity int, authorID *string, seriesID *string, categoryID *string, first *int, after *model.Cursor) int
BandwidthUsage func(childComplexity int, period model.TimePeriod) int
Blocks func(childComplexity int, first *int, after *model.Cursor) int
Bookmarks func(childComplexity int, first *int, after *model.Cursor) int
Categories func(childComplexity int, parentID *string) int
Category func(childComplexity int, id string) int
CategoryBySlug func(childComplexity int, slug string) int
CommunityNotesByAuthor func(childComplexity int, username string, first *int, after *model.Cursor) int
Conversation func(childComplexity int, id string) int
Conversations func(childComplexity int, first *int, after *model.Cursor) int
CostBreakdown func(childComplexity int, period *model.Period) int
CostProjections func(childComplexity int, period model.Period) int
CustomEmojis func(childComplexity int) int
DomainBlocks func(childComplexity int, first *int, after *model.Cursor) int
Draft func(childComplexity int, id string) int
Endorsements func(childComplexity int) int
ExplainObject func(childComplexity int, id string) int
Export func(childComplexity int, id string) int
Exports func(childComplexity int, first *int, after *model.Cursor) int
Favourites func(childComplexity int, first *int, after *model.Cursor) int
FederationCosts func(childComplexity int, first *int, after *string, orderBy *model.CostOrderBy) int
FederationFlow func(childComplexity int, period model.TimePeriod) int
FederationHealth func(childComplexity int, threshold *float64) int
FederationLimits func(childComplexity int, active *bool, first *int, after *string) int
FederationMap func(childComplexity int, depth *int) int
FederationStatus func(childComplexity int, domain string) int
Filter func(childComplexity int, id string) int
Filters func(childComplexity int) int
FollowRequests func(childComplexity int, first *int, after *model.Cursor) int
FollowedHashtags func(childComplexity int, first *int, after *string) int
Followers func(childComplexity int, username string, limit *int, cursor *model.Cursor) int
Following func(childComplexity int, username string, limit *int, cursor *model.Cursor) int
GroupedNotifications func(childComplexity int, input *model.GroupedNotificationsInput) int
Hashtag func(childComplexity int, name string) int
HashtagTimeline func(childComplexity int, hashtag string, first *int, after *string, mediaOnly *bool) int
Import func(childComplexity int, id string) int
Imports func(childComplexity int, first *int, after *model.Cursor) int
InfrastructureHealth func(childComplexity int) int
Instance func(childComplexity int) int
InstanceActivity func(childComplexity int, limit *int) int
InstanceBudgets func(childComplexity int, exceeded *bool) int
InstanceDomainBlocks func(childComplexity int, limit *int) int
InstanceHealthReport func(childComplexity int, domain string) int
InstanceMetrics func(childComplexity int) int
InstancePeers func(childComplexity int, limit *int) int
InstanceRelationships func(childComplexity int, domain string) int
LinkTimeline func(childComplexity int, url string, first *int, after *model.Cursor) int
List func(childComplexity int, id string) int
ListAccounts func(childComplexity int, id string) int
Lists func(childComplexity int) int
Markers func(childComplexity int, timelines []model.MarkerTimeline) int
Media func(childComplexity int, id string) int
MediaLibrary func(childComplexity int, filter *model.MediaFilterInput, first *int, after *model.Cursor) int
MediaStreamURL func(childComplexity int, mediaID string) int
ModerationConsensus func(childComplexity int, eventID string) int
ModerationDashboard func(childComplexity int, filter *moderation.ModerationFilter) int
ModerationEffectiveness func(childComplexity int, patternID string, period model.ModerationPeriod) int
ModerationHistory func(childComplexity int, objectID string) int
ModerationPatterns func(childComplexity int, active *bool, severity *model.ModerationSeverity, first *int, after *string) int
ModerationQueue func(childComplexity int, first *int, after *model.Cursor) int
ModerationTrustScore func(childComplexity int, actorID string) int
ModeratorActivity func(childComplexity int, moderatorID string, period model.TimePeriod) int
MultiHashtagTimeline func(childComplexity int, hashtags []string, mode model.HashtagMode, first *int, after *string) int
Mutes func(childComplexity int, first *int, after *model.Cursor) int
MyAgents func(childComplexity int) int
MyDrafts func(childComplexity int, contentType *model.ObjectType, status *model.DraftStatus, first *int, after *model.Cursor) int
MyPublications func(childComplexity int) int
Notification func(childComplexity int, id string) int
Notifications func(childComplexity int, types []string, excludeTypes []string, first *int, after *model.Cursor) int
Object func(childComplexity int, id string) int
PatternEffectiveness func(childComplexity int, patternID string) int
PerformanceMetrics func(childComplexity int, service model.ServiceCategory) int
PopularStreams func(childComplexity int, first int, after *string) int
ProfileDirectory func(childComplexity int, filters *model.DirectoryFiltersInput, first *int, after *model.Cursor) int
Publication func(childComplexity int, id string) int
PublicationBySlug func(childComplexity int, slug string) int
PushSubscription func(childComplexity int) int
Relationship func(childComplexity int, id string) int
Relationships func(childComplexity int, ids []string) int
RemoveSuggestion func(childComplexity int, accountID string) int
Reputation func(childComplexity int, actorID string) int
Revision func(childComplexity int, objectID string, version int) int
Revisions func(childComplexity int, objectID string, first *int, after *model.Cursor) int
RootCategories func(childComplexity int) int
ScheduledStatus func(childComplexity int, id string) int
ScheduledStatuses func(childComplexity int, first *int, after *model.Cursor) int
Search func(childComplexity int, query string, typeArg *string, first *int, after *model.Cursor) int
Series func(childComplexity int, id string) int
SeriesBySlug func(childComplexity int, slug string) int
SeveredRelationships func(childComplexity int, instance *string, first *int, after *string) int
SlowQueries func(childComplexity int, threshold model.Duration) int
StatusFavouritedBy func(childComplexity int, id string, first *int, after *model.Cursor) int
StatusHistory func(childComplexity int, id string, limit *int) int
StatusRebloggedBy func(childComplexity int, id string, first *int, after *model.Cursor) int
StreamingAnalytics func(childComplexity int, mediaID string) int
SuggestedHashtags func(childComplexity int, limit *int) int
Suggestions func(childComplexity int, limit *int) int
SupportedBitrates func(childComplexity int, mediaID string) int
ThreadContext func(childComplexity int, noteID string) int
Timeline func(childComplexity int, typeArg model.TimelineType, hashtag *string, listID *string, actorID *string, first *int, after *model.Cursor, mediaOnly *bool) int
TranslateStatus func(childComplexity int, id string, targetLanguage *string) int
TranslationLanguages func(childComplexity int) int
TrendingLinks func(childComplexity int, limit *int) int
TrendingStatuses func(childComplexity int, limit *int) int
TrendingTags func(childComplexity int, limit *int) int
Trends func(childComplexity int, limit *int) int
TrustGraph func(childComplexity int, actorID string, category *models.TrustCategory) int
UserPreferences func(childComplexity int) int
Viewer func(childComplexity int) int
Vouches func(childComplexity int, actorID string) int
}
QueryPerformance struct {
AvgDuration func(childComplexity int) int
Count func(childComplexity int) int
ErrorCount func(childComplexity int) int
LastSeen func(childComplexity int) int
P95Duration func(childComplexity int) int
Query func(childComplexity int) int
}
QueueStatus struct {
Depth func(childComplexity int) int
DlqCount func(childComplexity int) int
Name func(childComplexity int) int
OldestMessage func(childComplexity int) int
ProcessingRate func(childComplexity int) int
}
QuoteActivityUpdate struct {
Quote func(childComplexity int) int
Quoter func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
QuoteConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
QuoteContext struct {
OriginalAuthor func(childComplexity int) int
OriginalNote func(childComplexity int) int
QuoteAllowed func(childComplexity int) int
QuoteType func(childComplexity int) int
Withdrawn func(childComplexity int) int
}
QuoteEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
ReadingPreferences struct {
AutoplayGifs func(childComplexity int) int
ExpandMedia func(childComplexity int) int
ExpandSpoilers func(childComplexity int) int
TimelineOrder func(childComplexity int) int
}
ReblogFilter struct {
Enabled func(childComplexity int) int
Key func(childComplexity int) int
}
ReconnectionPayload struct {
Errors func(childComplexity int) int
Failed func(childComplexity int) int
Reconnected func(childComplexity int) int
SeveredRelationship func(childComplexity int) int
Success func(childComplexity int) int
}
RegisterAccountPayload struct {
Actor func(childComplexity int) int
Created func(childComplexity int) int
}
RegisterAgentPayload struct {
Agent func(childComplexity int) int
}
Relationship struct {
BlockedBy func(childComplexity int) int
Blocking func(childComplexity int) int
DomainBlocking func(childComplexity int) int
FollowedBy func(childComplexity int) int
Following func(childComplexity int) int
ID func(childComplexity int) int
Languages func(childComplexity int) int
Muting func(childComplexity int) int
MutingNotifications func(childComplexity int) int
Note func(childComplexity int) int
Notifying func(childComplexity int) int
Requested func(childComplexity int) int
ShowingReblogs func(childComplexity int) int
}
RelationshipUpdate struct {
Actor func(childComplexity int) int
Relationship func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
Report struct {
ActionTaken func(childComplexity int) int
ActionTakenAt func(childComplexity int) int
Category func(childComplexity int) int
Comment func(childComplexity int) int
CreatedAt func(childComplexity int) int
Forwarded func(childComplexity int) int
ID func(childComplexity int) int
RuleIds func(childComplexity int) int
StatusIds func(childComplexity int) int
TargetAccount func(childComplexity int) int
}
Reputation struct {
ActivityScore func(childComplexity int) int
ActorID func(childComplexity int) int
CalculatedAt func(childComplexity int) int
CommunityScore func(childComplexity int) int
Evidence func(childComplexity int) int
Instance func(childComplexity int) int
ModerationScore func(childComplexity int) int
Signature func(childComplexity int) int
TotalScore func(childComplexity int) int
TrustScore func(childComplexity int) int
Version func(childComplexity int) int
}
ReputationEvidence struct {
AccountAge func(childComplexity int) int
AverageTrustScore func(childComplexity int) int
TotalFollowers func(childComplexity int) int
TotalPosts func(childComplexity int) int
TrustingActors func(childComplexity int) int
VouchCount func(childComplexity int) int
}
ReputationImportResult struct {
ActorID func(childComplexity int) int
Error func(childComplexity int) int
ImportedScore func(childComplexity int) int
Message func(childComplexity int) int
PreviousScore func(childComplexity int) int
Success func(childComplexity int) int
VouchesImported func(childComplexity int) int
}
ReputationVerificationResult struct {
ActorID func(childComplexity int) int
Error func(childComplexity int) int
ExpiresAt func(childComplexity int) int
IssuedAt func(childComplexity int) int
Issuer func(childComplexity int) int
IssuerTrusted func(childComplexity int) int
NotExpired func(childComplexity int) int
SignatureValid func(childComplexity int) int
Valid func(childComplexity int) int
}
Revision struct {
ChangeSummary func(childComplexity int) int
ChangeType func(childComplexity int) int
ChangedBy func(childComplexity int) int
Content func(childComplexity int) int
CreatedAt func(childComplexity int) int
ID func(childComplexity int) int
MetadataJSON func(childComplexity int) int
ObjectID func(childComplexity int) int
Version func(childComplexity int) int
}
RevisionConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
RevisionEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
ScheduledStatus struct {
CreatedAt func(childComplexity int) int
ID func(childComplexity int) int
MediaAttachments func(childComplexity int) int
Params func(childComplexity int) int
ScheduledAt func(childComplexity int) int
}
SearchResult struct {
Accounts func(childComplexity int) int
Hashtags func(childComplexity int) int
Statuses func(childComplexity int) int
}
SentimentScores struct {
Mixed func(childComplexity int) int
Negative func(childComplexity int) int
Neutral func(childComplexity int) int
Positive func(childComplexity int) int
}
Series struct {
ArticleCount func(childComplexity int) int
Author func(childComplexity int) int
CoverImageURL func(childComplexity int) int
CreatedAt func(childComplexity int) int
Description func(childComplexity int) int
ID func(childComplexity int) int
IsComplete func(childComplexity int) int
Slug func(childComplexity int) int
Title func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
SeriesConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
SeriesEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
ServiceStatus struct {
ErrorRate func(childComplexity int) int
LastRestart func(childComplexity int) int
Name func(childComplexity int) int
Status func(childComplexity int) int
Type func(childComplexity int) int
Uptime func(childComplexity int) int
}
SeveranceDetails struct {
AdminNotes func(childComplexity int) int
AutoDetected func(childComplexity int) int
Description func(childComplexity int) int
Metadata func(childComplexity int) int
}
SeveredRelationship struct {
AffectedFollowers func(childComplexity int) int
AffectedFollowing func(childComplexity int) int
Details func(childComplexity int) int
ID func(childComplexity int) int
LocalInstance func(childComplexity int) int
Reason func(childComplexity int) int
RemoteInstance func(childComplexity int) int
Reversible func(childComplexity int) int
Timestamp func(childComplexity int) int
}
SeveredRelationshipConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
SeveredRelationshipEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
SpamAnalysis struct {
AccountAgeDays func(childComplexity int) int
FollowerRatio func(childComplexity int) int
InteractionRate func(childComplexity int) int
LinkDensity func(childComplexity int) int
PostingVelocity func(childComplexity int) int
RepetitionScore func(childComplexity int) int
SpamIndicators func(childComplexity int) int
SpamScore func(childComplexity int) int
}
SpamIndicator struct {
Description func(childComplexity int) int
Severity func(childComplexity int) int
Type func(childComplexity int) int
}
StatusEdit struct {
Account func(childComplexity int) int
Content func(childComplexity int) int
CreatedAt func(childComplexity int) int
Sensitive func(childComplexity int) int
SpoilerText func(childComplexity int) int
}
StatusParams struct {
InReplyToID func(childComplexity int) int
Language func(childComplexity int) int
Poll func(childComplexity int) int
Sensitive func(childComplexity int) int
SpoilerText func(childComplexity int) int
Text func(childComplexity int) int
Visibility func(childComplexity int) int
}
Stream struct {
CreatedAt func(childComplexity int) int
Duration func(childComplexity int) int
ID func(childComplexity int) int
MediaID func(childComplexity int) int
Popularity func(childComplexity int) int
Quality func(childComplexity int) int
Thumbnail func(childComplexity int) int
Title func(childComplexity int) int
ViewCount func(childComplexity int) int
}
StreamConnection struct {
Edges func(childComplexity int) int
PageInfo func(childComplexity int) int
TotalCount func(childComplexity int) int
}
StreamEdge struct {
Cursor func(childComplexity int) int
Node func(childComplexity int) int
}
StreamingAnalytics struct {
AverageWatchTime func(childComplexity int) int
BufferingEvents func(childComplexity int) int
CompletionRate func(childComplexity int) int
QualityDistribution func(childComplexity int) int
TotalViews func(childComplexity int) int
UniqueViewers func(childComplexity int) int
}
StreamingPreferences struct {
AutoQuality func(childComplexity int) int
DataSaver func(childComplexity int) int
DefaultQuality func(childComplexity int) int
PreloadNext func(childComplexity int) int
}
StreamingQualityReport struct {
MediaID func(childComplexity int) int
Quality func(childComplexity int) int
ReportID func(childComplexity int) int
Success func(childComplexity int) int
}
Subscription struct {
ActivityStream func(childComplexity int, types []model.ActivityType) int
AgentActivity func(childComplexity int, username string) int
AiAnalysisUpdates func(childComplexity int, objectID *string) int
BudgetAlerts func(childComplexity int, domain *string) int
ConversationUpdates func(childComplexity int) int
CostAlerts func(childComplexity int, thresholdUsd float64) int
CostUpdates func(childComplexity int, threshold *int) int
FederationHealthUpdates func(childComplexity int, domain *string) int
HashtagActivity func(childComplexity int, hashtags []string) int
InfrastructureEvent func(childComplexity int) int
ListUpdates func(childComplexity int, listID string) int
MetricsUpdates func(childComplexity int, categories []string, services []string, threshold *float64) int
ModerationAlerts func(childComplexity int, severity *model.ModerationSeverity) int
ModerationEvents func(childComplexity int, actorID *string) int
ModerationQueueUpdate func(childComplexity int, priority *model.Priority) int
NotificationStream func(childComplexity int, types []string) int
PerformanceAlert func(childComplexity int, severity model.AlertSeverity) int
QuoteActivity func(childComplexity int, noteID string) int
RelationshipUpdates func(childComplexity int, actorID *string) int
ThreatIntelligence func(childComplexity int) int
TimelineUpdates func(childComplexity int, typeArg model.TimelineType, listID *string) int
TrustUpdates func(childComplexity int, actorID string) int
}
SyncRepliesPayload struct {
Success func(childComplexity int) int
SyncedReplies func(childComplexity int) int
Thread func(childComplexity int) int
}
SyncThreadPayload struct {
Errors func(childComplexity int) int
Success func(childComplexity int) int
SyncedPosts func(childComplexity int) int
Thread func(childComplexity int) int
}
TOCEntry struct {
ID func(childComplexity int) int
Level func(childComplexity int) int
Text func(childComplexity int) int
}
Tag struct {
Name func(childComplexity int) int
URL func(childComplexity int) int
}
TextAnalysis struct {
ContainsPii func(childComplexity int) int
DominantLanguage func(childComplexity int) int
Entities func(childComplexity int) int
KeyPhrases func(childComplexity int) int
Sentiment func(childComplexity int) int
SentimentScores func(childComplexity int) int
ToxicityLabels func(childComplexity int) int
ToxicityScore func(childComplexity int) int
}
TextAnalysisCapabilities struct {
EntityExtraction func(childComplexity int) int
LanguageDetection func(childComplexity int) int
PiiDetection func(childComplexity int) int
SentimentAnalysis func(childComplexity int) int
SpamDetection func(childComplexity int) int
ToxicityDetection func(childComplexity int) int
}
ThreadContext struct {
Ancestors func(childComplexity int) int
Descendants func(childComplexity int) int
LastActivity func(childComplexity int) int
MissingPosts func(childComplexity int) int
ParticipantCount func(childComplexity int) int
ReplyCount func(childComplexity int) int
RootNote func(childComplexity int) int
SyncStatus func(childComplexity int) int
}
ThreatAlert struct {
AffectedInstances func(childComplexity int) int
Description func(childComplexity int) int
ID func(childComplexity int) int
MitigationSteps func(childComplexity int) int
Severity func(childComplexity int) int
Source func(childComplexity int) int
Timestamp func(childComplexity int) int
Type func(childComplexity int) int
}
ThreatTrend struct {
Change func(childComplexity int) int
Count func(childComplexity int) int
Instances func(childComplexity int) int
Severity func(childComplexity int) int
Type func(childComplexity int) int
}
TipsConfig struct {
ChainID func(childComplexity int) int
ContractAddress func(childComplexity int) int
Enabled func(childComplexity int) int
}
TrainingResult struct {
Accuracy func(childComplexity int) int
DatasetS3Key func(childComplexity int) int
F1Score func(childComplexity int) int
Improvements func(childComplexity int) int
JobID func(childComplexity int) int
JobName func(childComplexity int) int
ModelVersion func(childComplexity int) int
Precision func(childComplexity int) int
Recall func(childComplexity int) int
SamplesUsed func(childComplexity int) int
Status func(childComplexity int) int
Success func(childComplexity int) int
TrainingTime func(childComplexity int) int
}
TranslationLanguage struct {
Code func(childComplexity int) int
Name func(childComplexity int) int
}
TranslationResult struct {
Content func(childComplexity int) int
DetectedLanguage func(childComplexity int) int
Provider func(childComplexity int) int
SpoilerText func(childComplexity int) int
}
TrendingItem struct {
Hashtag func(childComplexity int) int
Link func(childComplexity int) int
Status func(childComplexity int) int
Type func(childComplexity int) int
}
TrendingLink struct {
AuthorName func(childComplexity int) int
Description func(childComplexity int) int
Image func(childComplexity int) int
Shares func(childComplexity int) int
Title func(childComplexity int) int
Type func(childComplexity int) int
URL func(childComplexity int) int
}
TrendingStatus struct {
AuthorID func(childComplexity int) int
Content func(childComplexity int) int
Engagements func(childComplexity int) int
ID func(childComplexity int) int
PublishedAt func(childComplexity int) int
URL func(childComplexity int) int
}
TrendingTag struct {
Accounts func(childComplexity int) int
History func(childComplexity int) int
Name func(childComplexity int) int
URL func(childComplexity int) int
Uses func(childComplexity int) int
}
TrustCategoryScore struct {
Category func(childComplexity int) int
Score func(childComplexity int) int
}
TrustEdge struct {
Category func(childComplexity int) int
From func(childComplexity int) int
Score func(childComplexity int) int
To func(childComplexity int) int
UpdatedAt func(childComplexity int) int
}
UnfollowHashtagPayload struct {
Hashtag func(childComplexity int) int
Success func(childComplexity int) int
}
UpdateHashtagNotificationsPayload struct {
Hashtag func(childComplexity int) int
Settings func(childComplexity int) int
Success func(childComplexity int) int
}
UpdateQuotePermissionsPayload struct {
AffectedQuotes func(childComplexity int) int
Note func(childComplexity int) int
Success func(childComplexity int) int
}
UploadMediaPayload struct {
Media func(childComplexity int) int
UploadID func(childComplexity int) int
Warnings func(childComplexity int) int
}
UserPreferences struct {
ActorID func(childComplexity int) int
Discovery func(childComplexity int) int
Notifications func(childComplexity int) int
Posting func(childComplexity int) int
Privacy func(childComplexity int) int
Reading func(childComplexity int) int
ReblogFilters func(childComplexity int) int
Streaming func(childComplexity int) int
}
Vouch struct {
Active func(childComplexity int) int
Confidence func(childComplexity int) int
Context func(childComplexity int) int
CreatedAt func(childComplexity int) int
ExpiresAt func(childComplexity int) int
From func(childComplexity int) int
ID func(childComplexity int) int
Revoked func(childComplexity int) int
RevokedAt func(childComplexity int) int
To func(childComplexity int) int
VoucherReputation func(childComplexity int) int
}
WithdrawQuotePayload struct {
Note func(childComplexity int) int
Success func(childComplexity int) int
WithdrawnCount func(childComplexity int) int
}
}
type Config ¶
type Config struct {
Schema *ast.Schema
Resolvers ResolverRoot
Directives DirectiveRoot
Complexity ComplexityRoot
}
type CursorData ¶
type CursorData struct {
ID string `json:"id"`
Timestamp time.Time `json:"timestamp"`
Score float64 `json:"score,omitempty"`
}
CursorData represents cursor data for GraphQL pagination
func DecodeGraphQLCursor ¶
func DecodeGraphQLCursor(cursor model.Cursor) (*CursorData, error)
DecodeGraphQLCursor parses a cursor back to cursor data
type DirectiveRoot ¶
type DirectiveRoot struct {
}
type DriverResolver ¶
type DriverResolver interface {
Type(ctx context.Context, obj *cost.Driver) (string, error)
Domain(ctx context.Context, obj *cost.Driver) (*string, error)
Cost(ctx context.Context, obj *cost.Driver) (float64, error)
PercentOfTotal(ctx context.Context, obj *cost.Driver) (float64, error)
Trend(ctx context.Context, obj *cost.Driver) (model.Trend, error)
}
type EventConverter ¶
type EventConverter struct {
// contains filtered or unexported fields
}
EventConverter converts streaming.InternalEvent to GraphQL model types
func NewEventConverter ¶
func NewEventConverter(logger *zap.Logger) *EventConverter
NewEventConverter creates a new event converter
func (*EventConverter) ConvertToAIAnalysis ¶
func (ec *EventConverter) ConvertToAIAnalysis(event *streaming.InternalEvent) *model.AIAnalysis
ConvertToAIAnalysis converts a streaming event to a model.AIAnalysis
func (*EventConverter) ConvertToBudgetAlert ¶
func (ec *EventConverter) ConvertToBudgetAlert(event *streaming.InternalEvent) *model.BudgetAlert
ConvertToBudgetAlert converts a streaming event to a GraphQL BudgetAlert
func (*EventConverter) ConvertToConversation ¶
func (ec *EventConverter) ConvertToConversation(event *streaming.InternalEvent) *model.Conversation
ConvertToConversation converts a streaming event to a GraphQL Conversation
func (*EventConverter) ConvertToCostAlert ¶
func (ec *EventConverter) ConvertToCostAlert(event *streaming.InternalEvent, thresholdUSD float64) *model.CostAlert
ConvertToCostAlert converts a streaming event to a GraphQL CostAlert
func (*EventConverter) ConvertToCostUpdate ¶
func (ec *EventConverter) ConvertToCostUpdate(event *streaming.InternalEvent) *model.CostUpdate
ConvertToCostUpdate converts a streaming event to a GraphQL CostUpdate
func (*EventConverter) ConvertToFederationHealthUpdate ¶
func (ec *EventConverter) ConvertToFederationHealthUpdate(event *streaming.InternalEvent) *model.FederationHealthUpdate
ConvertToFederationHealthUpdate converts a streaming event to a GraphQL FederationHealthUpdate
func (*EventConverter) ConvertToHashtagActivity ¶
func (ec *EventConverter) ConvertToHashtagActivity(event *streaming.InternalEvent) *model.HashtagActivityUpdate
ConvertToHashtagActivity converts a streaming event to a model.HashtagActivityUpdate
func (*EventConverter) ConvertToInfrastructureEvent ¶
func (ec *EventConverter) ConvertToInfrastructureEvent(event *streaming.InternalEvent) *model.InfrastructureEvent
ConvertToInfrastructureEvent converts a streaming event to a GraphQL InfrastructureEvent
func (*EventConverter) ConvertToListUpdate ¶
func (ec *EventConverter) ConvertToListUpdate(event *streaming.InternalEvent) *model.ListUpdate
ConvertToListUpdate converts a streaming event to a GraphQL ListUpdate
func (*EventConverter) ConvertToMetricsUpdate ¶
func (ec *EventConverter) ConvertToMetricsUpdate(event *streaming.InternalEvent) *model.MetricsUpdate
ConvertToMetricsUpdate converts a streaming event to a GraphQL MetricsUpdate
func (*EventConverter) ConvertToModerationAlert ¶
func (ec *EventConverter) ConvertToModerationAlert(event *streaming.InternalEvent, severity *model.ModerationSeverity) *model.ModerationAlert
ConvertToModerationAlert converts a streaming event to a GraphQL ModerationAlert
func (*EventConverter) ConvertToModerationDecision ¶
func (ec *EventConverter) ConvertToModerationDecision(event *streaming.InternalEvent) *moderation.ModerationDecision
ConvertToModerationDecision converts a streaming event to a moderation.ModerationDecision
func (*EventConverter) ConvertToNotification ¶
func (ec *EventConverter) ConvertToNotification(event *streaming.InternalEvent) *model.Notification
ConvertToNotification converts a streaming event to a GraphQL Notification
func (*EventConverter) ConvertToObject ¶
func (ec *EventConverter) ConvertToObject(event *streaming.InternalEvent) *model.Object
ConvertToObject converts a streaming event to a GraphQL Object
func (*EventConverter) ConvertToPerformanceAlert ¶
func (ec *EventConverter) ConvertToPerformanceAlert(event *streaming.InternalEvent) *model.PerformanceAlert
ConvertToPerformanceAlert converts a streaming event to a GraphQL PerformanceAlert
func (*EventConverter) ConvertToQuoteActivity ¶
func (ec *EventConverter) ConvertToQuoteActivity(event *streaming.InternalEvent) *model.QuoteActivityUpdate
ConvertToQuoteActivity converts a streaming event to a model.QuoteActivityUpdate
func (*EventConverter) ConvertToRelationshipUpdate ¶
func (ec *EventConverter) ConvertToRelationshipUpdate(event *streaming.InternalEvent) *model.RelationshipUpdate
ConvertToRelationshipUpdate converts a streaming event to a GraphQL RelationshipUpdate
func (*EventConverter) ConvertToThreatAlert ¶
func (ec *EventConverter) ConvertToThreatAlert(event *streaming.InternalEvent) *model.ThreatAlert
ConvertToThreatAlert converts a streaming event to a GraphQL ThreatAlert
func (*EventConverter) ConvertToTrustEdge ¶
func (ec *EventConverter) ConvertToTrustEdge(event *streaming.InternalEvent) *trust.TrustEdge
ConvertToTrustEdge converts a streaming event to a trust.TrustEdge
type GraphQLSubscription ¶
type GraphQLSubscription struct {
ID string
Type string // timeline, notification, cost, etc.
UserID string // User context
ConnectionID string // WebSocket connection ID
Params map[string]interface{} // Subscription parameters
Streams []string // Stream names subscribed to
OutputChannel interface{} // Typed output channel
Context context.Context // Subscription context
Cancel context.CancelFunc // Cancel function
Created time.Time
LastActivity time.Time
}
GraphQLSubscription represents an active GraphQL subscription
type GraphQLSubscriptionManager ¶
type GraphQLSubscriptionManager struct {
// contains filtered or unexported fields
}
GraphQLSubscriptionManager manages lifecycle of all GraphQL subscriptions using DynamoDB-backed persistence and queue-based event delivery
func NewGraphQLSubscriptionManager ¶
func NewGraphQLSubscriptionManager( connRepo interfaces.StreamingConnectionRepository, publisher streaming.Publisher, logger *zap.Logger, ) *GraphQLSubscriptionManager
NewGraphQLSubscriptionManager creates a new GraphQL subscription manager with DynamoDB backing
func (*GraphQLSubscriptionManager) GetStats ¶
func (sm *GraphQLSubscriptionManager) GetStats() map[string]interface{}
GetStats returns statistics about active subscriptions
func (*GraphQLSubscriptionManager) IsRunning ¶
func (sm *GraphQLSubscriptionManager) IsRunning() bool
IsRunning returns whether the subscription manager is running
func (*GraphQLSubscriptionManager) Start ¶
func (sm *GraphQLSubscriptionManager) Start(ctx context.Context) error
Start starts the subscription manager
func (*GraphQLSubscriptionManager) Stop ¶
func (sm *GraphQLSubscriptionManager) Stop() error
Stop stops the subscription manager and cleans up all subscriptions
func (*GraphQLSubscriptionManager) SubscribeToAIAnalysis ¶
func (sm *GraphQLSubscriptionManager) SubscribeToAIAnalysis(ctx context.Context, objectID *string) (<-chan *model.AIAnalysis, error)
SubscribeToAIAnalysis subscribes to AI analysis updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToBudgetAlerts ¶
func (sm *GraphQLSubscriptionManager) SubscribeToBudgetAlerts(ctx context.Context, username string, domain *string) (<-chan *model.BudgetAlert, error)
SubscribeToBudgetAlerts subscribes to budget alert updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToConversation ¶
func (sm *GraphQLSubscriptionManager) SubscribeToConversation(ctx context.Context, username string) (<-chan *model.Conversation, error)
SubscribeToConversation subscribes to conversation updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToCostAlerts ¶
func (sm *GraphQLSubscriptionManager) SubscribeToCostAlerts(ctx context.Context, username string, thresholdUSD float64) (<-chan *model.CostAlert, error)
SubscribeToCostAlerts subscribes to cost alert updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToCostUpdates ¶
func (sm *GraphQLSubscriptionManager) SubscribeToCostUpdates(ctx context.Context, username string, threshold *int) (<-chan *model.CostUpdate, error)
SubscribeToCostUpdates subscribes to cost update events via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToFederationHealth ¶
func (sm *GraphQLSubscriptionManager) SubscribeToFederationHealth(ctx context.Context, username string, domain *string) (<-chan *model.FederationHealthUpdate, error)
SubscribeToFederationHealth subscribes to federation health updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToHashtagActivity ¶
func (sm *GraphQLSubscriptionManager) SubscribeToHashtagActivity(ctx context.Context, username string, hashtags []string) (<-chan *model.HashtagActivityUpdate, error)
SubscribeToHashtagActivity subscribes to hashtag activity via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToInfrastructureEvents ¶
func (sm *GraphQLSubscriptionManager) SubscribeToInfrastructureEvents(ctx context.Context, username string) (<-chan *model.InfrastructureEvent, error)
SubscribeToInfrastructureEvents subscribes to infrastructure event updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToListActivity ¶
func (sm *GraphQLSubscriptionManager) SubscribeToListActivity(ctx context.Context, username string, listID string) (<-chan *model.ListUpdate, error)
SubscribeToListActivity subscribes to list activity updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToMetricsUpdates ¶
func (sm *GraphQLSubscriptionManager) SubscribeToMetricsUpdates(ctx context.Context, username string, categories []string, services []string, threshold *float64) (<-chan *model.MetricsUpdate, error)
SubscribeToMetricsUpdates subscribes to real-time metrics updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToModerationAlerts ¶
func (sm *GraphQLSubscriptionManager) SubscribeToModerationAlerts(ctx context.Context, username string, severity *model.ModerationSeverity) (<-chan *model.ModerationAlert, error)
SubscribeToModerationAlerts subscribes to moderation alert updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToModerationEvents ¶
func (sm *GraphQLSubscriptionManager) SubscribeToModerationEvents(ctx context.Context, actorID *string) (<-chan *moderation.ModerationDecision, error)
SubscribeToModerationEvents subscribes to moderation events via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToModerationQueueUpdate ¶
func (sm *GraphQLSubscriptionManager) SubscribeToModerationQueueUpdate(ctx context.Context, username string, priority *model.Priority) (<-chan *model.ModerationItem, error)
SubscribeToModerationQueueUpdate subscribes to moderation queue updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToNotifications ¶
func (sm *GraphQLSubscriptionManager) SubscribeToNotifications(ctx context.Context, username string) (<-chan *model.Notification, error)
SubscribeToNotifications subscribes to notification events via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToPerformanceAlerts ¶
func (sm *GraphQLSubscriptionManager) SubscribeToPerformanceAlerts(ctx context.Context, username string, severity model.AlertSeverity) (<-chan *model.PerformanceAlert, error)
SubscribeToPerformanceAlerts subscribes to performance alert updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToQuoteActivity ¶
func (sm *GraphQLSubscriptionManager) SubscribeToQuoteActivity(ctx context.Context, username string, noteID string) (<-chan *model.QuoteActivityUpdate, error)
SubscribeToQuoteActivity subscribes to quote activity via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToRelationshipUpdates ¶
func (sm *GraphQLSubscriptionManager) SubscribeToRelationshipUpdates(ctx context.Context, username string, actorID *string) (<-chan *model.RelationshipUpdate, error)
SubscribeToRelationshipUpdates subscribes to relationship updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToThreatIntelligence ¶
func (sm *GraphQLSubscriptionManager) SubscribeToThreatIntelligence(ctx context.Context, username string) (<-chan *model.ThreatAlert, error)
SubscribeToThreatIntelligence subscribes to threat intelligence updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToTimeline ¶
func (sm *GraphQLSubscriptionManager) SubscribeToTimeline(ctx context.Context, username string, timelineType model.TimelineType) (<-chan *model.Object, error)
SubscribeToTimeline subscribes to timeline updates via DynamoDB-backed subscriptions
func (*GraphQLSubscriptionManager) SubscribeToTrustUpdates ¶
func (sm *GraphQLSubscriptionManager) SubscribeToTrustUpdates(ctx context.Context, actorID string) (<-chan *trust.TrustEdge, error)
SubscribeToTrustUpdates subscribes to trust score updates via DynamoDB-backed subscriptions
type ImageAnalysisResolver ¶
type ImageAnalysisResolver interface {
IsNsfw(ctx context.Context, obj *moderation.ImageAnalysis) (bool, error)
NsfwConfidence(ctx context.Context, obj *moderation.ImageAnalysis) (float64, error)
ViolenceScore(ctx context.Context, obj *moderation.ImageAnalysis) (float64, error)
WeaponsDetected(ctx context.Context, obj *moderation.ImageAnalysis) (bool, error)
TextToxicity(ctx context.Context, obj *moderation.ImageAnalysis) (float64, error)
CelebrityFaces(ctx context.Context, obj *moderation.ImageAnalysis) ([]*model.Celebrity, error)
DeepfakeScore(ctx context.Context, obj *moderation.ImageAnalysis) (float64, error)
}
type Loaders ¶
type Loaders struct {
ActorLoader *dataloader.Loader
ObjectLoader *dataloader.Loader
TrustScoreLoader *dataloader.Loader
QuoteTargetLoader *dataloader.Loader
// Viewer interaction loaders (GraphQL fields on Object).
ViewerFavouritedLoader *dataloader.Loader
ViewerBookmarkedLoader *dataloader.Loader
ViewerPinnedLoader *dataloader.Loader
}
Loaders holds all the dataloaders for the GraphQL server
func GetLoaders ¶
GetLoaders retrieves loaders from context
func NewLoaders ¶
func NewLoaders(repos core.RepositoryStorage, logger *zap.Logger) *Loaders
NewLoaders creates new instances of all dataloaders
type ModerationDecisionResolver ¶
type ModerationDecisionResolver interface {
Object(ctx context.Context, obj *moderation.ModerationDecision) (*model.Object, error)
Decision(ctx context.Context, obj *moderation.ModerationDecision) (string, error)
Confidence(ctx context.Context, obj *moderation.ModerationDecision) (float64, error)
Evidence(ctx context.Context, obj *moderation.ModerationDecision) ([]string, error)
Reviewers(ctx context.Context, obj *moderation.ModerationDecision) ([]*activitypub.Actor, error)
Timestamp(ctx context.Context, obj *moderation.ModerationDecision) (*model.Time, error)
}
type ModerationFilterResolver ¶
type ModerationFilterResolver interface {
Severity(ctx context.Context, obj *moderation.ModerationFilter, data *model.ModerationSeverity) error
AssignedTo(ctx context.Context, obj *moderation.ModerationFilter, data *string) error
Priority(ctx context.Context, obj *moderation.ModerationFilter, data *model.Priority) error
Unhandled(ctx context.Context, obj *moderation.ModerationFilter, data *bool) error
}
type ModerationLabelResolver ¶
type ModerationLabelResolver interface {
Confidence(ctx context.Context, obj *moderation.ModerationLabel) (float64, error)
}
type ModerationPatternResolver ¶
type ModerationPatternResolver interface {
Pattern(ctx context.Context, obj *moderation.ModerationPattern) (string, error)
Type(ctx context.Context, obj *moderation.ModerationPattern) (model.PatternType, error)
Severity(ctx context.Context, obj *moderation.ModerationPattern) (model.ModerationSeverity, error)
FalsePositiveRate(ctx context.Context, obj *moderation.ModerationPattern) (float64, error)
CreatedAt(ctx context.Context, obj *moderation.ModerationPattern) (*model.Time, error)
UpdatedAt(ctx context.Context, obj *moderation.ModerationPattern) (*model.Time, error)
CreatedBy(ctx context.Context, obj *moderation.ModerationPattern) (*activitypub.Actor, error)
}
type MutationResolver ¶
type MutationResolver interface {
RegisterAccount(ctx context.Context, input model.RegisterAccountInput) (*model.RegisterAccountPayload, error)
UpdateAccountQuotePermissions(ctx context.Context, input model.UpdateAccountQuotePermissionsInput) (*model.AccountQuotePermissions, error)
AcceptFollowRequest(ctx context.Context, accountID string) (*model.Relationship, error)
RejectFollowRequest(ctx context.Context, accountID string) (*model.Relationship, error)
AddDomainBlock(ctx context.Context, domain string) (bool, error)
RemoveDomainBlock(ctx context.Context, domain string) (bool, error)
SaveMarkers(ctx context.Context, input []*model.SaveMarkerInput) (*model.MarkerSet, error)
CreateNote(ctx context.Context, input model.CreateNoteInput) (*model.CreateNotePayload, error)
UpdateStatus(ctx context.Context, id string, input model.UpdateStatusInput) (*model.Object, error)
DeleteObject(ctx context.Context, id string) (bool, error)
LikeObject(ctx context.Context, id string) (*activitypub.Activity, error)
UnlikeObject(ctx context.Context, id string) (bool, error)
BookmarkObject(ctx context.Context, id string) (*model.Object, error)
UnbookmarkObject(ctx context.Context, id string) (bool, error)
PinObject(ctx context.Context, id string) (*model.Object, error)
UnpinObject(ctx context.Context, id string) (bool, error)
MuteStatus(ctx context.Context, id string, durationSeconds *int) (bool, error)
UnmuteStatus(ctx context.Context, id string) (bool, error)
DismissAnnouncement(ctx context.Context, id string) (bool, error)
AddAnnouncementReaction(ctx context.Context, id string, name string) (bool, error)
RemoveAnnouncementReaction(ctx context.Context, id string, name string) (bool, error)
FollowActor(ctx context.Context, id string) (*activitypub.Activity, error)
UnfollowActor(ctx context.Context, id string) (bool, error)
BlockActor(ctx context.Context, id string) (*model.Relationship, error)
UnblockActor(ctx context.Context, id string) (bool, error)
MuteActor(ctx context.Context, id string, notifications *bool) (*model.Relationship, error)
UnmuteActor(ctx context.Context, id string) (bool, error)
UpdateRelationship(ctx context.Context, id string, input model.UpdateRelationshipInput) (*model.Relationship, error)
UpdateProfile(ctx context.Context, input model.UpdateProfileInput) (*activitypub.Actor, error)
CreateList(ctx context.Context, input model.CreateListInput) (*model.List, error)
UpdateList(ctx context.Context, id string, input model.UpdateListInput) (*model.List, error)
DeleteList(ctx context.Context, id string) (bool, error)
AddAccountsToList(ctx context.Context, id string, accountIds []string) (*model.List, error)
RemoveAccountsFromList(ctx context.Context, id string, accountIds []string) (*model.List, error)
MarkConversationAsRead(ctx context.Context, id string) (*model.Conversation, error)
DeleteConversation(ctx context.Context, id string) (bool, error)
UploadMedia(ctx context.Context, input model.UploadMediaInput) (*model.UploadMediaPayload, error)
UpdateMedia(ctx context.Context, id string, input model.UpdateMediaInput) (*model.Media, error)
DismissNotification(ctx context.Context, id string) (bool, error)
ClearNotifications(ctx context.Context) (bool, error)
MarkNotificationGroupAsRead(ctx context.Context, groupID string) (bool, error)
UpdateUserPreferences(ctx context.Context, input model.UpdateUserPreferencesInput) (*model.UserPreferences, error)
UpdateStreamingPreferences(ctx context.Context, input model.StreamingPreferencesInput) (*model.UserPreferences, error)
RegisterPushSubscription(ctx context.Context, input model.RegisterPushSubscriptionInput) (*model.PushSubscription, error)
UpdatePushSubscription(ctx context.Context, input model.UpdatePushSubscriptionInput) (*model.PushSubscription, error)
DeletePushSubscription(ctx context.Context) (bool, error)
CreateExport(ctx context.Context, input model.CreateExportInput) (*model.ExportJob, error)
CreateImport(ctx context.Context, input model.CreateImportInput) (*model.ImportJob, error)
CancelImport(ctx context.Context, id string) (*model.ImportJob, error)
CreateFilter(ctx context.Context, input model.CreateFilterInput) (*mastodon.Filter, error)
UpdateFilter(ctx context.Context, id string, input model.UpdateFilterInput) (*mastodon.Filter, error)
DeleteFilter(ctx context.Context, id string) (bool, error)
AddFilterKeyword(ctx context.Context, filterID string, input model.AddFilterKeywordInput) (*mastodon.FilterKeyword, error)
DeleteFilterKeyword(ctx context.Context, filterID string, keywordID string) (bool, error)
AddFilterStatus(ctx context.Context, filterID string, statusID string) (*mastodon.FilterStatus, error)
DeleteFilterStatus(ctx context.Context, filterID string, filterStatusID string) (bool, error)
TestFilters(ctx context.Context, input model.FilterTestInput) (*model.FilterTestPayload, error)
ScheduleStatus(ctx context.Context, input model.ScheduleStatusInput) (*model.ScheduledStatus, error)
UpdateScheduledStatus(ctx context.Context, id string, input model.UpdateScheduledStatusInput) (*model.ScheduledStatus, error)
CancelScheduledStatus(ctx context.Context, id string) (bool, error)
CreateEmoji(ctx context.Context, input model.CreateEmojiInput) (*model.CustomEmoji, error)
UpdateEmoji(ctx context.Context, shortcode string, input model.UpdateEmojiInput) (*model.CustomEmoji, error)
DeleteEmoji(ctx context.Context, shortcode string) (bool, error)
UpdateTrust(ctx context.Context, input model.TrustInput) (*trust.TrustEdge, error)
FlagObject(ctx context.Context, input model.FlagInput) (*model.FlagPayload, error)
SubmitModerationReview(ctx context.Context, input model.ModerationReviewInput) (*model.ModerationReviewResult, error)
CreateReport(ctx context.Context, input model.CreateReportInput) (*model.Report, error)
ExportReputation(ctx context.Context) (*model.PortableReputation, error)
ImportReputation(ctx context.Context, document string) (*model.ReputationImportResult, error)
VerifyReputation(ctx context.Context, document string) (*model.ReputationVerificationResult, error)
CreateVouch(ctx context.Context, input model.CreateVouchInput) (*model.Vouch, error)
RevokeVouch(ctx context.Context, id string) (bool, error)
AddCommunityNote(ctx context.Context, input model.CommunityNoteInput) (*model.CommunityNotePayload, error)
VoteCommunityNote(ctx context.Context, id string, helpful bool) (*model.CommunityNote, error)
RequestAIAnalysis(ctx context.Context, objectID string, objectType *string, force *bool) (*model.AIAnalysisRequest, error)
CreateQuoteNote(ctx context.Context, input model.CreateQuoteNoteInput) (*model.CreateNotePayload, error)
WithdrawFromQuotes(ctx context.Context, noteID string) (*model.WithdrawQuotePayload, error)
UpdateQuotePermissions(ctx context.Context, noteID string, quoteable bool, permission model.QuotePermission) (*model.UpdateQuotePermissionsPayload, error)
FollowHashtag(ctx context.Context, hashtag string, notifyLevel *model.NotificationLevel) (*model.HashtagFollowPayload, error)
UnfollowHashtag(ctx context.Context, hashtag string) (*model.UnfollowHashtagPayload, error)
UpdateHashtagNotifications(ctx context.Context, hashtag string, settings model.HashtagNotificationSettingsInput) (*model.UpdateHashtagNotificationsPayload, error)
MuteHashtag(ctx context.Context, hashtag string, until *model.Time) (*model.MuteHashtagPayload, error)
SyncThread(ctx context.Context, noteURL string, depth *int) (*model.SyncThreadPayload, error)
SyncMissingReplies(ctx context.Context, noteID string) (*model.SyncRepliesPayload, error)
AcknowledgeSeverance(ctx context.Context, id string) (*model.AcknowledgePayload, error)
AttemptReconnection(ctx context.Context, id string) (*model.ReconnectionPayload, error)
CreateDraft(ctx context.Context, input model.CreateDraftInput) (*model.Draft, error)
UpdateDraft(ctx context.Context, id string, input model.UpdateDraftInput) (*model.Draft, error)
AutosaveDraft(ctx context.Context, id string, content string) (*model.Draft, error)
DeleteDraft(ctx context.Context, id string) (bool, error)
PublishDraft(ctx context.Context, id string) (*model.Article, error)
ScheduleDraft(ctx context.Context, id string, scheduledAt model.Time) (*model.Draft, error)
CancelScheduledDraft(ctx context.Context, id string) (*model.Draft, error)
CreateArticle(ctx context.Context, input model.CreateArticleInput) (*model.Article, error)
UpdateArticle(ctx context.Context, id string, input model.UpdateArticleInput) (*model.Article, error)
DeleteArticle(ctx context.Context, id string) (bool, error)
RestoreRevision(ctx context.Context, objectID string, version int) (*model.Article, error)
CreateSeries(ctx context.Context, input model.CreateSeriesInput) (*model.Series, error)
UpdateSeries(ctx context.Context, id string, input model.UpdateSeriesInput) (*model.Series, error)
DeleteSeries(ctx context.Context, id string) (bool, error)
AddArticleToSeries(ctx context.Context, seriesID string, articleID string, order *int) (*model.Series, error)
RemoveArticleFromSeries(ctx context.Context, seriesID string, articleID string) (*model.Series, error)
ReorderSeriesArticles(ctx context.Context, seriesID string, articleIds []string) (*model.Series, error)
CreateCategory(ctx context.Context, input model.CreateCategoryInput) (*model.Category, error)
UpdateCategory(ctx context.Context, id string, input model.UpdateCategoryInput) (*model.Category, error)
DeleteCategory(ctx context.Context, id string) (bool, error)
AddArticleToCategory(ctx context.Context, categoryID string, articleID string) (*model.Article, error)
RemoveArticleFromCategory(ctx context.Context, categoryID string, articleID string) (*model.Article, error)
CreatePublication(ctx context.Context, input model.CreatePublicationInput) (*model.Publication, error)
UpdatePublication(ctx context.Context, id string, input model.UpdatePublicationInput) (*model.Publication, error)
InvitePublicationMember(ctx context.Context, publicationID string, userID string, role model.PublicationRole) (*model.PublicationMember, error)
RemovePublicationMember(ctx context.Context, publicationID string, userID string) (bool, error)
UpdatePublicationMemberRole(ctx context.Context, publicationID string, userID string, role model.PublicationRole) (*model.PublicationMember, error)
RequestStreamingURL(ctx context.Context, mediaID string, quality *model.StreamQuality) (*model.MediaStream, error)
PreloadMedia(ctx context.Context, mediaIds []string) ([]*model.MediaStream, error)
CreateModerationPattern(ctx context.Context, input model.ModerationPatternInput) (*moderation.ModerationPattern, error)
UpdateModerationPattern(ctx context.Context, id string, input model.ModerationPatternInput) (*moderation.ModerationPattern, error)
DeleteModerationPattern(ctx context.Context, id string) (bool, error)
TrainModerationModel(ctx context.Context, samples []*model.ModerationSampleInput, options *model.BedrockTrainingOptions) (*model.TrainingResult, error)
SetFederationLimit(ctx context.Context, domain string, limit model.FederationLimitInput) (*model.FederationLimit, error)
PauseFederation(ctx context.Context, domain string, reason string, until *model.Time) (*model.FederationManagementStatus, error)
ResumeFederation(ctx context.Context, domain string) (*model.FederationManagementStatus, error)
SetInstanceBudget(ctx context.Context, domain string, monthlyUsd float64, autoLimit *bool) (*model.InstanceBudget, error)
OptimizeFederationCosts(ctx context.Context, threshold float64) (*model.CostOptimizationResult, error)
ReportStreamingQuality(ctx context.Context, input model.StreamingQualityInput) (*model.StreamingQualityReport, error)
AdminCreateUser(ctx context.Context, input model.AdminCreateUserInput) (*model.AdminAccount, error)
AdminAccountAction(ctx context.Context, input model.AdminAccountActionInput) (bool, error)
AdminCreateAnnouncement(ctx context.Context, input model.AdminCreateAnnouncementInput) (*model.Announcement, error)
AdminCreateDomainAllow(ctx context.Context, domain string) (*model.AdminDomainAllow, error)
AdminDeleteDomainAllow(ctx context.Context, id string) (bool, error)
AdminCreateDomainBlock(ctx context.Context, input model.AdminDomainBlockCreateInput) (*model.AdminDomainBlock, error)
AdminUpdateDomainBlock(ctx context.Context, id string, input model.AdminDomainBlockUpdateInput) (*model.AdminDomainBlock, error)
AdminDeleteDomainBlock(ctx context.Context, id string) (bool, error)
AdminCreateEmailDomainBlock(ctx context.Context, domain string) (*model.AdminEmailDomainBlock, error)
AdminDeleteEmailDomainBlock(ctx context.Context, id string) (bool, error)
AdminOverrideModerationEvent(ctx context.Context, input model.AdminModerationEventOverrideInput) (*model.AdminModerationEventOverrideResult, error)
AdminUpdateTrust(ctx context.Context, input model.AdminUpdateTrustInput) (*model.AdminUpdateTrustResult, error)
AdminPromoteReviewer(ctx context.Context, id string) (*model.AdminReviewerRoleResult, error)
AdminDemoteReviewer(ctx context.Context, id string) (*model.AdminReviewerRoleResult, error)
AdminReportAction(ctx context.Context, id string, action model.AdminReportAction) (*model.AdminReport, error)
AdminDeleteStatus(ctx context.Context, id string) (bool, error)
AdminSetStatusSensitive(ctx context.Context, id string, sensitive bool) (*model.Object, error)
RegisterAgent(ctx context.Context, input model.RegisterAgentInput) (*model.RegisterAgentPayload, error)
UpdateAgent(ctx context.Context, username string, input model.UpdateAgentInput) (*model.Agent, error)
DelegateToAgent(ctx context.Context, input model.DelegateToAgentInput) (*model.DelegationPayload, error)
RevokeAgentToken(ctx context.Context, username string) (bool, error)
}
type ObjectResolver ¶ added in v1.1.1
type PaginationOptions ¶
type PaginationOptions struct {
First *int `json:"first,omitempty"`
After *model.Cursor `json:"after,omitempty"`
Last *int `json:"last,omitempty"`
Before *model.Cursor `json:"before,omitempty"`
}
PaginationOptions represents GraphQL pagination parameters
func ParsePaginationArgs ¶
func ParsePaginationArgs(first *int, after *model.Cursor, last *int, before *model.Cursor) (*PaginationOptions, error)
ParsePaginationArgs parses and validates GraphQL pagination arguments
type QueryResolver ¶
type QueryResolver interface {
Viewer(ctx context.Context) (*activitypub.Actor, error)
Actor(ctx context.Context, id *string, username *string) (*activitypub.Actor, error)
Object(ctx context.Context, id string) (*model.Object, error)
Timeline(ctx context.Context, typeArg model.TimelineType, hashtag *string, listID *string, actorID *string, first *int, after *model.Cursor, mediaOnly *bool) (*model.ObjectConnection, error)
Search(ctx context.Context, query string, typeArg *string, first *int, after *model.Cursor) (*model.SearchResult, error)
Notifications(ctx context.Context, types []string, excludeTypes []string, first *int, after *model.Cursor) (*model.NotificationConnection, error)
Notification(ctx context.Context, id string) (*model.Notification, error)
StatusHistory(ctx context.Context, id string, limit *int) ([]*model.StatusEdit, error)
StatusFavouritedBy(ctx context.Context, id string, first *int, after *model.Cursor) (*model.ActorListPage, error)
StatusRebloggedBy(ctx context.Context, id string, first *int, after *model.Cursor) (*model.ActorListPage, error)
LinkTimeline(ctx context.Context, url string, first *int, after *model.Cursor) (*model.ObjectConnection, error)
TranslateStatus(ctx context.Context, id string, targetLanguage *string) (*model.TranslationResult, error)
Instance(ctx context.Context) (*model.InstanceInfo, error)
InstanceActivity(ctx context.Context, limit *int) ([]*model.InstanceActivityEntry, error)
InstancePeers(ctx context.Context, limit *int) ([]string, error)
InstanceDomainBlocks(ctx context.Context, limit *int) ([]*model.InstanceDomainBlock, error)
TranslationLanguages(ctx context.Context) ([]*model.TranslationLanguage, error)
Announcements(ctx context.Context) ([]*model.Announcement, error)
AccountQuotePermissions(ctx context.Context, username string) (*model.AccountQuotePermissions, error)
Blocks(ctx context.Context, first *int, after *model.Cursor) (*model.ActorListPage, error)
Mutes(ctx context.Context, first *int, after *model.Cursor) (*model.ActorListPage, error)
Endorsements(ctx context.Context) ([]*activitypub.Actor, error)
FollowRequests(ctx context.Context, first *int, after *model.Cursor) (*model.ActorListPage, error)
DomainBlocks(ctx context.Context, first *int, after *model.Cursor) (*model.DomainBlockPage, error)
Markers(ctx context.Context, timelines []model.MarkerTimeline) (*model.MarkerSet, error)
Favourites(ctx context.Context, first *int, after *model.Cursor) (*model.ObjectConnection, error)
Bookmarks(ctx context.Context, first *int, after *model.Cursor) (*model.ObjectConnection, error)
CommunityNotesByAuthor(ctx context.Context, username string, first *int, after *model.Cursor) (*model.CommunityNoteConnection, error)
Conversations(ctx context.Context, first *int, after *model.Cursor) ([]*model.Conversation, error)
Conversation(ctx context.Context, id string) (*model.Conversation, error)
Lists(ctx context.Context) ([]*model.List, error)
List(ctx context.Context, id string) (*model.List, error)
ListAccounts(ctx context.Context, id string) ([]*activitypub.Actor, error)
Media(ctx context.Context, id string) (*model.Media, error)
MediaLibrary(ctx context.Context, filter *model.MediaFilterInput, first *int, after *model.Cursor) (*model.MediaConnection, error)
CustomEmojis(ctx context.Context) ([]*model.CustomEmoji, error)
ScheduledStatuses(ctx context.Context, first *int, after *model.Cursor) ([]*model.ScheduledStatus, error)
ScheduledStatus(ctx context.Context, id string) (*model.ScheduledStatus, error)
Relationship(ctx context.Context, id string) (*model.Relationship, error)
Relationships(ctx context.Context, ids []string) ([]*model.Relationship, error)
Followers(ctx context.Context, username string, limit *int, cursor *model.Cursor) (*model.ActorListPage, error)
Following(ctx context.Context, username string, limit *int, cursor *model.Cursor) (*model.ActorListPage, error)
UserPreferences(ctx context.Context) (*model.UserPreferences, error)
PushSubscription(ctx context.Context) (*model.PushSubscription, error)
ProfileDirectory(ctx context.Context, filters *model.DirectoryFiltersInput, first *int, after *model.Cursor) (*model.ProfileDirectory, error)
Suggestions(ctx context.Context, limit *int) ([]*model.AccountSuggestion, error)
RemoveSuggestion(ctx context.Context, accountID string) (bool, error)
Exports(ctx context.Context, first *int, after *model.Cursor) (*model.ExportJobConnection, error)
Export(ctx context.Context, id string) (*model.ExportJob, error)
Imports(ctx context.Context, first *int, after *model.Cursor) (*model.ImportJobConnection, error)
Import(ctx context.Context, id string) (*model.ImportJob, error)
Filters(ctx context.Context) ([]*mastodon.Filter, error)
Filter(ctx context.Context, id string) (*mastodon.Filter, error)
Trends(ctx context.Context, limit *int) ([]*model.TrendingItem, error)
TrendingTags(ctx context.Context, limit *int) ([]*model.TrendingTag, error)
TrendingStatuses(ctx context.Context, limit *int) ([]*model.TrendingStatus, error)
TrendingLinks(ctx context.Context, limit *int) ([]*model.TrendingLink, error)
GroupedNotifications(ctx context.Context, input *model.GroupedNotificationsInput) ([]*model.GroupedNotificationGroup, error)
InstanceMetrics(ctx context.Context) (*model.InstanceMetrics, error)
CostBreakdown(ctx context.Context, period *model.Period) (*model.CostBreakdown, error)
TrustGraph(ctx context.Context, actorID string, category *models.TrustCategory) ([]*trust.TrustEdge, error)
ModerationQueue(ctx context.Context, first *int, after *model.Cursor) ([]*moderation.ModerationDecision, error)
ModerationConsensus(ctx context.Context, eventID string) (*model.ModerationConsensusResult, error)
ModerationHistory(ctx context.Context, objectID string) (*model.ModerationHistoryResult, error)
ModerationTrustScore(ctx context.Context, actorID string) (*model.ModerationTrustScore, error)
Reputation(ctx context.Context, actorID string) (*model.Reputation, error)
Vouches(ctx context.Context, actorID string) ([]*model.Vouch, error)
ExplainObject(ctx context.Context, id string) (*model.ObjectExplanation, error)
FederationStatus(ctx context.Context, domain string) (*model.FederationStatus, error)
AiAnalysis(ctx context.Context, objectID string) (*model.AIAnalysis, error)
AiStats(ctx context.Context, period model.Period) (*model.AIStats, error)
AiCapabilities(ctx context.Context) (*model.AICapabilities, error)
Hashtag(ctx context.Context, name string) (*model.Hashtag, error)
HashtagTimeline(ctx context.Context, hashtag string, first *int, after *string, mediaOnly *bool) (*model.PostConnection, error)
MultiHashtagTimeline(ctx context.Context, hashtags []string, mode model.HashtagMode, first *int, after *string) (*model.PostConnection, error)
ThreadContext(ctx context.Context, noteID string) (*model.ThreadContext, error)
SeveredRelationships(ctx context.Context, instance *string, first *int, after *string) (*model.SeveredRelationshipConnection, error)
AffectedRelationships(ctx context.Context, severedRelationshipID string) (*model.AffectedRelationshipConnection, error)
Draft(ctx context.Context, id string) (*model.Draft, error)
MyDrafts(ctx context.Context, contentType *model.ObjectType, status *model.DraftStatus, first *int, after *model.Cursor) (*model.DraftConnection, error)
Revisions(ctx context.Context, objectID string, first *int, after *model.Cursor) (*model.RevisionConnection, error)
Revision(ctx context.Context, objectID string, version int) (*model.Revision, error)
Article(ctx context.Context, id string) (*model.Article, error)
ArticleBySlug(ctx context.Context, slug string) (*model.Article, error)
Articles(ctx context.Context, authorID *string, seriesID *string, categoryID *string, first *int, after *model.Cursor) (*model.ArticleConnection, error)
Series(ctx context.Context, id string) (*model.Series, error)
SeriesBySlug(ctx context.Context, slug string) (*model.Series, error)
AllSeries(ctx context.Context, authorID *string, first *int, after *model.Cursor) (*model.SeriesConnection, error)
Category(ctx context.Context, id string) (*model.Category, error)
CategoryBySlug(ctx context.Context, slug string) (*model.Category, error)
Categories(ctx context.Context, parentID *string) ([]*model.Category, error)
RootCategories(ctx context.Context) ([]*model.Category, error)
Publication(ctx context.Context, id string) (*model.Publication, error)
PublicationBySlug(ctx context.Context, slug string) (*model.Publication, error)
MyPublications(ctx context.Context) ([]*model.Publication, error)
FederationCosts(ctx context.Context, first *int, after *string, orderBy *model.CostOrderBy) (*model.FederationCostConnection, error)
InstanceHealthReport(ctx context.Context, domain string) (*model.InstanceHealthReport, error)
CostProjections(ctx context.Context, period model.Period) (*model.CostProjection, error)
MediaStreamURL(ctx context.Context, mediaID string) (*model.MediaStream, error)
SupportedBitrates(ctx context.Context, mediaID string) ([]*model.Bitrate, error)
ModerationPatterns(ctx context.Context, active *bool, severity *model.ModerationSeverity, first *int, after *string) ([]*moderation.ModerationPattern, error)
ModerationEffectiveness(ctx context.Context, patternID string, period model.ModerationPeriod) (*model.ModerationEffectiveness, error)
FederationLimits(ctx context.Context, active *bool, first *int, after *string) ([]*model.FederationLimit, error)
InstanceBudgets(ctx context.Context, exceeded *bool) ([]*model.InstanceBudget, error)
FederationHealth(ctx context.Context, threshold *float64) ([]*model.FederationManagementStatus, error)
FederationMap(ctx context.Context, depth *int) (*model.FederationGraph, error)
InstanceRelationships(ctx context.Context, domain string) (*model.InstanceRelations, error)
FederationFlow(ctx context.Context, period model.TimePeriod) (*model.FederationFlow, error)
StreamingAnalytics(ctx context.Context, mediaID string) (*model.StreamingAnalytics, error)
PopularStreams(ctx context.Context, first int, after *string) (*model.StreamConnection, error)
BandwidthUsage(ctx context.Context, period model.TimePeriod) (*model.BandwidthReport, error)
ModerationDashboard(ctx context.Context, filter *moderation.ModerationFilter) (*model.ModerationDashboard, error)
PatternEffectiveness(ctx context.Context, patternID string) (*model.PatternStats, error)
ModeratorActivity(ctx context.Context, moderatorID string, period model.TimePeriod) (*model.ModeratorStats, error)
PerformanceMetrics(ctx context.Context, service model.ServiceCategory) (*model.PerformanceReport, error)
SlowQueries(ctx context.Context, threshold model.Duration) ([]*model.QueryPerformance, error)
InfrastructureHealth(ctx context.Context) (*model.InfrastructureStatus, error)
AdminAccounts(ctx context.Context, first *int, after *model.Cursor) (*model.AdminAccountConnection, error)
AdminAccount(ctx context.Context, id string) (*model.AdminAccount, error)
AdminDomainAllows(ctx context.Context, first *int, after *model.Cursor) (*model.AdminDomainAllowConnection, error)
AdminDomainBlocks(ctx context.Context, first *int, after *model.Cursor) (*model.AdminDomainBlockConnection, error)
AdminDomainBlock(ctx context.Context, id string) (*model.AdminDomainBlock, error)
AdminEmailDomainBlocks(ctx context.Context, first *int, after *model.Cursor) (*model.AdminEmailDomainBlockConnection, error)
AdminFederationInstances(ctx context.Context, first *int, after *model.Cursor) (*model.AdminFederationInstanceConnection, error)
AdminFederationInstance(ctx context.Context, domain string) (*model.AdminFederationInstance, error)
AdminFederationStatistics(ctx context.Context, start *model.Time, end *model.Time) (*model.AdminFederationStatistics, error)
AdminModerationEvents(ctx context.Context, filter *model.AdminModerationEventFilter, first *int, after *model.Cursor) (*model.AdminModerationEventConnection, error)
AdminModerationReviewers(ctx context.Context) ([]*model.AdminReviewer, error)
AdminTrustGraph(ctx context.Context, limit *int) (*model.AdminTrustGraph, error)
AdminReports(ctx context.Context, status *model.AdminReportStatus, first *int, after *model.Cursor) (*model.AdminReportConnection, error)
AdminReport(ctx context.Context, id string) (*model.AdminReport, error)
AdminStatuses(ctx context.Context, filter *model.AdminStatusFilter, first *int, after *model.Cursor) (*model.AdminStatusConnection, error)
AdminStatus(ctx context.Context, id string) (*model.Object, error)
Agent(ctx context.Context, username string) (*model.Agent, error)
Agents(ctx context.Context, first *int, after *model.Cursor, typeArg *model.AgentType) (*model.AgentConnection, error)
MyAgents(ctx context.Context) ([]*model.Agent, error)
AgentMemorySearch(ctx context.Context, query string, tags []string, dateRange *model.DateRangeInput, first *int, after *model.Cursor) (*model.ObjectConnection, error)
}
type QuoteContextResolver ¶
type QuoteContextResolver interface {
OriginalAuthor(ctx context.Context, obj *activitypub.QuoteContext) (*activitypub.Actor, error)
OriginalNote(ctx context.Context, obj *activitypub.QuoteContext) (*model.Object, error)
QuoteType(ctx context.Context, obj *activitypub.QuoteContext) (model.QuoteType, error)
}
type Resolver ¶
type Resolver struct {
// Service registry - primary source for all business operations
Registry *services.Registry
// Legacy fields (to be phased out)
Config *config.Config
Storage core.RepositoryStorage
CostTracker *cost.Tracker
UnifiedTracker *cost.UnifiedTracker // Centralized cost tracking
TableName string // DynamoDB table name
S3BucketName string // S3 bucket name
MastodonConv mastodon.Converter
Logger *zap.Logger
SubscriptionManager *SubscriptionManager // For GraphQL subscriptions
AIService *ai.AIService // AI analysis service
// contains filtered or unexported fields
}
Resolver is the root resolver for GraphQL operations It uses the service registry for all business logic operations
func (*Resolver) Activity ¶
func (r *Resolver) Activity() ActivityResolver
Activity returns the ActivityResolver implementation
func (*Resolver) Actor ¶
func (r *Resolver) Actor() ActorResolver
Actor returns the ActorResolver implementation
func (*Resolver) Attachment ¶
func (r *Resolver) Attachment() AttachmentResolver
Attachment returns the AttachmentResolver implementation
func (*Resolver) Driver ¶
func (r *Resolver) Driver() DriverResolver
Driver returns the DriverResolver
func (*Resolver) ImageAnalysis ¶
func (r *Resolver) ImageAnalysis() ImageAnalysisResolver
ImageAnalysis returns the ImageAnalysisResolver implementation
func (*Resolver) ModerationDecision ¶
func (r *Resolver) ModerationDecision() ModerationDecisionResolver
ModerationDecision returns the ModerationDecisionResolver implementation
func (*Resolver) ModerationFilter ¶
func (r *Resolver) ModerationFilter() ModerationFilterResolver
ModerationFilter returns the ModerationFilterResolver implementation
func (*Resolver) ModerationLabel ¶
func (r *Resolver) ModerationLabel() ModerationLabelResolver
ModerationLabel returns the ModerationLabelResolver implementation
func (*Resolver) ModerationPattern ¶
func (r *Resolver) ModerationPattern() ModerationPatternResolver
ModerationPattern returns the ModerationPatternResolver implementation
func (*Resolver) Mutation ¶
func (r *Resolver) Mutation() MutationResolver
Mutation returns the MutationResolver implementation
func (*Resolver) Object ¶ added in v1.1.1
func (r *Resolver) Object() ObjectResolver
Object returns the ObjectResolver implementation
func (*Resolver) Query ¶
func (r *Resolver) Query() QueryResolver
Query returns the QueryResolver implementation
func (*Resolver) QuoteContext ¶
func (r *Resolver) QuoteContext() QuoteContextResolver
QuoteContext returns the QuoteContextResolver implementation
func (*Resolver) Subscription ¶
func (r *Resolver) Subscription() SubscriptionResolver
Subscription returns the SubscriptionResolver implementation
func (*Resolver) Tag ¶
func (r *Resolver) Tag() TagResolver
Tag returns the TagResolver implementation
func (*Resolver) TextAnalysis ¶
func (r *Resolver) TextAnalysis() TextAnalysisResolver
TextAnalysis returns the TextAnalysisResolver implementation
func (*Resolver) TrustEdge ¶
func (r *Resolver) TrustEdge() TrustEdgeResolver
TrustEdge returns the TrustEdgeResolver implementation
type ResolverRoot ¶
type ResolverRoot interface {
Activity() ActivityResolver
Actor() ActorResolver
Attachment() AttachmentResolver
Driver() DriverResolver
ImageAnalysis() ImageAnalysisResolver
ModerationDecision() ModerationDecisionResolver
ModerationLabel() ModerationLabelResolver
ModerationPattern() ModerationPatternResolver
Mutation() MutationResolver
Object() ObjectResolver
Query() QueryResolver
QuoteContext() QuoteContextResolver
Subscription() SubscriptionResolver
Tag() TagResolver
TextAnalysis() TextAnalysisResolver
TrustEdge() TrustEdgeResolver
ModerationFilter() ModerationFilterResolver
}
type SubscriptionManager ¶
type SubscriptionManager struct {
// contains filtered or unexported fields
}
SubscriptionManager provides the GraphQL subscription API This is a wrapper around GraphQLSubscriptionManager to maintain compatibility
func NewSubscriptionManager ¶
func NewSubscriptionManager( connRepo interfaces.StreamingConnectionRepository, publisher streaming.Publisher, logger *zap.Logger, ) *SubscriptionManager
NewSubscriptionManager creates a new subscription manager with DynamoDB-backed persistence
func (*SubscriptionManager) GetStats ¶
func (sm *SubscriptionManager) GetStats() map[string]interface{}
GetStats returns statistics about active subscriptions
func (*SubscriptionManager) IsRunning ¶
func (sm *SubscriptionManager) IsRunning() bool
IsRunning returns whether the subscription manager is running
func (*SubscriptionManager) Start ¶
func (sm *SubscriptionManager) Start(ctx context.Context) error
Start starts the subscription manager
func (*SubscriptionManager) Stop ¶
func (sm *SubscriptionManager) Stop() error
Stop stops the subscription manager
func (*SubscriptionManager) SubscribeToAIAnalysisUpdates ¶
func (sm *SubscriptionManager) SubscribeToAIAnalysisUpdates(ctx context.Context, objectID *string) (<-chan *model.AIAnalysis, error)
SubscribeToAIAnalysisUpdates creates a channel for AI analysis updates using event bus
func (*SubscriptionManager) SubscribeToActivityStream ¶
func (sm *SubscriptionManager) SubscribeToActivityStream(ctx context.Context, username string, activityTypes []model.ActivityType) (<-chan *activitypub.Activity, error)
SubscribeToActivityStream creates a channel for activity stream updates NOTE: This method creates ActivityPub activities, not GraphQL Objects
func (*SubscriptionManager) SubscribeToBudgetAlerts ¶
func (sm *SubscriptionManager) SubscribeToBudgetAlerts(ctx context.Context, username string, domain *string) (<-chan *model.BudgetAlert, error)
SubscribeToBudgetAlerts creates a channel for budget alert updates using event bus
func (*SubscriptionManager) SubscribeToConversation ¶
func (sm *SubscriptionManager) SubscribeToConversation(ctx context.Context, username string) (<-chan *model.Conversation, error)
SubscribeToConversation creates a channel for conversation updates using event bus
func (*SubscriptionManager) SubscribeToCostAlerts ¶
func (sm *SubscriptionManager) SubscribeToCostAlerts(ctx context.Context, username string, thresholdUSD float64) (<-chan *model.CostAlert, error)
SubscribeToCostAlerts creates a channel for cost alert updates using event bus
func (*SubscriptionManager) SubscribeToCostUpdates ¶
func (sm *SubscriptionManager) SubscribeToCostUpdates(ctx context.Context, username string, threshold *int) (<-chan *model.CostUpdate, error)
SubscribeToCostUpdates creates a channel for cost updates using event bus
func (*SubscriptionManager) SubscribeToFederationHealth ¶
func (sm *SubscriptionManager) SubscribeToFederationHealth(ctx context.Context, username string, domain *string) (<-chan *model.FederationHealthUpdate, error)
SubscribeToFederationHealth creates a channel for federation health updates using event bus
func (*SubscriptionManager) SubscribeToHashtagActivity ¶
func (sm *SubscriptionManager) SubscribeToHashtagActivity(ctx context.Context, username string, hashtags []string) (<-chan *model.HashtagActivityUpdate, error)
SubscribeToHashtagActivity creates a channel for hashtag activity updates using event bus
func (*SubscriptionManager) SubscribeToInfrastructureEvents ¶
func (sm *SubscriptionManager) SubscribeToInfrastructureEvents(ctx context.Context, username string) (<-chan *model.InfrastructureEvent, error)
SubscribeToInfrastructureEvents creates a channel for infrastructure event updates using event bus
func (*SubscriptionManager) SubscribeToListActivity ¶
func (sm *SubscriptionManager) SubscribeToListActivity(ctx context.Context, username string, listID string) (<-chan *model.ListUpdate, error)
SubscribeToListActivity creates a channel for list activity updates using event bus
func (*SubscriptionManager) SubscribeToMetricsUpdates ¶
func (sm *SubscriptionManager) SubscribeToMetricsUpdates(ctx context.Context, username string, categories []string, services []string, threshold *float64) (<-chan *model.MetricsUpdate, error)
SubscribeToMetricsUpdates creates a channel for real-time metrics updates using event bus
func (*SubscriptionManager) SubscribeToModerationAlerts ¶
func (sm *SubscriptionManager) SubscribeToModerationAlerts(ctx context.Context, username string, severity *model.ModerationSeverity) (<-chan *model.ModerationAlert, error)
SubscribeToModerationAlerts creates a channel for moderation alert updates using event bus
func (*SubscriptionManager) SubscribeToModerationEvents ¶
func (sm *SubscriptionManager) SubscribeToModerationEvents(ctx context.Context, actorID *string) (<-chan *moderation.ModerationDecision, error)
SubscribeToModerationEvents creates a channel for moderation events using event bus
func (*SubscriptionManager) SubscribeToModerationQueueUpdate ¶
func (sm *SubscriptionManager) SubscribeToModerationQueueUpdate(ctx context.Context, username string, priority *model.Priority) (<-chan *model.ModerationItem, error)
SubscribeToModerationQueueUpdate creates a channel for moderation queue updates using event bus
func (*SubscriptionManager) SubscribeToNotifications ¶
func (sm *SubscriptionManager) SubscribeToNotifications(ctx context.Context, username string) (<-chan *model.Notification, error)
SubscribeToNotifications creates a channel for notification updates using event bus
func (*SubscriptionManager) SubscribeToPerformanceAlerts ¶
func (sm *SubscriptionManager) SubscribeToPerformanceAlerts(ctx context.Context, username string, severity model.AlertSeverity) (<-chan *model.PerformanceAlert, error)
SubscribeToPerformanceAlerts creates a channel for performance alert updates using event bus
func (*SubscriptionManager) SubscribeToQuoteActivity ¶
func (sm *SubscriptionManager) SubscribeToQuoteActivity(ctx context.Context, username string, noteID string) (<-chan *model.QuoteActivityUpdate, error)
SubscribeToQuoteActivity creates a channel for quote activity updates using event bus
func (*SubscriptionManager) SubscribeToRelationshipUpdates ¶
func (sm *SubscriptionManager) SubscribeToRelationshipUpdates(ctx context.Context, username string, actorID *string) (<-chan *model.RelationshipUpdate, error)
SubscribeToRelationshipUpdates creates a channel for relationship updates using event bus
func (*SubscriptionManager) SubscribeToThreatIntelligence ¶
func (sm *SubscriptionManager) SubscribeToThreatIntelligence(ctx context.Context, username string) (<-chan *model.ThreatAlert, error)
SubscribeToThreatIntelligence creates a channel for threat intelligence updates using event bus
func (*SubscriptionManager) SubscribeToTimelineUpdates ¶
func (sm *SubscriptionManager) SubscribeToTimelineUpdates(ctx context.Context, username string, timelineType model.TimelineType) (<-chan *model.Object, error)
SubscribeToTimelineUpdates creates a channel for timeline updates using event bus
func (*SubscriptionManager) SubscribeToTrustUpdates ¶
func (sm *SubscriptionManager) SubscribeToTrustUpdates(ctx context.Context, actorID string) (<-chan *trust.TrustEdge, error)
SubscribeToTrustUpdates creates a channel for trust score updates using event bus
type SubscriptionResolver ¶
type SubscriptionResolver interface {
ActivityStream(ctx context.Context, types []model.ActivityType) (<-chan *activitypub.Activity, error)
TimelineUpdates(ctx context.Context, typeArg model.TimelineType, listID *string) (<-chan *model.Object, error)
NotificationStream(ctx context.Context, types []string) (<-chan *model.Notification, error)
ConversationUpdates(ctx context.Context) (<-chan *model.Conversation, error)
ListUpdates(ctx context.Context, listID string) (<-chan *model.ListUpdate, error)
RelationshipUpdates(ctx context.Context, actorID *string) (<-chan *model.RelationshipUpdate, error)
CostUpdates(ctx context.Context, threshold *int) (<-chan *model.CostUpdate, error)
ModerationEvents(ctx context.Context, actorID *string) (<-chan *moderation.ModerationDecision, error)
TrustUpdates(ctx context.Context, actorID string) (<-chan *trust.TrustEdge, error)
AiAnalysisUpdates(ctx context.Context, objectID *string) (<-chan *model.AIAnalysis, error)
QuoteActivity(ctx context.Context, noteID string) (<-chan *model.QuoteActivityUpdate, error)
HashtagActivity(ctx context.Context, hashtags []string) (<-chan *model.HashtagActivityUpdate, error)
MetricsUpdates(ctx context.Context, categories []string, services []string, threshold *float64) (<-chan *model.MetricsUpdate, error)
ModerationAlerts(ctx context.Context, severity *model.ModerationSeverity) (<-chan *model.ModerationAlert, error)
CostAlerts(ctx context.Context, thresholdUsd float64) (<-chan *model.CostAlert, error)
BudgetAlerts(ctx context.Context, domain *string) (<-chan *model.BudgetAlert, error)
FederationHealthUpdates(ctx context.Context, domain *string) (<-chan *model.FederationHealthUpdate, error)
ModerationQueueUpdate(ctx context.Context, priority *model.Priority) (<-chan *model.ModerationItem, error)
ThreatIntelligence(ctx context.Context) (<-chan *model.ThreatAlert, error)
PerformanceAlert(ctx context.Context, severity model.AlertSeverity) (<-chan *model.PerformanceAlert, error)
InfrastructureEvent(ctx context.Context) (<-chan *model.InfrastructureEvent, error)
AgentActivity(ctx context.Context, username string) (<-chan *model.AgentActivityEvent, error)
}
type TagResolver ¶
type TextAnalysisResolver ¶
type TextAnalysisResolver interface {
Sentiment(ctx context.Context, obj *moderation.TextAnalysis) (model.Sentiment, error)
SentimentScores(ctx context.Context, obj *moderation.TextAnalysis) (*model.SentimentScores, error)
ToxicityScore(ctx context.Context, obj *moderation.TextAnalysis) (float64, error)
ToxicityLabels(ctx context.Context, obj *moderation.TextAnalysis) ([]string, error)
ContainsPii(ctx context.Context, obj *moderation.TextAnalysis) (bool, error)
DominantLanguage(ctx context.Context, obj *moderation.TextAnalysis) (string, error)
Entities(ctx context.Context, obj *moderation.TextAnalysis) ([]*model.Entity, error)
KeyPhrases(ctx context.Context, obj *moderation.TextAnalysis) ([]string, error)
}
Source Files
¶
- actor_resolution_helpers.go
- actor_tip_resolvers.go
- admin_parity_helpers.go
- agent_resolvers_stubs.go
- auth_helpers_roles.go
- cms_article_query_helpers.go
- cms_converters.go
- cms_feature_gates.go
- cms_helpers.go
- constants.go
- content_hash_helpers.go
- dataloader.go
- driver_resolver.go
- errors.go
- event_converter.go
- generated.go
- helpers.go
- import_export_helpers.go
- media_helpers.go
- mutation_resolvers_accounts.go
- mutation_resolvers_admin_parity.go
- mutation_resolvers_announcements_parity.go
- mutation_resolvers_cms.go
- mutation_resolvers_conversations.go
- mutation_resolvers_emoji.go
- mutation_resolvers_engagement.go
- mutation_resolvers_federation.go
- mutation_resolvers_filters_v2.go
- mutation_resolvers_grouped_notifications.go
- mutation_resolvers_hashtags.go
- mutation_resolvers_import_export.go
- mutation_resolvers_lists.go
- mutation_resolvers_media.go
- mutation_resolvers_moderation.go
- mutation_resolvers_moderation_parity.go
- mutation_resolvers_notes.go
- mutation_resolvers_notifications.go
- mutation_resolvers_preferences.go
- mutation_resolvers_profile.go
- mutation_resolvers_push.go
- mutation_resolvers_quotes.go
- mutation_resolvers_relationships.go
- mutation_resolvers_reports_parity.go
- mutation_resolvers_reputation_parity.go
- mutation_resolvers_statuses_parity.go
- mutation_resolvers_stubs.go
- mutation_resolvers_threads.go
- object_viewer_interactions_resolvers.go
- pagination_helpers.go
- preferences_helpers.go
- push_helpers.go
- query_resolvers_accounts.go
- query_resolvers_accounts_lists.go
- query_resolvers_admin.go
- query_resolvers_admin_parity.go
- query_resolvers_ai.go
- query_resolvers_announcements_parity.go
- query_resolvers_cms.go
- query_resolvers_conversations.go
- query_resolvers_cost.go
- query_resolvers_federation.go
- query_resolvers_filters_v2.go
- query_resolvers_grouped_notifications.go
- query_resolvers_hashtags.go
- query_resolvers_import_export.go
- query_resolvers_instance_parity.go
- query_resolvers_lists.go
- query_resolvers_media.go
- query_resolvers_moderation.go
- query_resolvers_moderation_parity.go
- query_resolvers_notes.go
- query_resolvers_notification_single.go
- query_resolvers_notifications.go
- query_resolvers_preferences.go
- query_resolvers_relationships.go
- query_resolvers_reputation_parity.go
- query_resolvers_statuses_parity.go
- query_resolvers_trends_v2.go
- reputation_service_helpers.go
- resolver.go
- schema.resolvers.go
- status_object_helpers.go
- subscription_manager.go
- subscription_resolvers_ai.go
- subscription_resolvers_conversations.go
- subscription_resolvers_cost.go
- subscription_resolvers_federation.go
- subscription_resolvers_hashtags.go
- subscription_resolvers_lists.go
- subscription_resolvers_moderation.go
- subscription_resolvers_notifications.go
- subscription_resolvers_quotes.go
- subscription_resolvers_relationships.go
- subscription_resolvers_timelines.go
- subscriptions.go
- vouch_conversion_helpers.go