server

package

Go to main page

Versions in this module

v0

v0.11.3

Sep 11, 2026

Changes in this version

type DbPersister

+ func (p *DbPersister) EventSeqRange(ctx context.Context) (oldest, newest int64, ok bool, err error)

v0.11.2

Sep 11, 2026

Changes in this version

+ type RepoGcOptions struct

+ BlockstoreVariant string

+ Dids []string

+ DryRun bool

+ Logger *slog.Logger

+ type RepoGcResult struct

+ Did string

+ Err error

+ Head string

+ LiveBlocks int64

+ RemovedBlocks int64

+ TotalBlocks int64

+ func RunRepoGcMigration(ctx context.Context, gdb *gorm.DB, opts RepoGcOptions) ([]RepoGcResult, error)

v0.11.1

Aug 24, 2026

Changes in this version

+ const BlobDeletionDeleted

+ const BlobDeletionFailed

+ const BlobDeletionPending

+ const BlobDeletionRetention

+ const BlobDeletionRetry

+ const DelegationExchangePolicy

+ const FailureAfterBlobMutation

+ const FailureAfterHeadUpdate

+ const FailureAfterOplogInsertion

+ const FailureAfterRecordMutation

+ const FailureAfterRepoCreation

+ const OAuthOnlyPolicy

+ const OAuthOrSpaceCredentialPolicy

+ const PrincipalDelegation

+ const PrincipalOAuth

+ const PrincipalServiceAuth

+ const PrincipalSpaceCredential

+ const PrincipalTypeDelegation

+ const PrincipalTypeOAuth

+ const PrincipalTypeServiceAuth

+ const PrincipalTypeSpaceCredential

+ const ServiceAuthOnlyPolicy

+ const SpaceCredentialOnlyPolicy

+ const SpaceNotifyDeliveryDelivered

+ const SpaceNotifyDeliveryExpired

+ const SpaceNotifyDeliveryFailed

+ const SpaceNotifyDeliveryPending

+ const SpaceNotifyDeliveryRetry

+ const SpaceNotifyDeliveryTTL

+ const SpaceNotifyRegistrationTTL

+ const SpaceNotifySpaceDeletedLXM

+ const SpaceNotifyWriteLXM

+ const SpaceRepoCreate

+ const SpaceRepoDelete

+ const SpaceRepoFailureAfterBlobMutation

+ const SpaceRepoFailureAfterHeadUpdate

+ const SpaceRepoFailureAfterOplogInsertion

+ const SpaceRepoFailureAfterRecordMutation

+ const SpaceRepoFailureAfterRepoCreation

+ const SpaceRepoOpCreate

+ const SpaceRepoOpDelete

+ const SpaceRepoOpPut

+ const SpaceRepoOpUpdate

+ const SpaceRepoPut

+ const SpaceRepoUpdate

+ var ErrSpaceNotifyRevisionConflict = errors.New("space notification revision has conflicting hash")

+ func NewDelegationExchangeMiddleware(s *Server, next echo.HandlerFunc) echo.HandlerFunc

+ func NewOAuthOnlyMiddleware(s *Server, next echo.HandlerFunc) echo.HandlerFunc

+ func NewOAuthOrSpaceCredentialMiddleware(s *Server, next echo.HandlerFunc) echo.HandlerFunc

+ func NewServiceAuthOnlyMiddleware(s *Server, next echo.HandlerFunc) echo.HandlerFunc

+ func NewSpaceCredentialOnlyMiddleware(s *Server, next echo.HandlerFunc) echo.HandlerFunc

+ func ParseSpaceNotificationHash(raw string) ([]byte, error)

+ func SetPrincipal(e echo.Context, principal Principal)

type Args

+ SpacesEnabled bool

+ type AuthPolicy string

+ const PolicyDelegationExchange

+ const PolicyOAuthOnly

+ const PolicyOAuthOrSpace

+ const PolicyServiceAuthOnly

+ const PolicySpaceCredentialOnly

+ type AuthPrincipal = Principal

+ type BlobDeletionS3Client interface

+ DeleteObject func(*s3.DeleteObjectInput) (*s3.DeleteObjectOutput, error)

+ type BlobDeletionWorker struct

+ func NewBlobDeletionWorker(s *Server) *BlobDeletionWorker

+ func NewBlobDeletionWorkerForDB(database *db.DB, client BlobDeletionS3Client, clock func() time.Time) *BlobDeletionWorker

+ func (w *BlobDeletionWorker) ProcessOnce(ctx context.Context, limit int) (int, error)

+ func (w *BlobDeletionWorker) PruneDeleted(ctx context.Context) (int64, error)

+ func (w *BlobDeletionWorker) RunOnce(ctx context.Context, limit int) (int, error)

