storage_handler

package
v0.0.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 5, 2025 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterHandlers 

func RegisterHandlers(server *server.Server, grp *huma.Group)

Types

type CreatePVCInput 

type CreatePVCInput struct {
	server.BaseAuthInput
	Body *models.CreatePVCInput
}

type CreatePVCResponse 

type CreatePVCResponse struct {
	Body struct {
		Data *models.PVCInfo `json:"data"`
	}
}

type CreateS3Input 

type CreateS3Input struct {
	server.BaseAuthInput
	Body *models.S3BackendCreateInput
}

type CreateS3Output 

type CreateS3Output struct {
	Body struct {
		Data *models.S3Response `json:"data"`
	}
}

type DeletePVCInput 

type DeletePVCInput struct {
	server.BaseAuthInput
	Body *models.DeletePVCInput
}

type DeletePVCResponse 

type DeletePVCResponse struct {
	Body struct {
		Data server.DeletedResponse `json:"data"`
	}
}

type DeleteS3SourceByIDInput 

type DeleteS3SourceByIDInput struct {
	server.BaseAuthInput
	Body struct {
		ID     uuid.UUID `json:"id" format:"uuid" required:"true"`
		TeamID uuid.UUID `json:"team_id" format:"uuid" required:"true"`
	}
}

type DeleteS3SourceByIDOutput 

type DeleteS3SourceByIDOutput struct {
	Body struct {
		Data server.DeletedResponse `json:"data"`
	}
}

type GetPVCInput 

type GetPVCInput struct {
	server.BaseAuthInput
	models.GetPVCInput
}

* get by ID

type GetPVCResponse 

type GetPVCResponse struct {
	Body struct {
		Data *models.PVCInfo `json:"data"`
	}
}

type GetS3SourceByIDInput 

type GetS3SourceByIDInput struct {
	server.BaseAuthInput
	ID          uuid.UUID `query:"id" format:"uuid" required:"true"`
	TeamID      uuid.UUID `query:"team_id" format:"uuid" required:"true"`
	WithBuckets bool      `query:"with_buckets"`
}

type GetS3SourceByIDOutput 

type GetS3SourceByIDOutput struct {
	Body struct {
		Data *models.S3Response `json:"data"`
	}
}

type HandlerGroup 

type HandlerGroup struct {
	// contains filtered or unexported fields
}

func (*HandlerGroup) CreatePVC 

func (self *HandlerGroup) CreatePVC(ctx context.Context, input *CreatePVCInput) (*CreatePVCResponse, error)

func (*HandlerGroup) CreateS3 

func (self *HandlerGroup) CreateS3(ctx context.Context, input *CreateS3Input) (*CreateS3Output, error)

func (*HandlerGroup) DeletePVC 

func (self *HandlerGroup) DeletePVC(ctx context.Context, input *DeletePVCInput) (*DeletePVCResponse, error)

func (*HandlerGroup) DeleteS3Source 

func (self *HandlerGroup) DeleteS3Source(ctx context.Context, input *DeleteS3SourceByIDInput) (*DeleteS3SourceByIDOutput, error)

func (*HandlerGroup) GetPVC 

func (self *HandlerGroup) GetPVC(ctx context.Context, input *GetPVCInput) (*GetPVCResponse, error)

func (*HandlerGroup) GetS3SourceByID 

func (self *HandlerGroup) GetS3SourceByID(ctx context.Context, input *GetS3SourceByIDInput) (*GetS3SourceByIDOutput, error)

func (*HandlerGroup) ListPVCs 

func (self *HandlerGroup) ListPVCs(ctx context.Context, input *ListPVCInput) (*ListPVCResponse, error)

func (*HandlerGroup) ListS3Source 

func (self *HandlerGroup) ListS3Source(ctx context.Context, input *ListS3SourceInput) (*ListS3SourceOutput, error)

func (*HandlerGroup) TestS3Access 

func (self *HandlerGroup) TestS3Access(ctx context.Context, input *TestS3AccessInput) (*TestS3Output, error)

func (*HandlerGroup) UpdatePVC 

func (self *HandlerGroup) UpdatePVC(ctx context.Context, input *UpdatePVCInput) (*UpdatePVCResponse, error)

func (*HandlerGroup) UpdateS3Source 

func (self *HandlerGroup) UpdateS3Source(ctx context.Context, input *UpdateS3SourceInput) (*UpdateS3SourceResponse, error)

type ListPVCInput 

type ListPVCInput struct {
	server.BaseAuthInput
	models.ListPVCInput
}

type ListPVCResponse 

type ListPVCResponse struct {
	Body struct {
		Data []*models.PVCInfo `json:"data" nullable:"false"`
	}
}

type ListS3SourceInput 

type ListS3SourceInput struct {
	server.BaseAuthInput
	TeamID      uuid.UUID `query:"team_id" format:"uuid" required:"true"`
	WithBuckets bool      `query:"with_buckets"`
}

type ListS3SourceOutput 

type ListS3SourceOutput struct {
	Body struct {
		Data []*models.S3Response `json:"data" nullable:"false"`
	}
}

type S3TestResult 

type S3TestResult struct {
	Valid bool   `json:"valid"`
	Error string `json:"error,omitempty"`
}

type TestS3AccessInput 

type TestS3AccessInput struct {
	server.BaseAuthInput
	Body struct {
		Endpoint    string `json:"endpoint" required:"true"`
		Region      string `json:"region" required:"true"`
		AccessKeyID string `json:"access_key_id" required:"true"`
		SecretKey   string `json:"secret_key" required:"true"`
	}
}

Test that S3 credentials are valid and can be used to list buckets and RW buckets

type TestS3Output 

type TestS3Output struct {
	Body struct {
		Data *S3TestResult `json:"data"`
	}
}

type UpdatePVCInput 

type UpdatePVCInput struct {
	server.BaseAuthInput
	Body *models.UpdatePVCInput
}

type UpdatePVCResponse 

type UpdatePVCResponse struct {
	Body struct {
		Data *models.PVCInfo `json:"data"`
	}
}

type UpdateS3SourceInput 

type UpdateS3SourceInput struct {
	server.BaseAuthInput
	Body struct {
		ID          uuid.UUID `json:"id" format:"uuid" required:"true"`
		TeamID      uuid.UUID `json:"team_id" format:"uuid" required:"true"`
		Name        *string   `json:"name,omitempty" required:"false" minLength:"1"`
		AccessKeyID *string   `json:"access_key_id,omitempty" required:"false" minLength:"1"`
		SecretKey   *string   `json:"secret_key,omitempty" required:"false" minLength:"1"`
	}
}

type UpdateS3SourceResponse 

type UpdateS3SourceResponse struct {
	Body struct {
		Data *models.S3Response `json:"data"`
	}
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.