api

Documentation

Index

• Constants
• Variables
• func AuthMiddleware(logger logging.Logger, swagger *openapi3.Swagger, ...) func(next http.Handler) http.Handler
• func GenerateJWTLogin(secret []byte, userID string, issuedAt, expiresAt time.Time) (string, error)
• func Int64Ptr(n int64) *int64
• func Int64Value(p *int64) int64
• func InvalidAPIEndpointHandler(w http.ResponseWriter, r *http.Request)
• func IsStatusCodeOK(statusCode int) bool
• 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 NewOIDCLoginPageHandler(oidcConfig config.OIDC, sessionStore sessions.Store, ...) 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.Interface, ...) http.Handler
• func StringPtr(s string) *string
• func StringValue(s *string) string
• func VerifyResetPasswordToken(ctx context.Context, authService auth.Service, token string) (*jwt.StandardClaims, error)
• type AuditChecker
• type Controller
  • func NewController(cfg *config.Config, catalog catalog.Interface, ...) *Controller
  • func (c *Controller) AddGroupMembership(w http.ResponseWriter, r *http.Request, groupID string, userID string)
  • func (c *Controller) AttachPolicyToGroup(w http.ResponseWriter, r *http.Request, groupID string, policyID string)
  • func (c *Controller) AttachPolicyToUser(w http.ResponseWriter, r *http.Request, userID string, policyID string)
  • func (c *Controller) Commit(w http.ResponseWriter, r *http.Request, body CommitJSONRequestBody, ...)
  • func (c *Controller) CreateBranch(w http.ResponseWriter, r *http.Request, body CreateBranchJSONRequestBody, ...)
  • func (c *Controller) CreateBranchProtectionRule(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) CreateCredentials(w http.ResponseWriter, r *http.Request, userID string)
  • func (c *Controller) CreateGroup(w http.ResponseWriter, r *http.Request, body CreateGroupJSONRequestBody)
  • func (c *Controller) CreateMetaRange(w http.ResponseWriter, r *http.Request, body CreateMetaRangeJSONRequestBody, ...)
  • func (c *Controller) CreatePolicy(w http.ResponseWriter, r *http.Request, body CreatePolicyJSONRequestBody)
  • func (c *Controller) CreateRepository(w http.ResponseWriter, r *http.Request, body CreateRepositoryJSONRequestBody, ...)
  • func (c *Controller) CreateSymlinkFile(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
  • func (c *Controller) CreateTag(w http.ResponseWriter, r *http.Request, body CreateTagJSONRequestBody, ...)
  • func (c *Controller) CreateUser(w http.ResponseWriter, r *http.Request, body CreateUserJSONRequestBody)
  • func (c *Controller) DeleteBranch(w http.ResponseWriter, r *http.Request, repository string, branch string)
  • func (c *Controller) DeleteBranchProtectionRule(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) DeleteCredentials(w http.ResponseWriter, r *http.Request, userID string, accessKeyID string)
  • func (c *Controller) DeleteGarbageCollectionRules(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 string, userID string)
  • func (c *Controller) DeleteObject(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
  • func (c *Controller) DeleteObjects(w http.ResponseWriter, r *http.Request, body DeleteObjectsJSONRequestBody, ...)
  • 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) DeleteTag(w http.ResponseWriter, r *http.Request, repository string, 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 string, policyID string)
  • func (c *Controller) DetachPolicyFromUser(w http.ResponseWriter, r *http.Request, userID string, policyID string)
  • func (c *Controller) DiffBranch(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
  • func (c *Controller) DiffRefs(w http.ResponseWriter, r *http.Request, repository string, leftRef string, ...)
  • func (c *Controller) DumpRefs(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) ExpandTemplate(w http.ResponseWriter, r *http.Request, templateLocation string, ...)
  • func (c *Controller) ForgotPassword(w http.ResponseWriter, r *http.Request, body ForgotPasswordJSONRequestBody)
  • func (c *Controller) GetAuthCapabilities(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetBranch(w http.ResponseWriter, r *http.Request, repository string, 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 string, commitID string)
  • func (c *Controller) GetCredentials(w http.ResponseWriter, r *http.Request, userID string, accessKeyID string)
  • func (c *Controller) GetCurrentUser(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetGroup(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 string, metaRange string)
  • func (c *Controller) GetObject(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) GetPhysicalAddress(w http.ResponseWriter, r *http.Request, repository string, 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 string, pRange string)
  • func (c *Controller) GetRepository(w http.ResponseWriter, r *http.Request, repository string)
  • func (c *Controller) GetRun(w http.ResponseWriter, r *http.Request, repository string, runID string)
  • func (c *Controller) GetRunHookOutput(w http.ResponseWriter, r *http.Request, repository string, runID 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 string, tag string)
  • func (c *Controller) GetUnderlyingProperties(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) GetUser(w http.ResponseWriter, r *http.Request, userID string)
  • func (c *Controller) HeadObject(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) HealthCheck(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) IngestRange(w http.ResponseWriter, r *http.Request, body IngestRangeJSONRequestBody, ...)
  • 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 ListGroupsParams)
  • func (c *Controller) ListObjects(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) ListPolicies(w http.ResponseWriter, r *http.Request, params ListPoliciesParams)
  • func (c *Controller) ListRepositories(w http.ResponseWriter, r *http.Request, params ListRepositoriesParams)
  • func (c *Controller) ListRepositoryRuns(w http.ResponseWriter, r *http.Request, repository string, ...)
  • func (c *Controller) ListRunHooks(w http.ResponseWriter, r *http.Request, repository string, 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 ListUsersParams)
  • func (c *Controller) LogAction(ctx context.Context, action string, r *http.Request, ...)
  • func (c *Controller) LogBranchCommits(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
  • func (c *Controller) LogCommits(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) Login(w http.ResponseWriter, r *http.Request, body LoginJSONRequestBody)
  • func (c *Controller) MergeIntoBranch(w http.ResponseWriter, r *http.Request, body MergeIntoBranchJSONRequestBody, ...)
  • func (c *Controller) OauthCallback(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) PrepareGarbageCollectionCommits(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) PrepareGarbageCollectionUncommitted(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) ResetBranch(w http.ResponseWriter, r *http.Request, body ResetBranchJSONRequestBody, ...)
  • func (c *Controller) RestoreRefs(w http.ResponseWriter, r *http.Request, body RestoreRefsJSONRequestBody, ...)
  • func (c *Controller) RevertBranch(w http.ResponseWriter, r *http.Request, body RevertBranchJSONRequestBody, ...)
  • func (c *Controller) SetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, ...)
  • func (c *Controller) Setup(w http.ResponseWriter, r *http.Request, body SetupJSONRequestBody)
  • func (c *Controller) SetupCommPrefs(w http.ResponseWriter, r *http.Request, body SetupCommPrefsJSONRequestBody)
  • func (c *Controller) StageObject(w http.ResponseWriter, r *http.Request, body StageObjectJSONRequestBody, ...)
  • func (c *Controller) StatObject(w http.ResponseWriter, r *http.Request, repository string, ref string, ...)
  • func (c *Controller) UpdatePassword(w http.ResponseWriter, r *http.Request, body UpdatePasswordJSONRequestBody)
  • func (c *Controller) UpdatePolicy(w http.ResponseWriter, r *http.Request, body UpdatePolicyJSONRequestBody, ...)
  • func (c *Controller) UploadObject(w http.ResponseWriter, r *http.Request, repository string, branch string, ...)
• type InjectSnippetsFS
  • func (i *InjectSnippetsFS) Open(name string) (fs.File, error)
• type Migrator

Constants

const (
	TokenSessionKeyName     = "token"
	InternalAuthSessionName = "internal_auth_session"
)

const (
	// DefaultMaxPerPage is the maximum amount of results returned for paginated queries to the API
	DefaultMaxPerPage int = 1000

	DefaultMaxDeleteObjects = 1000

	DefaultResetPasswordExpiration = 20 * time.Minute
)

const (
	IDTokenClaimsSessionKey = "id_token_claims"
	StateSessionKey         = "state"
	OIDCAuthSessionName     = "oidc_auth_session"
)

const (
	RequestIDHeaderName = "X-Request-ID"
	LoggerServiceName   = "rest_api"
	BaseURL             = "/api/v1"
)

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")
)

Functions

func AuthMiddleware

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

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 Int64Ptr

func Int64Ptr(n int64) *int64

func Int64Value

func Int64Value(p *int64) int64

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 IsStatusCodeOK

func IsStatusCodeOK(statusCode int) bool

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 NewOIDCLoginPageHandler

func NewOIDCLoginPageHandler(oidcConfig config.OIDC, sessionStore sessions.Store, oauthConfig *oauth2.Config, logger logging.Logger) http.HandlerFunc

NewOIDCLoginPageHandler returns a handler to redirect the user the OIDC provider's 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 Used 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.Interface,
	middlewareAuthenticator auth.Authenticator,
	controllerAuthenticator 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,
	emailer *email.Emailer,
	templater templater.Service,
	gatewayDomains []string,
	snippets []params.CodeSnippet,
	oidcProvider *oidc.Provider,
	oauthConfig *oauth2.Config,
	pathProvider upload.PathProvider,
) http.Handler

func StringPtr

func StringPtr(s string) *string

func StringValue

func StringValue(s *string) string

func VerifyResetPasswordToken

func VerifyResetPasswordToken(ctx context.Context, authService auth.Service, token string) (*jwt.StandardClaims, error)

Types

type AuditChecker

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

type Controller

type Controller struct {
	Config                *config.Config
	Catalog               catalog.Interface
	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
	Emailer               *email.Emailer
	Templater             templater.Service

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

func NewController

func NewController(
	cfg *config.Config,
	catalog catalog.Interface,
	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,
	emailer *email.Emailer,
	templater templater.Service,
	oidcAuthenticator *oidc.Authenticator,
	sessionStore sessions.Store,
	pathProvider upload.PathProvider,
) *Controller

func (*Controller) AddGroupMembership

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

func (*Controller) AttachPolicyToGroup

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

func (*Controller) AttachPolicyToUser

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

func (*Controller) Commit

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

func (*Controller) CreateBranch

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

func (*Controller) CreateBranchProtectionRule

func (c *Controller) CreateBranchProtectionRule(w http.ResponseWriter, r *http.Request, body CreateBranchProtectionRuleJSONRequestBody, 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 CreateGroupJSONRequestBody)

func (*Controller) CreateMetaRange

func (c *Controller) CreateMetaRange(w http.ResponseWriter, r *http.Request, body CreateMetaRangeJSONRequestBody, repository string)

func (*Controller) CreatePolicy

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

func (*Controller) CreateRepository

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

func (*Controller) CreateSymlinkFile

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

func (*Controller) CreateTag

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

func (*Controller) CreateUser

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

func (*Controller) DeleteBranch

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

func (*Controller) DeleteBranchProtectionRule

func (c *Controller) DeleteBranchProtectionRule(w http.ResponseWriter, r *http.Request, body DeleteBranchProtectionRuleJSONRequestBody, repository string)

func (*Controller) DeleteCredentials

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

func (*Controller) DeleteGarbageCollectionRules

func (c *Controller) DeleteGarbageCollectionRules(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 string, userID string)

func (*Controller) DeleteObject

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

func (*Controller) DeleteObjects

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

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)

func (*Controller) DeleteTag

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

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 string, policyID string)