+ func (w *BlobDeletionWorker) SetClock(clock func() time.Time)

+ func (w *BlobDeletionWorker) SetOptions(options BlobDeletionWorkerOptions)

+ func (w *BlobDeletionWorker) SetS3Client(client BlobDeletionS3Client)

+ type BlobDeletionWorkerOptions struct

+ BaseDelay time.Duration

+ BatchSize int

+ DeletedRetention time.Duration

+ MaxAttempts int

+ MaxDelay time.Duration

+ type ComAtprotoSimpleSpaceCreateSpaceInput struct

+ AppAccess json.RawMessage

+ Policy json.RawMessage

+ SKey *string

+ Type string

+ type ComAtprotoSimpleSpaceCreateSpaceOutput struct

+ URI string

+ type ComAtprotoSimpleSpaceDeleteSpaceInput struct

+ Space string

+ type ComAtprotoSimpleSpaceGetSpaceOutput struct

+ AppAccess json.RawMessage

+ Policy json.RawMessage

+ URI string

+ type ComAtprotoSimpleSpaceListMembersOutput struct

+ Cursor *string

+ Members []ComAtprotoSimpleSpaceMember

+ type ComAtprotoSimpleSpaceMember struct

+ DID string

+ type ComAtprotoSimpleSpaceMemberInput struct

+ DID string

+ Space string

+ type ComAtprotoSimpleSpaceUpdateSpaceInput struct

+ AppAccess json.RawMessage

+ Policy json.RawMessage

+ Space string

+ type ComAtprotoSpaceApplyWritesElement struct

+ Collection string

+ Rkey *string

+ Type string

+ Value MarshalableMap

+ type ComAtprotoSpaceApplyWritesInput struct

+ Repo string

+ Space string

+ Validate *bool

+ Writes []ComAtprotoSpaceApplyWritesElement

+ type ComAtprotoSpaceApplyWritesOutput struct

+ Results []ComAtprotoSpaceApplyWritesResult

+ type ComAtprotoSpaceApplyWritesResult struct

+ CID string

+ Type string

+ URI string

+ ValidationStatus *string

+ type ComAtprotoSpaceCreateRecordInput struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey *string

+ Space string

+ Validate *bool

+ type ComAtprotoSpaceDeleteRecordInput struct

+ Collection string

+ Repo string

+ Rkey string

+ Space string

+ type ComAtprotoSpaceGetDelegationTokenOutput struct

+ Token string

+ type ComAtprotoSpaceGetLatestCommitResponse struct

+ Commit space.SignedCommit

+ type ComAtprotoSpaceGetRecordResponse struct

+ CID string

+ URI string

+ Value any

+ type ComAtprotoSpaceGetSpaceCredentialInput struct

+ ClientAttestation string

+ Space string

+ type ComAtprotoSpaceGetSpaceCredentialOutput struct

+ Credential string

+ type ComAtprotoSpaceListBlobsResponse struct

+ CIDs []string

+ Cursor *string

+ type ComAtprotoSpaceListRecordsRecord struct

+ CID string

+ Collection string

+ Rkey string

+ Value any

+ type ComAtprotoSpaceListRecordsResponse struct

+ Cursor *string

+ Records []ComAtprotoSpaceListRecordsRecord

+ type ComAtprotoSpaceListRepoOpsResponse struct

+ Commit *space.SignedCommit

+ Cursor *string

+ Ops []ComAtprotoSpaceRepoOp

+ type ComAtprotoSpaceListReposRepoRef struct

+ DID string

+ Hash string

+ Rev string

+ func (r *ComAtprotoSpaceListReposRepoRef) UnmarshalJSON(data []byte) error

+ func (r ComAtprotoSpaceListReposRepoRef) MarshalJSON() ([]byte, error)

+ type ComAtprotoSpaceListReposResponse struct

+ Cursor *string

+ Repos []ComAtprotoSpaceListReposRepoRef

+ type ComAtprotoSpaceListSpacesOutput struct

+ Cursor *string

+ Spaces []ComAtprotoSpaceListSpacesSpaceView

+ type ComAtprotoSpaceListSpacesSpaceView struct

+ URI string

+ type ComAtprotoSpaceNotifySpaceDeletedInput struct

+ Space string

+ type ComAtprotoSpaceNotifyWriteInput struct

+ Hash string

+ Repo string

+ Rev string

+ Space string

+ type ComAtprotoSpacePutRecordInput struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey string

+ Space string

+ Validate *bool

+ type ComAtprotoSpaceRecordWriteOutput struct

+ CID string

+ URI string

+ ValidationStatus *string

+ type ComAtprotoSpaceRegisterNotifyInput struct

+ Service string

+ Space string

