api

Documentation

Index

• Constants
• Variables
• func AuthMiddleware(logger logging.Logger, swagger *openapi3.Swagger, ...) func(next http.Handler) http.Handler
• func EtagMiddleware(root fs.FS, next http.Handler) http.Handler
• func GenerateJWTLogin(secret []byte, userID string, issuedAt, expiresAt time.Time) (string, error)
• func GenericAuthMiddleware(logger logging.Logger, authenticator auth.Authenticator, ...) (func(next http.Handler) http.Handler, error)
• func InvalidAPIEndpointHandler(w http.ResponseWriter, r *http.Request)
• func MetricsMiddleware(swagger *openapi3.Swagger) func(http.Handler) http.Handler
• func NewHandlerWithDefault(fileSystem http.FileSystem, handler http.Handler, gatewayDomains []string) http.Handler
• func NewInjectIndexFS(fsys fs.FS, name string, marker string, snippets []params.CodeSnippet) (fs.FS, error)
• func NewLogoutHandler(sessionStore sessions.Store, logger logging.Logger, logoutRedirectURL string) http.HandlerFunc
• func NewS3GatewayEndpointErrorHandler(gatewayDomains []string) http.Handler
• func NewUIHandler(gatewayDomains []string, snippets []params.CodeSnippet) http.Handler
• func OapiRequestValidatorWithOptions(swagger *openapi3.Swagger, options *openapi3filter.Options) func(http.Handler) http.Handler
• func Serve(cfg *config.Config, catalog *catalog.Catalog, ...) http.Handler
• type AuditChecker
• type Controller
  • func NewController(cfg *config.Config, catalog *catalog.Catalog, authenticator auth.Authenticator, ...) *Controller
  • func (c *Controller) AbortPresignMultipartUpload(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) AddGroupMembership(w http.ResponseWriter, r *http.Request, groupID, userID string)
  • func (c *Controller) AttachPolicyToGroup(w http.ResponseWriter, r *http.Request, groupID, policyID string)
  • func (c *Controller) AttachPolicyToUser(w http.ResponseWriter, r *http.Request, userID, policyID string)
  • func (c *Controller) CherryPick(w http.ResponseWriter, r *http.Request, body apigen.CherryPickJSONRequestBody, ...)
  • func (c *Controller) Commit(w http.ResponseWriter, r *http.Request, body apigen.CommitJSONRequestBody, ...)
  • func (c *Controller) CompletePresignMultipartUpload(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) CopyObject(w http.ResponseWriter, r *http.Request, body apigen.CopyObjectJSONRequestBody, ...)
  • func (c *Controller) CreateBranch(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) CreateBranchProtectionRulePreflight(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) CreateCredentials(w http.ResponseWriter, r *http.Request, userID string)
  • func (c *Controller) CreateGroup(w http.ResponseWriter, r *http.Request, body apigen.CreateGroupJSONRequestBody)
  • func (c *Controller) CreatePolicy(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) CreatePresignMultipartUpload(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
  • func (c *Controller) CreateRepository(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) CreateSymlinkFile(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) CreateTag(w http.ResponseWriter, r *http.Request, body apigen.CreateTagJSONRequestBody, ...)
  • func (c *Controller) CreateUser(w http.ResponseWriter, r *http.Request, body apigen.CreateUserJSONRequestBody)
  • func (c *Controller) DeleteBranch(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) DeleteCredentials(w http.ResponseWriter, r *http.Request, userID, accessKeyID string)
  • func (c *Controller) DeleteGCRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) DeleteGroup(w http.ResponseWriter, r *http.Request, groupID string)
  • func (c *Controller) DeleteGroupMembership(w http.ResponseWriter, r *http.Request, groupID, userID string)
  • func (c *Controller) DeleteObject(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) DeleteObjects(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) DeletePolicy(w http.ResponseWriter, r *http.Request, policyID string)
  • func (c *Controller) DeleteRepository(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) DeleteRepositoryMetadata(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) DeleteTag(w http.ResponseWriter, r *http.Request, repository, tag string, ...)
  • func (c *Controller) DeleteUser(w http.ResponseWriter, r *http.Request, userID string)
  • func (c *Controller) DetachPolicyFromGroup(w http.ResponseWriter, r *http.Request, groupID, policyID string)
  • func (c *Controller) DetachPolicyFromUser(w http.ResponseWriter, r *http.Request, userID, policyID string)
  • func (c *Controller) DiffBranch(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) DiffRefs(w http.ResponseWriter, r *http.Request, repository, leftRef, rightRef string, ...)
  • func (c *Controller) DumpRefs(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) DumpStatus(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) DumpSubmit(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) FindMergeBase(w http.ResponseWriter, r *http.Request, repository string, sourceRef string, ...)
  • func (c *Controller) GetAuthCapabilities(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetBranch(w http.ResponseWriter, r *http.Request, repository, branch string)
  • func (c *Controller) GetBranchProtectionRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetCommit(w http.ResponseWriter, r *http.Request, repository, commitID string)
  • func (c *Controller) GetConfig(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetCredentials(w http.ResponseWriter, r *http.Request, userID, accessKeyID string)
  • func (c *Controller) GetCurrentUser(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetGCRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetGarbageCollectionConfig(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetGroup(w http.ResponseWriter, r *http.Request, groupID string)
  • func (c *Controller) GetGroupACL(w http.ResponseWriter, r *http.Request, groupID string)
  • func (c *Controller) GetLakeFSVersion(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetMetaRange(w http.ResponseWriter, r *http.Request, repository, metaRange string)
  • func (c *Controller) GetObject(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) GetOtfDiffs(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetPhysicalAddress(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) GetPolicy(w http.ResponseWriter, r *http.Request, policyID string)
  • func (c *Controller) GetRange(w http.ResponseWriter, r *http.Request, repository, pRange string)
  • func (c *Controller) GetRepository(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetRepositoryMetadata(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetRun(w http.ResponseWriter, r *http.Request, repository, runID string)
  • func (c *Controller) GetRunHookOutput(w http.ResponseWriter, r *http.Request, repository, runID, hookRunID string)
  • func (c *Controller) GetSetupState(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetStorageConfig(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetTag(w http.ResponseWriter, r *http.Request, repository, tag string)
  • func (c *Controller) GetUnderlyingProperties(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) GetUsageReportSummary(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetUser(w http.ResponseWriter, r *http.Request, userID string)
  • func (c *Controller) HardResetBranch(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) HeadObject(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) HealthCheck(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) ImportCancel(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) ImportStart(w http.ResponseWriter, r *http.Request, body apigen.ImportStartJSONRequestBody, ...)
  • func (c *Controller) ImportStatus(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) InternalCreateBranchProtectionRule(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) InternalDeleteBranchProtectionRule(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) InternalDeleteGarbageCollectionRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) InternalGetBranchProtectionRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) InternalGetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) InternalSetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) LinkPhysicalAddress(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) ListBranches(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) ListGroupMembers(w http.ResponseWriter, r *http.Request, groupID string, ...)
  • func (c *Controller) ListGroupPolicies(w http.ResponseWriter, r *http.Request, groupID string, ...)
  • func (c *Controller) ListGroups(w http.ResponseWriter, r *http.Request, params apigen.ListGroupsParams)
  • func (c *Controller) ListObjects(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) ListPolicies(w http.ResponseWriter, r *http.Request, params apigen.ListPoliciesParams)
  • func (c *Controller) ListRepositories(w http.ResponseWriter, r *http.Request, params apigen.ListRepositoriesParams)
  • func (c *Controller) ListRepositoryRuns(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) ListRunHooks(w http.ResponseWriter, r *http.Request, repository, runID string, ...)
  • func (c *Controller) ListTags(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) ListUserCredentials(w http.ResponseWriter, r *http.Request, userID string, ...)
  • func (c *Controller) ListUserGroups(w http.ResponseWriter, r *http.Request, userID string, ...)
  • func (c *Controller) ListUserPolicies(w http.ResponseWriter, r *http.Request, userID string, ...)
  • func (c *Controller) ListUsers(w http.ResponseWriter, r *http.Request, params apigen.ListUsersParams)
  • func (c *Controller) LogAction(ctx context.Context, action string, r *http.Request, ...)
  • func (c *Controller) LogCommits(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) Login(w http.ResponseWriter, r *http.Request, body apigen.LoginJSONRequestBody)
  • func (c *Controller) MergeIntoBranch(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) OtfDiff(w http.ResponseWriter, r *http.Request, repository, leftRef, rightRef string, ...)
  • func (c *Controller) PostStatsEvents(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) PrepareGarbageCollectionCommits(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) PrepareGarbageCollectionUncommitted(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) ResetBranch(w http.ResponseWriter, r *http.Request, body apigen.ResetBranchJSONRequestBody, ...)
  • func (c *Controller) RestoreRefs(w http.ResponseWriter, r *http.Request, body apigen.RestoreRefsJSONRequestBody, ...)
  • func (c *Controller) RestoreStatus(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) RestoreSubmit(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) RevertBranch(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) SetBranchProtectionRules(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) SetGCRules(w http.ResponseWriter, r *http.Request, body apigen.SetGCRulesJSONRequestBody, ...)
  • func (c *Controller) SetGarbageCollectionRulesPreflight(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) SetGroupACL(w http.ResponseWriter, r *http.Request, body apigen.SetGroupACLJSONRequestBody, ...)
  • func (c *Controller) SetRepositoryMetadata(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) Setup(w http.ResponseWriter, r *http.Request, body apigen.SetupJSONRequestBody)
  • func (c *Controller) SetupCommPrefs(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) StageObject(w http.ResponseWriter, r *http.Request, body apigen.StageObjectJSONRequestBody, ...)
  • func (c *Controller) StatObject(w http.ResponseWriter, r *http.Request, repository, ref string, ...)
  • func (c *Controller) UpdatePolicy(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) UploadObject(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
  • func (c *Controller) UploadObjectPreflight(w http.ResponseWriter, r *http.Request, repository, branch string, ...)
• type CookieAuthConfig
• type InjectSnippetsFS
  • func (i *InjectSnippetsFS) Open(name string) (fs.File, error)
• type Migrator
• type OIDCConfig

Constants

const (
	TokenSessionKeyName       = "token"
	InternalAuthSessionName   = "internal_auth_session"
	IDTokenClaimsSessionKey   = "id_token_claims"
	OIDCAuthSessionName       = "oidc_auth_session"
	SAMLTokenClaimsSessionKey = "saml_token_claims"
	SAMLAuthSessionName       = "saml_auth_session"
)

const (
	// DefaultMaxPerPage is the maximum number of results returned for paginated queries to the API
	DefaultMaxPerPage int = 1000
	// DefaultPerPage is the default number of results returned for paginated queries to the API
	DefaultPerPage int = 100

	DefaultMaxDeleteObjects = 1000
)

const (
	RequestIDHeaderName = "X-Request-ID"
	LoggerServiceName   = "rest_api"
)

const (
	LoginAudience = "login"
)

Variables

var (
	ErrFailedToAccessStorage = errors.New("failed to access storage")
	ErrAuthenticatingRequest = errors.New("error authenticating request")
	ErrInvalidAPIEndpoint    = errors.New("invalid API endpoint")
	ErrRequestSizeExceeded   = errors.New("request size exceeded")
	ErrStorageNamespaceInUse = errors.New("storage namespace already in use")
)

Functions

func AuthMiddleware

func AuthMiddleware(logger logging.Logger, swagger *openapi3.Swagger, authenticator auth.Authenticator, authService auth.Service, sessionStore sessions.Store, oidcConfig *OIDCConfig, cookieAuthConfig *CookieAuthConfig) func(next http.Handler) http.Handler

func EtagMiddleware

func EtagMiddleware(root fs.FS, next http.Handler) http.Handler

EtagMiddleware returns a new Etag middleware handler. It designs to work on embedded FS, where the content doesn't change. It calculates the Etag for each file on startup and serves it on each request.

func GenerateJWTLogin

func GenerateJWTLogin(secret []byte, userID string, issuedAt, expiresAt time.Time) (string, error)

GenerateJWTLogin creates a jwt token which can be used for authentication during login only, i.e. it will not work for password reset. It supports backward compatibility for creating a login jwt. The audience is not set for login token. Any audience will make the token invalid for login. No email is passed to support the ability of login for users via user/access keys which don't have an email yet

func GenericAuthMiddleware

func GenericAuthMiddleware(logger logging.Logger, authenticator auth.Authenticator, authService auth.Service, oidcConfig *OIDCConfig, cookieAuthConfig *CookieAuthConfig) (func(next http.Handler) http.Handler, error)

func InvalidAPIEndpointHandler

func InvalidAPIEndpointHandler(w http.ResponseWriter, r *http.Request)

InvalidAPIEndpointHandler returns ErrInvalidAPIEndpoint, and is currently being used to ensure that routes under the pattern it is used with in chi.Router.Mount (i.e. /api/v1) are not accessible.

func MetricsMiddleware

func MetricsMiddleware(swagger *openapi3.Swagger) func(http.Handler) http.Handler

func NewHandlerWithDefault

func NewHandlerWithDefault(fileSystem http.FileSystem, handler http.Handler, gatewayDomains []string) http.Handler

func NewInjectIndexFS

func NewInjectIndexFS(fsys fs.FS, name string, marker string, snippets []params.CodeSnippet) (fs.FS, error)

func NewLogoutHandler

func NewLogoutHandler(sessionStore sessions.Store, logger logging.Logger, logoutRedirectURL string) http.HandlerFunc

NewLogoutHandler returns a handler to clear the user sessions and redirect the user to the login page.

func NewS3GatewayEndpointErrorHandler

func NewS3GatewayEndpointErrorHandler(gatewayDomains []string) http.Handler

func NewUIHandler

func NewUIHandler(gatewayDomains []string, snippets []params.CodeSnippet) http.Handler

func OapiRequestValidatorWithOptions

func OapiRequestValidatorWithOptions(swagger *openapi3.Swagger, options *openapi3filter.Options) func(http.Handler) http.Handler

OapiRequestValidatorWithOptions Creates middleware to validate request by swagger spec. This middleware is good for net/http either since go-chi is 100% compatible with net/http. The original implementation can be found at https://github.com/deepmap/oapi-codegen/blob/master/pkg/chi-middleware/oapi_validate.go Use our own implementation in order to:

1. Use the latest version kin-openapi (can switch back when oapi-codegen will be updated)
2. For file upload wanted to skip body validation for two reasons: a. didn't find a way for the validator to accept any file content type b. didn't want the validator to read the complete request body for the specific request

func Serve

func Serve(cfg *config.Config, catalog *catalog.Catalog, middlewareAuthenticator auth.Authenticator, authService auth.Service, blockAdapter block.Adapter, metadataManager auth.MetadataManager, migrator Migrator, collector stats.Collector, cloudMetadataProvider cloud.MetadataProvider, actions actionsHandler, auditChecker AuditChecker, logger logging.Logger, gatewayDomains []string, snippets []params.CodeSnippet, pathProvider upload.PathProvider, otfService *tablediff.Service, usageReporter stats.UsageReporterOperations) http.Handler

Types

type AuditChecker

type AuditChecker interface {
	LastCheck() (*version.AuditResponse, error)
	CheckLatestVersion() (*version.LatestVersionResponse, error)
}

type Controller

type Controller struct {
	Config                *config.Config
	Catalog               *catalog.Catalog
	Authenticator         auth.Authenticator
	Auth                  auth.Service
	BlockAdapter          block.Adapter
	MetadataManager       auth.MetadataManager
	Migrator              Migrator
	Collector             stats.Collector
	CloudMetadataProvider cloud.MetadataProvider
	Actions               actionsHandler
	AuditChecker          AuditChecker
	Logger                logging.Logger

	PathProvider upload.PathProvider
	// contains filtered or unexported fields
}

func NewController

func NewController(cfg *config.Config, catalog *catalog.Catalog, authenticator auth.Authenticator, authService auth.Service, blockAdapter block.Adapter, metadataManager auth.MetadataManager, migrator Migrator, collector stats.Collector, cloudMetadataProvider cloud.MetadataProvider, actions actionsHandler, auditChecker AuditChecker, logger logging.Logger, sessionStore sessions.Store, pathProvider upload.PathProvider, otfDiffService *tablediff.Service, usageReporter stats.UsageReporterOperations) *Controller

func (*Controller) AbortPresignMultipartUpload

func (c *Controller) AbortPresignMultipartUpload(w http.ResponseWriter, r *http.Request, body apigen.AbortPresignMultipartUploadJSONRequestBody, repository string, branch string, uploadID string, params apigen.AbortPresignMultipartUploadParams)

func (*Controller) AddGroupMembership

func (c *Controller) AddGroupMembership(w http.ResponseWriter, r *http.Request, groupID, userID string)

func (*Controller) AttachPolicyToGroup

func (c *Controller) AttachPolicyToGroup(w http.ResponseWriter, r *http.Request, groupID, policyID string)

func (*Controller) AttachPolicyToUser

func (c *Controller) AttachPolicyToUser(w http.ResponseWriter, r *http.Request, userID, policyID string)

func (*Controller) CherryPick

func (c *Controller) CherryPick(w http.ResponseWriter, r *http.Request, body apigen.CherryPickJSONRequestBody, repository string, branch string)

func (*Controller) Commit

func (c *Controller) Commit(w http.ResponseWriter, r *http.Request, body apigen.CommitJSONRequestBody, repository, branch string, params apigen.CommitParams)

func (*Controller) CompletePresignMultipartUpload

func (c *Controller) CompletePresignMultipartUpload(w http.ResponseWriter, r *http.Request, body apigen.CompletePresignMultipartUploadJSONRequestBody, repository string, branch string, uploadID string, params apigen.CompletePresignMultipartUploadParams)

func (*Controller) CopyObject

func (c *Controller) CopyObject(w http.ResponseWriter, r *http.Request, body apigen.CopyObjectJSONRequestBody, repository, branch string, params apigen.CopyObjectParams)

func (*Controller) CreateBranch

func (c *Controller) CreateBranch(w http.ResponseWriter, r *http.Request, body apigen.CreateBranchJSONRequestBody, repository string)

func (*Controller) CreateBranchProtectionRulePreflight

func (c *Controller) CreateBranchProtectionRulePreflight(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) CreateCredentials

func (c *Controller) CreateCredentials(w http.ResponseWriter, r *http.Request, userID string)

func (*Controller) CreateGroup

func (c *Controller) CreateGroup(w http.ResponseWriter, r *http.Request, body apigen.CreateGroupJSONRequestBody)

func (*Controller) CreatePolicy

func (c *Controller) CreatePolicy(w http.ResponseWriter, r *http.Request, body apigen.CreatePolicyJSONRequestBody)

func (*Controller) CreatePresignMultipartUpload

func (c *Controller) CreatePresignMultipartUpload(w http.ResponseWriter, r *http.Request, repository string, branch string, params apigen.CreatePresignMultipartUploadParams)

func (*Controller) CreateRepository

func (c *Controller) CreateRepository(w http.ResponseWriter, r *http.Request, body apigen.CreateRepositoryJSONRequestBody, params apigen.CreateRepositoryParams)

func (*Controller) CreateSymlinkFile

func (c *Controller) CreateSymlinkFile(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.CreateSymlinkFileParams)

func (*Controller) CreateTag

func (c *Controller) CreateTag(w http.ResponseWriter, r *http.Request, body apigen.CreateTagJSONRequestBody, repository string)

func (*Controller) CreateUser

func (c *Controller) CreateUser(w http.ResponseWriter, r *http.Request, body apigen.CreateUserJSONRequestBody)

func (*Controller) DeleteBranch

func (c *Controller) DeleteBranch(w http.ResponseWriter, r *http.Request, repository, branch string, body apigen.DeleteBranchParams)

func (*Controller) DeleteCredentials

func (c *Controller) DeleteCredentials(w http.ResponseWriter, r *http.Request, userID, accessKeyID string)

func (*Controller) DeleteGCRules

func (c *Controller) DeleteGCRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) DeleteGroup

func (c *Controller) DeleteGroup(w http.ResponseWriter, r *http.Request, groupID string)

func (*Controller) DeleteGroupMembership

func (c *Controller) DeleteGroupMembership(w http.ResponseWriter, r *http.Request, groupID, userID string)

func (*Controller) DeleteObject

func (c *Controller) DeleteObject(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.DeleteObjectParams)

func (*Controller) DeleteObjects

func (c *Controller) DeleteObjects(w http.ResponseWriter, r *http.Request, body apigen.DeleteObjectsJSONRequestBody, repository, branch string, params apigen.DeleteObjectsParams)

func (*Controller) DeletePolicy

func (c *Controller) DeletePolicy(w http.ResponseWriter, r *http.Request, policyID string)

func (*Controller) DeleteRepository

func (c *Controller) DeleteRepository(w http.ResponseWriter, r *http.Request, repository string, params apigen.DeleteRepositoryParams)

func (*Controller) DeleteRepositoryMetadata

func (c *Controller) DeleteRepositoryMetadata(w http.ResponseWriter, r *http.Request, body apigen.DeleteRepositoryMetadataJSONRequestBody, repository string)

func (*Controller) DeleteTag

func (c *Controller) DeleteTag(w http.ResponseWriter, r *http.Request, repository, tag string, params apigen.DeleteTagParams)

func (*Controller) DeleteUser

func (c *Controller) DeleteUser(w http.ResponseWriter, r *http.Request, userID string)

func (*Controller) DetachPolicyFromGroup

func (c *Controller) DetachPolicyFromGroup(w http.ResponseWriter, r *http.Request, groupID, policyID string)

func (*Controller) DetachPolicyFromUser

func (c *Controller) DetachPolicyFromUser(w http.ResponseWriter, r *http.Request, userID, policyID string)

func (*Controller) DiffBranch

func (c *Controller) DiffBranch(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.DiffBranchParams)

func (*Controller) DiffRefs

func (c *Controller) DiffRefs(w http.ResponseWriter, r *http.Request, repository, leftRef, rightRef string, params apigen.DiffRefsParams)

func (*Controller) DumpRefs

func (c *Controller) DumpRefs(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) DumpStatus

func (c *Controller) DumpStatus(w http.ResponseWriter, r *http.Request, repository string, params apigen.DumpStatusParams)

func (*Controller) DumpSubmit

func (c *Controller) DumpSubmit(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) FindMergeBase

func (c *Controller) FindMergeBase(w http.ResponseWriter, r *http.Request, repository string, sourceRef string, destinationRef string)

func (*Controller) GetAuthCapabilities

func (c *Controller) GetAuthCapabilities(w http.ResponseWriter, r *http.Request)

func (*Controller) GetBranch

func (c *Controller) GetBranch(w http.ResponseWriter, r *http.Request, repository, branch string)

func (*Controller) GetBranchProtectionRules

func (c *Controller) GetBranchProtectionRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) GetCommit

func (c *Controller) GetCommit(w http.ResponseWriter, r *http.Request, repository, commitID string)

func (*Controller) GetConfig

func (c *Controller) GetConfig(w http.ResponseWriter, r *http.Request)

func (*Controller) GetCredentials

func (c *Controller) GetCredentials(w http.ResponseWriter, r *http.Request, userID, accessKeyID string)

func (*Controller) GetCurrentUser

func (c *Controller) GetCurrentUser(w http.ResponseWriter, r *http.Request)

func (*Controller) GetGCRules

func (c *Controller) GetGCRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) GetGarbageCollectionConfig

func (c *Controller) GetGarbageCollectionConfig(w http.ResponseWriter, r *http.Request)

func (*Controller) GetGroup

func (c *Controller) GetGroup(w http.ResponseWriter, r *http.Request, groupID string)

func (*Controller) GetGroupACL

func (c *Controller) GetGroupACL(w http.ResponseWriter, r *http.Request, groupID string)

func (*Controller) GetLakeFSVersion

func (c *Controller) GetLakeFSVersion(w http.ResponseWriter, r *http.Request)

func (*Controller) GetMetaRange

func (c *Controller) GetMetaRange(w http.ResponseWriter, r *http.Request, repository, metaRange string)

func (*Controller) GetObject

func (c *Controller) GetObject(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.GetObjectParams)

func (*Controller) GetOtfDiffs

func (c *Controller) GetOtfDiffs(w http.ResponseWriter, r *http.Request)

func (*Controller) GetPhysicalAddress

func (c *Controller) GetPhysicalAddress(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.GetPhysicalAddressParams)

func (*Controller) GetPolicy

func (c *Controller) GetPolicy(w http.ResponseWriter, r *http.Request, policyID string)

func (*Controller) GetRange

func (c *Controller) GetRange(w http.ResponseWriter, r *http.Request, repository, pRange string)

func (*Controller) GetRepository

func (c *Controller) GetRepository(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) GetRepositoryMetadata

func (c *Controller) GetRepositoryMetadata(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) GetRun

func (c *Controller) GetRun(w http.ResponseWriter, r *http.Request, repository, runID string)

func (*Controller) GetRunHookOutput

func (c *Controller) GetRunHookOutput(w http.ResponseWriter, r *http.Request, repository, runID, hookRunID string)

func (*Controller) GetSetupState

func (c *Controller) GetSetupState(w http.ResponseWriter, r *http.Request)

func (*Controller) GetStorageConfig

func (c *Controller) GetStorageConfig(w http.ResponseWriter, r *http.Request)

func (*Controller) GetTag

func (c *Controller) GetTag(w http.ResponseWriter, r *http.Request, repository, tag string)

func (*Controller) GetUnderlyingProperties

func (c *Controller) GetUnderlyingProperties(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.GetUnderlyingPropertiesParams)

func (*Controller) GetUsageReportSummary

func (c *Controller) GetUsageReportSummary(w http.ResponseWriter, r *http.Request)

func (*Controller) GetUser

func (c *Controller) GetUser(w http.ResponseWriter, r *http.Request, userID string)

func (*Controller) HardResetBranch

func (c *Controller) HardResetBranch(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.HardResetBranchParams)

func (*Controller) HeadObject

func (c *Controller) HeadObject(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.HeadObjectParams)

func (*Controller) HealthCheck

func (c *Controller) HealthCheck(w http.ResponseWriter, r *http.Request)

func (*Controller) ImportCancel

func (c *Controller) ImportCancel(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.ImportCancelParams)

func (*Controller) ImportStart

func (c *Controller) ImportStart(w http.ResponseWriter, r *http.Request, body apigen.ImportStartJSONRequestBody, repository, branch string)

func (*Controller) ImportStatus

func (c *Controller) ImportStatus(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.ImportStatusParams)

func (*Controller) InternalCreateBranchProtectionRule

func (c *Controller) InternalCreateBranchProtectionRule(w http.ResponseWriter, r *http.Request, body apigen.InternalCreateBranchProtectionRuleJSONRequestBody, repository string)

func (*Controller) InternalDeleteBranchProtectionRule

func (c *Controller) InternalDeleteBranchProtectionRule(w http.ResponseWriter, r *http.Request, body apigen.InternalDeleteBranchProtectionRuleJSONRequestBody, repository string)

func (*Controller) InternalDeleteGarbageCollectionRules

func (c *Controller) InternalDeleteGarbageCollectionRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) InternalGetBranchProtectionRules

func (c *Controller) InternalGetBranchProtectionRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) InternalGetGarbageCollectionRules

func (c *Controller) InternalGetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) InternalSetGarbageCollectionRules

func (c *Controller) InternalSetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, body apigen.InternalSetGarbageCollectionRulesJSONRequestBody, repository string)

func (*Controller) LinkPhysicalAddress

func (c *Controller) LinkPhysicalAddress(w http.ResponseWriter, r *http.Request, body apigen.LinkPhysicalAddressJSONRequestBody, repository, branch string, params apigen.LinkPhysicalAddressParams)

func (*Controller) ListBranches

func (c *Controller) ListBranches(w http.ResponseWriter, r *http.Request, repository string, params apigen.ListBranchesParams)

func (*Controller) ListGroupMembers

func (c *Controller) ListGroupMembers(w http.ResponseWriter, r *http.Request, groupID string, params apigen.ListGroupMembersParams)

func (*Controller) ListGroupPolicies

func (c *Controller) ListGroupPolicies(w http.ResponseWriter, r *http.Request, groupID string, params apigen.ListGroupPoliciesParams)

func (*Controller) ListGroups

func (c *Controller) ListGroups(w http.ResponseWriter, r *http.Request, params apigen.ListGroupsParams)

func (*Controller) ListObjects

func (c *Controller) ListObjects(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.ListObjectsParams)

func (*Controller) ListPolicies

func (c *Controller) ListPolicies(w http.ResponseWriter, r *http.Request, params apigen.ListPoliciesParams)

func (*Controller) ListRepositories

func (c *Controller) ListRepositories(w http.ResponseWriter, r *http.Request, params apigen.ListRepositoriesParams)

func (*Controller) ListRepositoryRuns

func (c *Controller) ListRepositoryRuns(w http.ResponseWriter, r *http.Request, repository string, params apigen.ListRepositoryRunsParams)

func (*Controller) ListRunHooks

func (c *Controller) ListRunHooks(w http.ResponseWriter, r *http.Request, repository, runID string, params apigen.ListRunHooksParams)

func (*Controller) ListTags

func (c *Controller) ListTags(w http.ResponseWriter, r *http.Request, repository string, params apigen.ListTagsParams)

func (*Controller) ListUserCredentials

func (c *Controller) ListUserCredentials(w http.ResponseWriter, r *http.Request, userID string, params apigen.ListUserCredentialsParams)

func (*Controller) ListUserGroups

func (c *Controller) ListUserGroups(w http.ResponseWriter, r *http.Request, userID string, params apigen.ListUserGroupsParams)

func (*Controller) ListUserPolicies

func (c *Controller) ListUserPolicies(w http.ResponseWriter, r *http.Request, userID string, params apigen.ListUserPoliciesParams)

func (*Controller) ListUsers

func (c *Controller) ListUsers(w http.ResponseWriter, r *http.Request, params apigen.ListUsersParams)

func (*Controller) LogAction

func (c *Controller) LogAction(ctx context.Context, action string, r *http.Request, repository, ref, sourceRef string)

func (*Controller) LogCommits

func (c *Controller) LogCommits(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.LogCommitsParams)

func (*Controller) Login

func (c *Controller) Login(w http.ResponseWriter, r *http.Request, body apigen.LoginJSONRequestBody)

func (*Controller) MergeIntoBranch

func (c *Controller) MergeIntoBranch(w http.ResponseWriter, r *http.Request, body apigen.MergeIntoBranchJSONRequestBody, repository, sourceRef, destinationBranch string)

func (*Controller) OtfDiff

func (c *Controller) OtfDiff(w http.ResponseWriter, r *http.Request, repository, leftRef, rightRef string, params apigen.OtfDiffParams)

func (*Controller) PostStatsEvents

func (c *Controller) PostStatsEvents(w http.ResponseWriter, r *http.Request, body apigen.PostStatsEventsJSONRequestBody)

func (*Controller) PrepareGarbageCollectionCommits

func (c *Controller) PrepareGarbageCollectionCommits(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) PrepareGarbageCollectionUncommitted

func (c *Controller) PrepareGarbageCollectionUncommitted(w http.ResponseWriter, r *http.Request, body apigen.PrepareGarbageCollectionUncommittedJSONRequestBody, repository string)

func (*Controller) ResetBranch

func (c *Controller) ResetBranch(w http.ResponseWriter, r *http.Request, body apigen.ResetBranchJSONRequestBody, repository, branch string)

func (*Controller) RestoreRefs

func (c *Controller) RestoreRefs(w http.ResponseWriter, r *http.Request, body apigen.RestoreRefsJSONRequestBody, repository string)

func (*Controller) RestoreStatus

func (c *Controller) RestoreStatus(w http.ResponseWriter, r *http.Request, repository string, params apigen.RestoreStatusParams)

func (*Controller) RestoreSubmit

func (c *Controller) RestoreSubmit(w http.ResponseWriter, r *http.Request, body apigen.RestoreSubmitJSONRequestBody, repository string)

func (*Controller) RevertBranch

func (c *Controller) RevertBranch(w http.ResponseWriter, r *http.Request, body apigen.RevertBranchJSONRequestBody, repository, branch string)

func (*Controller) SetBranchProtectionRules

func (c *Controller) SetBranchProtectionRules(w http.ResponseWriter, r *http.Request, body apigen.SetBranchProtectionRulesJSONRequestBody, repository string, params apigen.SetBranchProtectionRulesParams)

func (*Controller) SetGCRules

func (c *Controller) SetGCRules(w http.ResponseWriter, r *http.Request, body apigen.SetGCRulesJSONRequestBody, repository string)

func (*Controller) SetGarbageCollectionRulesPreflight

func (c *Controller) SetGarbageCollectionRulesPreflight(w http.ResponseWriter, r *http.Request, repository string)

func (*Controller) SetGroupACL

func (c *Controller) SetGroupACL(w http.ResponseWriter, r *http.Request, body apigen.SetGroupACLJSONRequestBody, groupID string)

func (*Controller) SetRepositoryMetadata

func (c *Controller) SetRepositoryMetadata(w http.ResponseWriter, r *http.Request, body apigen.SetRepositoryMetadataJSONRequestBody, repository string)

func (*Controller) Setup

func (c *Controller) Setup(w http.ResponseWriter, r *http.Request, body apigen.SetupJSONRequestBody)

func (*Controller) SetupCommPrefs

func (c *Controller) SetupCommPrefs(w http.ResponseWriter, r *http.Request, body apigen.SetupCommPrefsJSONRequestBody)

func (*Controller) StageObject

func (c *Controller) StageObject(w http.ResponseWriter, r *http.Request, body apigen.StageObjectJSONRequestBody, repository, branch string, params apigen.StageObjectParams)

func (*Controller) StatObject

func (c *Controller) StatObject(w http.ResponseWriter, r *http.Request, repository, ref string, params apigen.StatObjectParams)

func (*Controller) UpdatePolicy

func (c *Controller) UpdatePolicy(w http.ResponseWriter, r *http.Request, body apigen.UpdatePolicyJSONRequestBody, policyID string)

func (*Controller) UploadObject

func (c *Controller) UploadObject(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.UploadObjectParams)

func (*Controller) UploadObjectPreflight

func (c *Controller) UploadObjectPreflight(w http.ResponseWriter, r *http.Request, repository, branch string, params apigen.UploadObjectPreflightParams)

type CookieAuthConfig

type CookieAuthConfig struct {
	ValidateIDTokenClaims   map[string]string
	DefaultInitialGroups    []string
	InitialGroupsClaimName  string
	FriendlyNameClaimName   string
	ExternalUserIDClaimName string
	AuthSource              string
}

type InjectSnippetsFS

type InjectSnippetsFS struct {
	fs.FS
	// contains filtered or unexported fields
}

func (*InjectSnippetsFS) Open

func (i *InjectSnippetsFS) Open(name string) (fs.File, error)

type Migrator

type Migrator interface {
	Migrate(ctx context.Context) error
}

type OIDCConfig

type OIDCConfig struct {
	ValidateIDTokenClaims  map[string]string
	DefaultInitialGroups   []string
	InitialGroupsClaimName string
	FriendlyNameClaimName  string
}