custom

package

v1.3.4 Latest Latest Go to latest Published: Feb 9, 2024 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/t2bot/matrix-media-repo

Links

Open Source Insights

Documentation ¶

Index ¶

func AppendToImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func DeleteExport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func DownloadExportPart(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func ExportServerData(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func ExportUserData(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetAttributes(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetDatastoreStorageEstimate(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetDatastores(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetDomainUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetExportMetadata(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetFederationInfo(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetHealthz(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetTask(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetUploadsUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetUserUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func GetVersion(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func ListAllTasks(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func ListUnfinishedTasks(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func MigrateBetweenDatastores(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeDomainMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeIndividualRecord(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeOldMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeQuarantined(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeRemoteMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeRoomMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func PurgeUserMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func QuarantineDomainMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func QuarantineMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func QuarantineRoomMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func QuarantineUserMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func SetAttributes(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func StartImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func StopImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func SynGetUsersMediaStats(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
func ViewExport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}
type Attributes
type CountsUsageResponse
type DatastoreMigration
type ExportMetadata
type ExportPartMetadata
type ExportStarted
type HealthzResponse
type ImportStarted
type MediaPurgedResponse
type MediaQuarantinedResponse
type MediaUsageEntry
type MinimalUsageInfo
type TaskStatus
type UsageInfo
type UserUsageEntry

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AppendToImport ¶

func AppendToImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func DeleteExport ¶

func DeleteExport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func DownloadExportPart ¶

func DownloadExportPart(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func ExportServerData ¶

func ExportServerData(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func ExportUserData ¶

func ExportUserData(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetAttributes ¶

func GetAttributes(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetDatastoreStorageEstimate ¶

func GetDatastoreStorageEstimate(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetDatastores ¶

func GetDatastores(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetDomainUsage ¶

func GetDomainUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetExportMetadata ¶

func GetExportMetadata(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetFederationInfo ¶

func GetFederationInfo(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetHealthz ¶

func GetHealthz(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetTask ¶

func GetTask(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetUploadsUsage ¶

func GetUploadsUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetUserUsage ¶

func GetUserUsage(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func GetVersion ¶

func GetVersion(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func ListAllTasks ¶

func ListAllTasks(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func ListUnfinishedTasks ¶

func ListUnfinishedTasks(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func MigrateBetweenDatastores ¶

func MigrateBetweenDatastores(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeDomainMedia ¶

func PurgeDomainMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeIndividualRecord ¶

func PurgeIndividualRecord(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeOldMedia ¶

func PurgeOldMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeQuarantined ¶

func PurgeQuarantined(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeRemoteMedia ¶

func PurgeRemoteMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeRoomMedia ¶

func PurgeRoomMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func PurgeUserMedia ¶

func PurgeUserMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func QuarantineDomainMedia ¶

func QuarantineDomainMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func QuarantineMedia ¶

func QuarantineMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func QuarantineRoomMedia ¶

func QuarantineRoomMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func QuarantineUserMedia ¶

func QuarantineUserMedia(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func SetAttributes ¶

func SetAttributes(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func StartImport ¶

func StartImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func StopImport ¶

func StopImport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

func SynGetUsersMediaStats ¶

func SynGetUsersMediaStats(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

SynGetUsersMediaStats attempts to provide a loose equivalent to this Synapse admin endpoint: https://matrix-org.github.io/synapse/v1.88/admin_api/statistics.html#users-media-usage-statistics

func ViewExport ¶

func ViewExport(r *http.Request, rctx rcontext.RequestContext, user _apimeta.UserInfo) interface{}

Types ¶

type Attributes ¶

type Attributes struct {
	Purpose database.Purpose `json:"purpose"`
}

type CountsUsageResponse ¶

type CountsUsageResponse struct {
	RawBytes  *UsageInfo `json:"raw_bytes"`
	RawCounts *UsageInfo `json:"raw_counts"`
}

type DatastoreMigration ¶

type DatastoreMigration struct {
	*datastores.SizeEstimate
	TaskID int `json:"task_id"`
}

type ExportMetadata ¶

type ExportMetadata struct {
	Entity string                `json:"entity"`
	Parts  []*ExportPartMetadata `json:"parts"`
}

type ExportPartMetadata ¶

type ExportPartMetadata struct {
	Index     int    `json:"index"`
	SizeBytes int64  `json:"size"`
	FileName  string `json:"name"`
}

type ExportStarted ¶

type ExportStarted struct {
	ExportID string `json:"export_id"`
	TaskID   int    `json:"task_id"`
}

type HealthzResponse ¶

type HealthzResponse struct {
	OK     bool   `json:"ok"`
	Status string `json:"status"`
}

type ImportStarted ¶

type ImportStarted struct {
	ImportID string `json:"import_id"`
	TaskID   int    `json:"task_id"`
}

type MediaPurgedResponse ¶

type MediaPurgedResponse struct {
	NumRemoved int `json:"total_removed"`
}

type MediaQuarantinedResponse ¶

type MediaQuarantinedResponse struct {
	NumQuarantined int64 `json:"num_quarantined"`
}

type MediaUsageEntry ¶

type MediaUsageEntry struct {
	SizeBytes         int64  `json:"size_bytes"`
	UploadedBy        string `json:"uploaded_by"`
	DatastoreId       string `json:"datastore_id"`
	DatastoreLocation string `json:"datastore_location"`
	Sha256Hash        string `json:"sha256_hash"`
	Quarantined       bool   `json:"quarantined"`
	UploadName        string `json:"upload_name"`
	ContentType       string `json:"content_type"`
	CreatedTs         int64  `json:"created_ts"`
}

type MinimalUsageInfo ¶

type MinimalUsageInfo struct {
	// Used in per-user endpoints where we can't count thumbnails
	Total int64 `json:"total"`
	Media int64 `json:"media"`
}

type TaskStatus ¶

type TaskStatus struct {
	TaskID     int                     `json:"task_id"`
	Name       string                  `json:"task_name"`
	Params     *database.AnonymousJson `json:"params"`
	StartTs    int64                   `json:"start_ts"`
	EndTs      int64                   `json:"end_ts"`
	IsFinished bool                    `json:"is_finished"`
	Error      string                  `json:"error_message"`
}

type UsageInfo ¶

type UsageInfo struct {
	*MinimalUsageInfo
	Thumbnails int64 `json:"thumbnails"`
}

type UserUsageEntry ¶

type UserUsageEntry struct {
	// Returned by per-user endpoints, where we can't count thumbnails
	RawBytes     *MinimalUsageInfo `json:"raw_bytes"`
	RawCounts    *MinimalUsageInfo `json:"raw_counts"`
	UploadedMxcs []string          `json:"uploaded"`
}

Source Files ¶

View all Source files

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