+ type ComAtprotoSpaceRegisterNotifyOutput struct

+ ExpiresAt time.Time

+ type ComAtprotoSpaceRepoOp struct

+ CID *string

+ Collection string

+ Prev *string

+ RKey string

+ Rev string

+ Value any

+ type ComAtprotoSpaceUnregisterNotifyInput struct

+ Service string

+ Space string

+ type DIDDocumentFetcher interface

+ BustDid func(context.Context, string) error

+ BustDoc func(context.Context, string) error

+ FetchDoc func(context.Context, string) (*cocoon_identity.DidDoc, error)

+ ResolveHandle func(context.Context, string) (string, error)

+ type DIDSpaceAuthorityKeyResolver struct

+ Source SpaceAuthorityKeySource

+ func NewDIDSpaceAuthorityKeyResolver(source SpaceAuthorityKeySource) *DIDSpaceAuthorityKeyResolver

+ func (r *DIDSpaceAuthorityKeyResolver) ResolveSigningKey(ctx context.Context, req space.KeyResolutionRequest) (space.Verifier, error)

+ type DelegationPrincipal struct

+ AuthorityDID string

+ Claims space.SpaceTokenClaims

+ DPoPIssuedAt time.Time

+ DPoPJKT string

+ DPoPJTI string

+ SpaceURI string

+ Token string

+ func (p *DelegationPrincipal) PrincipalType() PrincipalType

+ type OAuthPrincipal struct

+ ClientID string

+ DPoPJKT string

+ Legacy bool

+ Repo *models.RepoActor

+ Scopes []string

+ Subject string

+ Token string

+ func (p *OAuthPrincipal) GetClientID() string

+ func (p *OAuthPrincipal) GetScopes() []string

+ func (p *OAuthPrincipal) GetSubject() string

+ func (p *OAuthPrincipal) PrincipalType() PrincipalType

+ type PassportSpaceAuthorityKeyResolver struct

+ Passport DIDDocumentFetcher

+ func NewPassportSpaceAuthorityKeyResolver(passport DIDDocumentFetcher) *PassportSpaceAuthorityKeyResolver

+ func (r *PassportSpaceAuthorityKeyResolver) ResolveSigningKey(ctx context.Context, req space.KeyResolutionRequest) (space.Verifier, error)

+ type Principal interface

+ PrincipalType func() PrincipalType

+ func GetPrincipal(e echo.Context) Principal

+ func PrincipalFromContext(e echo.Context) Principal

+ type PrincipalType string

+ type RequestPrincipal = Principal

type Server

+ func (s *Server) AuthDispatcher(policy AuthPolicy, next echo.HandlerFunc) echo.HandlerFunc

+ func (s *Server) DelegationExchange(next echo.HandlerFunc) echo.HandlerFunc

+ func (s *Server) OAuthOnly(next echo.HandlerFunc) echo.HandlerFunc

+ func (s *Server) OAuthOrSpaceCredential(next echo.HandlerFunc) echo.HandlerFunc

+ func (s *Server) QueueSpaceDeletedNotifications(ctx context.Context, spaceRef, source string) error

+ func (s *Server) RecordSpaceNotifySpaceDeleted(ctx context.Context, uri, source string, queueForwarding bool) error

+ func (s *Server) RecordSpaceNotifyWrite(ctx context.Context, uri, author, rev string, hash []byte, source string) error

+ func (s *Server) ServiceAuthOnly(next echo.HandlerFunc) echo.HandlerFunc

+ func (s *Server) SetBlobDeletionS3Client(client BlobDeletionS3Client)

+ func (s *Server) SetManagingAppAuthorizer(a SimpleSpaceManagingAppAuthorizer)

+ func (s *Server) SetPassport(passport DIDDocumentFetcher)

+ func (s *Server) SetSimpleSpaceManagingAppAuthorizer(a SimpleSpaceManagingAppAuthorizer)

+ func (s *Server) SetSpaceAuthorityKeyResolver(resolver SpaceAuthorityKeyResolver)

+ func (s *Server) SetSpaceNotificationClock(now func() time.Time)

+ func (s *Server) SetSpaceNotificationResolver(r SpaceNotificationResolver)

+ func (s *Server) SetSpaceNotificationSender(sender SpaceNotificationSender)

+ func (s *Server) SetSpaceReplayStore(store space.ReplayStore)

+ func (s *Server) SetSpaceTypeResolver(resolver scopes.SpaceTypeResolver)

+ func (s *Server) SpaceCredentialOnly(next echo.HandlerFunc) echo.HandlerFunc

+ type ServiceAuthPrincipal struct

+ Audience string

+ Issuer string

+ LXM string

+ Repo *models.RepoActor

+ Token string