func (*Controller) DetachPolicyFromUser

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

func (*Controller) DiffBranch

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

func (*Controller) DiffRefs

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

func (*Controller) DumpRefs

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

func (*Controller) ExpandTemplate

func (c *Controller) ExpandTemplate(w http.ResponseWriter, r *http.Request, templateLocation string, p ExpandTemplateParams)

func (*Controller) ForgotPassword

func (c *Controller) ForgotPassword(w http.ResponseWriter, r *http.Request, body ForgotPasswordJSONRequestBody)

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 string, 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 string, commitID string)

func (*Controller) GetCredentials

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

func (*Controller) GetCurrentUser

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

func (*Controller) GetGarbageCollectionRules

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

func (*Controller) GetGroup

func (c *Controller) GetGroup(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 string, metaRange string)

func (*Controller) GetObject

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

func (*Controller) GetPhysicalAddress

func (c *Controller) GetPhysicalAddress(w http.ResponseWriter, r *http.Request, repository string, branch string, params 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 string, pRange string)

func (*Controller) GetRepository

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

func (*Controller) GetRun

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

func (*Controller) GetRunHookOutput

func (c *Controller) GetRunHookOutput(w http.ResponseWriter, r *http.Request, repository string, runID string, 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 string, tag string)

func (*Controller) GetUnderlyingProperties

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