+ func (p *ServiceAuthPrincipal) GetAudience() string

+ func (p *ServiceAuthPrincipal) GetIssuer() string

+ func (p *ServiceAuthPrincipal) GetLXM() string

+ func (p *ServiceAuthPrincipal) PrincipalType() PrincipalType

+ type SimpleSpaceManagingAppAuthorizer interface

+ CheckUserAccess func(context.Context, string, string, string, string) (bool, error)

+ type SimpleSpaceManagingAppAuthorizerFunc func(context.Context, string, string, string, string) (bool, error)

+ func (f SimpleSpaceManagingAppAuthorizerFunc) CheckUserAccess(ctx context.Context, app, spaceURI, userDID, clientID string) (bool, error)

+ type SpaceAuthorityKeyResolver interface

+ ResolveSigningKey func(context.Context, space.KeyResolutionRequest) (space.Verifier, error)

+ type SpaceAuthorityKeyResolverFunc func(context.Context, space.KeyResolutionRequest) (space.Verifier, error)

+ func (f SpaceAuthorityKeyResolverFunc) ResolveSigningKey(ctx context.Context, req space.KeyResolutionRequest) (space.Verifier, error)

+ type SpaceAuthorityKeySource interface

+ ResolveSpaceKey func(context.Context, string, string, string) (space.Verifier, error)

+ type SpaceAuthorityKeySourceFunc func(context.Context, string, string, string) (space.Verifier, error)

+ func (f SpaceAuthorityKeySourceFunc) ResolveSpaceKey(ctx context.Context, issuer, kid, alg string) (space.Verifier, error)

+ type SpaceCredentialPrincipal struct

+ AuthorityDID string

+ Claims space.SpaceTokenClaims

+ DPoPJKT string

+ Repo *models.RepoActor

+ SpaceURI string

+ Token string

+ TokenClaims space.SpaceTokenClaims

+ func (p *SpaceCredentialPrincipal) GetAuthorityDID() string

+ func (p *SpaceCredentialPrincipal) GetDPoPJKT() string

+ func (p *SpaceCredentialPrincipal) GetSpaceURI() string

+ func (p *SpaceCredentialPrincipal) PrincipalType() PrincipalType

+ type SpaceNotificationRepoSnapshot struct

+ Hash []byte

+ Host string

+ Repo string

+ Rev string

+ type SpaceNotificationResolver interface

+ Resolve func(context.Context, string) (string, error)

+ type SpaceNotificationResolverFunc func(context.Context, string) (string, error)

+ func (f SpaceNotificationResolverFunc) Resolve(ctx context.Context, service string) (string, error)

+ type SpaceNotificationSender interface

+ Send func(context.Context, string, models.SpaceNotifyDelivery) error

+ type SpaceNotificationSenderFunc func(context.Context, string, models.SpaceNotifyDelivery) error

+ func (f SpaceNotificationSenderFunc) Send(ctx context.Context, target string, d models.SpaceNotifyDelivery) error

+ type SpaceNotificationTargetResolver = SpaceNotificationResolver

+ type SpaceNotificationTargetResolverFunc = SpaceNotificationResolverFunc

+ type SpaceNotificationWorker struct

+ func NewSpaceNotificationWorker(s *Server, sender SpaceNotificationSender, ...) *SpaceNotificationWorker

+ func NewSpaceNotificationWorkerForDB(database *db.DB, sender SpaceNotificationSender, clock func() time.Time, ...) *SpaceNotificationWorker

+ func NewSpaceNotificationWorkerWithOptions(s *Server, sender SpaceNotificationSender, ...) *SpaceNotificationWorker

+ func (w *SpaceNotificationWorker) ProcessOnce(ctx context.Context, limit int) (int, error)

+ func (w *SpaceNotificationWorker) ReconcileNotifyWriters(ctx context.Context, spaceRef string, ...) (int, error)

+ func (w *SpaceNotificationWorker) ReconcileSpaceWriters(ctx context.Context, spaceRef string, ...) (int, error)

+ func (w *SpaceNotificationWorker) RunOnce(ctx context.Context, limit int) (int, error)

+ func (w *SpaceNotificationWorker) SetClock(clock func() time.Time)

+ func (w *SpaceNotificationWorker) SetOptions(options SpaceNotificationWorkerOptions)

+ func (w *SpaceNotificationWorker) SetResolver(resolver SpaceNotificationResolver)

+ func (w *SpaceNotificationWorker) SetSender(sender SpaceNotificationSender)

+ type SpaceNotificationWorkerOptions struct

+ BaseDelay time.Duration

+ BatchSize int

+ DeliveryRetention time.Duration

+ MaxAttempts int

+ MaxDelay time.Duration

+ type SpaceRepoAction struct

+ Collection string

+ Rkey string

+ Type SpaceRepoOpType

+ type SpaceRepoActionAuthorizer func(SpaceRepoAction) error

+ type SpaceRepoAllowedActions map[SpaceRepoOpType]bool

+ func (a SpaceRepoAllowedActions) Authorize(action SpaceRepoAction) error

+ type SpaceRepoBatch struct

+ Author string

+ Changes []SpaceRepoChange

+ LtHash []byte

+ Rev string

+ Space string

+ type SpaceRepoChange struct

+ CID string

+ Collection string

+ PreviousCID string

+ Rkey string

+ Type SpaceRepoOpType

+ URI string

+ type SpaceRepoFailureHook func(SpaceRepoFailureStage) error

+ type SpaceRepoFailureStage string

+ type SpaceRepoInsufficientScopeError struct

+ Action SpaceRepoAction

+ func (e *SpaceRepoInsufficientScopeError) Error() string

+ type SpaceRepoMan struct

+ func NewSpaceRepoMan(s *Server) *SpaceRepoMan

+ func NewSpaceRepoManager(s *Server) *SpaceRepoMan

+ func (m *SpaceRepoMan) Apply(ctx context.Context, spaceRef, author string, operations []SpaceRepoOperation) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) ApplyWithAuthorization(ctx context.Context, spaceRef, author string, operations []SpaceRepoOperation, ...) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) ApplyWrites(ctx context.Context, spaceRef, author string, operations []SpaceRepoOperation) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) DeleteRecord(ctx context.Context, spaceRef, author, collection, rkey string) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) GetRecord(ctx context.Context, spaceRef, author, collection, rkey string) (*models.SpaceRecord, error)

+ func (m *SpaceRepoMan) GetRepo(ctx context.Context, spaceRef, author string) (models.SpaceRepo, error)

+ func (m *SpaceRepoMan) ListCurrentRecords(ctx context.Context, spaceRef, author, cursor string, limit int) ([]models.SpaceRecord, string, error)

+ func (m *SpaceRepoMan) ListOperations(ctx context.Context, spaceRef, author, cursor string, limit int) ([]models.SpaceRepoOp, string, error)

+ func (m *SpaceRepoMan) ListOps(ctx context.Context, spaceRef, author, cursor string, limit int) ([]models.SpaceRepoOp, string, error)

+ func (m *SpaceRepoMan) ListRecords(ctx context.Context, spaceRef, author, cursor string, limit int) ([]models.SpaceRecord, string, error)

+ func (m *SpaceRepoMan) PutRecord(ctx context.Context, spaceRef, author, collection, rkey string, record any) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) PutRecordWithAuthorization(ctx context.Context, spaceRef, author, collection, rkey string, record any, ...) (SpaceRepoBatch, error)

+ func (m *SpaceRepoMan) SetFailureHook(hook SpaceRepoFailureHook) func()

+ func (m *SpaceRepoMan) SetFailureStage(stage SpaceRepoFailureStage) func()

+ type SpaceRepoOpType string

+ type SpaceRepoOperation struct

+ Collection string

+ Record any

+ Rkey string

+ Type SpaceRepoOpType

+ type SpaceRepoWrite = SpaceRepoOperation

v0.11.0

Aug 24, 2026

Changes in this version

+ var ErrSessionUnauthenticated = errors.New("session is unauthenticated")

+ type AccountSwitchRequest struct

+ Did string

+ Next string

+ QueryParams string

+ type OauthRevokeRequest struct

+ Token string

+ TokenTypeHint *string

+ type RecommitOptions struct

+ BlockstoreVariant string

+ Dids []string

+ DryRun bool

+ Logger *slog.Logger

+ type RecommitResult struct

+ Did string

+ Err error

+ NewHead string

+ NewRev string

+ OldHead string

+ OldRev string

+ Recommitted bool

+ func RunRecommitMigration(ctx context.Context, gdb *gorm.DB, opts RecommitOptions) ([]RecommitResult, error)

v0.9.0

Mar 8, 2026

v0.8.5

Feb 16, 2026

v0.8.4

Feb 4, 2026

Changes in this version

+ type DbPersister struct

+ Broadcast func(*events.XRPCStreamEvent)

+ Db *gorm.DB

+ Lk sync.Mutex

+ Retention time.Duration

+ Seq int64

+ func NewDbPersister(db *gorm.DB, retention time.Duration) (*DbPersister, error)

+ func (p *DbPersister) Flush(ctx context.Context) error

+ func (p *DbPersister) Persist(ctx context.Context, e *events.XRPCStreamEvent) error

+ func (p *DbPersister) Playback(ctx context.Context, since int64, cb func(*events.XRPCStreamEvent) error) error