func (*Controller) GetUser

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

func (*Controller) HeadObject

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

func (*Controller) HealthCheck

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

func (*Controller) IngestRange

func (c *Controller) IngestRange(w http.ResponseWriter, r *http.Request, body IngestRangeJSONRequestBody, repository string)

func (*Controller) LinkPhysicalAddress

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

func (*Controller) ListBranches

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

func (*Controller) ListGroupMembers

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

func (*Controller) ListGroupPolicies

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

func (*Controller) ListGroups

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

func (*Controller) ListObjects

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

func (*Controller) ListPolicies

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

func (*Controller) ListRepositories

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

func (*Controller) ListRepositoryRuns

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

func (*Controller) ListRunHooks

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

func (*Controller) ListTags

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

func (*Controller) ListUserCredentials

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

func (*Controller) ListUserGroups

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

func (*Controller) ListUserPolicies

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

func (*Controller) ListUsers

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

func (*Controller) LogAction

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

func (*Controller) LogBranchCommits

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

LogBranchCommits deprecated replaced by LogCommits

func (*Controller) LogCommits

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

func (*Controller) Login

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

func (*Controller) MergeIntoBranch

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

func (*Controller) OauthCallback

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

OauthCallback gets a code generated by an OIDC provider. It exchanges the code for an id token, and saves the claims from the ID token on a session.

func (*Controller) PrepareGarbageCollectionCommits

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

func (*Controller) PrepareGarbageCollectionUncommitted

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

func (*Controller) ResetBranch

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

func (*Controller) RestoreRefs

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

func (*Controller) RevertBranch

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

func (*Controller) SetGarbageCollectionRules

func (c *Controller) SetGarbageCollectionRules(w http.ResponseWriter, r *http.Request, body SetGarbageCollectionRulesJSONRequestBody, repository string)

func (*Controller) Setup

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

func (*Controller) SetupCommPrefs

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

func (*Controller) StageObject

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

func (*Controller) StatObject

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

func (*Controller) UpdatePassword

func (c *Controller) UpdatePassword(w http.ResponseWriter, r *http.Request, body UpdatePasswordJSONRequestBody)

func (*Controller) UpdatePolicy

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

func (*Controller) UploadObject

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

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
}