+ func (p *DbPersister) SetEventBroadcaster(brc func(*events.XRPCStreamEvent))

+ func (p *DbPersister) Shutdown(ctx context.Context) error

+ func (p *DbPersister) TakeDownRepo(ctx context.Context, uid indigomodels.Uid) error

v0.8.3

Jan 28, 2026

Changes in this version

type Args

+ LogLevel slog.Level

+ SessionCookieKey string

v0.8.2

Jan 19, 2026

v0.8.1

Jan 7, 2026

Changes in this version

+ type HandleOauthAuthorizeGetInput struct

+ RequestUri string

v0.8.0

Jan 4, 2026

Changes in this version

type OauthSigninInput

+ AuthFactorToken string

v0.7.2

Jan 2, 2026

Changes in this version

+ type AccountRevokeInput struct

+ Token string

+ type ComAtprotoRepoApplyWritesInput struct

+ Repo string

+ SwapCommit *string

+ Validate *bool

+ Writes []ComAtprotoRepoApplyWritesItem

+ type ComAtprotoRepoApplyWritesOutput struct

+ Commit RepoCommit

+ Results []ApplyWriteResult

+ type ComAtprotoRepoCreateRecordInput struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey *string

+ SwapCommit *string

+ SwapRecord *string

+ Validate *bool

+ type ComAtprotoRepoDeleteRecordInput struct

+ Collection string

+ Repo string

+ Rkey string

+ SwapCommit *string

+ SwapRecord *string

+ type ComAtprotoRepoPutRecordInput struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey string

+ SwapCommit *string

+ SwapRecord *string

+ Validate *bool

+ type OauthSigninInput struct

+ Password string

+ QueryParams string

+ Username string

v0.7.1

Dec 14, 2025

Changes in this version

type Args

+ RequireInvite bool

+ type ComAtprotoLabelQueryLabelsResponse struct

+ Cursor *string

+ Labels []Label

+ type Label struct

+ Cid *string

+ Cts string

+ Exp *string

+ Neg *bool

+ Sig []byte

+ Src string

+ Uri string

+ Val string

+ Ver *int

v0.7.0

Dec 9, 2025

Changes in this version

+ type ComAtprotoServerDeleteAccountRequest struct

+ Did string

+ Password string

+ Token string

type S3Config

+ CDNUrl string

+ type ServerReserveSigningKeyRequest struct

+ Did *string

+ type ServerReserveSigningKeyResponse struct

+ SigningKey string

v0.6.0

Dec 6, 2025

Changes in this version

type Args

+ DatabaseURL string

+ DbType string

+ type ComAtprotoRepoListMissingBlobsRecordBlob struct

+ Cid string

+ RecordUri string

+ type ComAtprotoRepoListMissingBlobsResponse struct

+ Blobs []ComAtprotoRepoListMissingBlobsRecordBlob

+ Cursor *string

v0.5.1

Nov 3, 2025

Changes in this version

+ const AccountSessionMaxAge

+ const BlockstoreVariantSqlite

+ var CocoonSupportedScopes = []string

+ var OpTypeCreate = OpType("com.atproto.repo.applyWrites#create")

+ var OpTypeDelete = OpType("com.atproto.repo.applyWrites#delete")

+ var OpTypeUpdate = OpType("com.atproto.repo.applyWrites#update")

+ type AccountRevokeRequest struct

+ Token string

+ type ApplyWriteResult struct

+ Cid *string

+ Commit *RepoCommit

+ Type *string

+ Uri *string

+ ValidationStatus *string

+ type Args struct

+ Addr string

+ AdminPassword string

+ BlockstoreVariant BlockstoreVariant

+ ContactEmail string

+ DbName string

+ Did string

+ FallbackProxy string

+ Hostname string

+ JwkPath string

+ Logger *slog.Logger

+ Relays []string

+ RotationKeyPath string

+ S3Config *S3Config

+ SessionSecret string

+ SmtpEmail string

+ SmtpHost string

+ SmtpName string

+ SmtpPass string

+ SmtpPort string

+ SmtpUser string

+ Version string

+ type BlockstoreVariant int

+ func MustReturnBlockstoreVariant(maybeBsv string) BlockstoreVariant

+ type ComAtprotoIdentityUpdateHandleRequest struct

+ Handle string

+ type ComAtprotoRepoApplyWritesItem struct

+ Collection string

+ Rkey string

+ Type string

+ Value *MarshalableMap

+ type ComAtprotoRepoApplyWritesRequest struct

+ Repo string

+ SwapCommit *string

+ Validate *bool

+ Writes []ComAtprotoRepoApplyWritesItem

+ type ComAtprotoRepoApplyWritesResponse struct

+ Commit RepoCommit

+ Results []ApplyWriteResult

+ type ComAtprotoRepoCreateRecordRequest struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey *string

+ SwapCommit *string

+ SwapRecord *string

+ Validate *bool

+ type ComAtprotoRepoDeleteRecordRequest struct

+ Collection string

+ Repo string

+ Rkey string

+ SwapCommit *string

+ SwapRecord *string

+ type ComAtprotoRepoDescribeRepoResponse struct

+ Collections []string

+ Did string

+ DidDoc identity.DidDoc

+ Handle string

+ HandleIsCorrect bool

+ type ComAtprotoRepoGetRecordResponse struct

+ Cid string

+ Uri string

+ Value map[string]any

+ type ComAtprotoRepoListRecordsRecordItem struct

+ Cid string

+ Uri string

+ Value map[string]any

+ type ComAtprotoRepoListRecordsRequest struct

+ Collection string

+ Cursor string

+ Limit int64

+ Repo string

+ Reverse bool

+ type ComAtprotoRepoListRecordsResponse struct

+ Cursor *string

+ Records []ComAtprotoRepoListRecordsRecordItem

+ type ComAtprotoRepoPutRecordRequest struct

+ Collection string

+ Record MarshalableMap

+ Repo string

+ Rkey string

+ SwapCommit *string

+ SwapRecord *string

+ Validate *bool

+ type ComAtprotoRepoUploadBlobResponse struct

+ Blob struct{ ... }

+ type ComAtprotoRequestEmailUpdateResponse struct

+ TokenRequired bool

+ type ComAtprotoServerActivateAccountRequest struct

+ DeleteAfter time.Time

+ type ComAtprotoServerCheckAccountStatusResponse struct

+ Activated bool

+ ExpectedBlobs int64

+ ImportedBlobs int64

+ IndexedRecords int64

+ PrivateStateValues int64

+ RepoBlocks int64

+ RepoCommit string

+ RepoRev string

+ ValidDid bool

+ type ComAtprotoServerConfirmEmailRequest struct

+ Email string

+ Token string

+ type ComAtprotoServerCreateAccountRequest struct

+ Did *string

+ Email string

+ Handle string

+ InviteCode string

+ Password string

+ type ComAtprotoServerCreateAccountResponse struct

+ AccessJwt string

+ Did string

+ Handle string

+ RefreshJwt string

+ type ComAtprotoServerCreateInviteCodeRequest struct

+ ForAccount *string

+ UseCount int

+ type ComAtprotoServerCreateInviteCodeResponse struct

+ Code string

+ type ComAtprotoServerCreateInviteCodesItem struct

+ Account string

+ Codes []string

+ type ComAtprotoServerCreateInviteCodesRequest struct

+ CodeCount *int

+ ForAccounts *[]string

+ UseCount int

+ type ComAtprotoServerCreateInviteCodesResponse []ComAtprotoServerCreateInviteCodesItem

+ type ComAtprotoServerCreateSessionRequest struct

+ AuthFactorToken *string

+ Identifier string

+ Password string

+ type ComAtprotoServerCreateSessionResponse struct

+ AccessJwt string

+ Active bool

+ Did string

+ Email string

+ EmailAuthFactor bool

+ EmailConfirmed bool

+ Handle string

+ RefreshJwt string

+ Status *string

+ type ComAtprotoServerDeactivateAccountRequest struct

+ DeleteAfter time.Time

+ type ComAtprotoServerDescribeServerResponse struct

+ AvailableUserDomains []string

+ Contact ComAtprotoServerDescribeServerResponseContact

+ Did string

+ InviteCodeRequired bool

+ Links ComAtprotoServerDescribeServerResponseLinks

+ PhoneVerificationRequired bool

+ type ComAtprotoServerDescribeServerResponseContact struct

+ Email string

+ type ComAtprotoServerDescribeServerResponseLinks struct

+ PrivacyPolicy *string

+ TermsOfService *string

+ type ComAtprotoServerGetSessionResponse struct

+ Active bool

+ Did string

+ Email string

+ EmailAuthFactor bool

+ EmailConfirmed bool

+ Handle string

+ Status *string

+ type ComAtprotoServerRefreshSessionResponse struct

+ AccessJwt string

+ Active bool

+ Did string

+ Handle string

+ RefreshJwt string

+ Status *string

+ type ComAtprotoServerRequestPasswordResetRequest struct

+ Email string

+ type ComAtprotoServerResetPasswordRequest struct

+ Password string

+ Token string

+ type ComAtprotoServerUpdateEmailRequest struct

+ Email string

+ EmailAuthFactor bool

+ Token string

+ type ComAtprotoSignPlcOperationRequest struct

+ AlsoKnownAs *[]string

+ RotationKeys *[]string

+ Services *map[string]identity.OperationService

+ Token string

+ VerificationMethods *map[string]string

+ type ComAtprotoSignPlcOperationResponse struct

+ Operation plc.Operation

+ type ComAtprotoSubmitPlcOperationRequest struct

+ Operation plc.Operation

+ type ComAtprotoSyncGetBlocksRequest struct

+ Cids []string

+ Did string

+ type ComAtprotoSyncGetLatestCommitResponse struct

+ Cid string

+ Rev string

+ type ComAtprotoSyncGetRepoStatusResponse struct

+ Active bool

+ Did string

+ Rev *string

+ Status *string

+ type ComAtprotoSyncListBlobsResponse struct

+ Cids []string

+ Cursor *string

+ type ComAtprotoSyncListReposRepoItem struct

+ Active bool

+ Did string

+ Head string

+ Rev string

+ Status *string

+ type ComAtprotoSyncListReposResponse struct

+ Cursor *string

+ Repos []ComAtprotoSyncListReposRepoItem

+ type CustomValidator struct

+ func (cv *CustomValidator) Validate(i any) error

+ type ES256KSigningMethod struct

+ func (m *ES256KSigningMethod) Alg() string

+ func (m *ES256KSigningMethod) Sign(signingString string, key interface{}) (string, error)

+ func (m *ES256KSigningMethod) Verify(signingString string, signature string, key interface{}) error

+ type FirehoseOp struct

+ Action string

+ Cid cid.Cid

+ Path string

+ type MarshalableMap map[string]any

+ func (mm *MarshalableMap) MarshalCBOR(w io.Writer) error

+ type OauthAuthorizationMetadata struct

+ AuthorizationEndpoint string

+ AuthorizationResponseISSParameterSupported bool

+ ClientIDMetadataDocumentSupported bool

+ CodeChallengeMethodsSupported []string

+ DisplayValuesSupported []string

+ DpopSigningAlgValuesSupported []string

+ GrantTypesSupported []string

+ IntrospectionEndpoint string

+ Issuer string

+ JwksUri string

+ ProtectedResources []string

+ PushedAuthorizationRequestEndpoint string

+ RequestObjectEncryptionAlgValuesSupported []string

+ RequestObjectEncryptionEncValuesSupported []string

+ RequestObjectSigningAlgValuesSupported []string

+ RequestParameterSupported bool

+ RequestUriParameterSupported bool

+ RequirePushedAuthorizationRequests bool

+ RequireRequestUriRegistration *bool

+ ResponseModesSupported []string

+ ResponseTypesSupported []string

+ RevocationEndpoint string

+ ScopesSupported []string

+ SubjectTypesSupported []string

+ TokenEndpoint string

+ TokenEndpointAuthMethodsSupported []string

+ TokenEndpointAuthSigningAlgValuesSupported []string

+ UILocalesSupported []string

+ type OauthAuthorizePostRequest struct

+ AcceptOrRejct string

+ RequestUri string

+ type OauthJwksResponse struct

+ Keys []any

+ type OauthParResponse struct

+ ExpiresIn int64

+ RequestURI string

+ type OauthSigninRequest struct

+ Password string

+ QueryParams string

+ Username string

+ type OauthTokenRequest struct

+ Code *string

+ CodeVerifier *string

+ GrantType string

+ RedirectURI *string

+ RefreshToken *string

+ type OauthTokenResponse struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ Scope string

+ Sub string

+ TokenType string

+ type Op struct

+ Collection string

+ Record *MarshalableMap

+ Rkey *string

+ SwapRecord *string

+ Type OpType

+ Validate *bool

+ type OpType string

+ func (ot OpType) String() string

+ type RepoCommit struct

+ Cid string

+ Rev string

+ type RepoMan struct

+ func NewRepoMan(s *Server) *RepoMan

+ type S3Config struct

+ AccessKey string

+ BackupsEnabled bool

+ BlobstoreEnabled bool

+ Bucket string

+ Endpoint string

+ Region string

+ SecretKey string

+ type Server struct

+ func New(args *Args) (*Server, error)

+ func (s *Server) Serve(ctx context.Context) error

+ func (s *Server) UpdateRepo(ctx context.Context, did string, root cid.Cid, rev string) error

+ type ServerGetServiceAuthRequest struct

+ Aud string

+ Exp float64

+ Lxm string

+ type Session struct

+ AccessToken string

+ RefreshToken string

+ type TemplateRenderer struct

+ func (t *TemplateRenderer) Render(w io.Writer, name string, data any, c echo.Context) error

+ type ValidationError struct

+ Field string

+ Tag string

v0.0.2

Apr 3, 2025

v0.0.1

Apr 1, 2025

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