objectstorage

Documentation

Index

• Constants
• Variables
• type GetObjectQuery
• type ObjectParams
• type ObjectStorage
  • func New(cfg *config.DaemonOption, dynconfig config.Dynconfig, ...) (ObjectStorage, error)
• type PutObjectRequset

Constants

const (
	// AsyncWriteBack writes the object asynchronously to the backend.
	AsyncWriteBack = iota

	// WriteBack writes the object synchronously to the backend.
	WriteBack

	// Ephemeral only writes the object to the dfdaemon.
	// It is only provided for creating temporary objects between peers,
	// and users are not allowed to use this mode.
	Ephemeral
)

const (
	PrometheusSubsystemName = "dragonfly_dfdaemon_object_stroage"
	OtelServiceName         = "dragonfly-dfdaemon-object-storage"
)

Variables

var GinLogFileName = "gin-object-stroage.log"

Types

type GetObjectQuery

type GetObjectQuery struct {
	Filter string `form:"filter" binding:"omitempty"`
}

type ObjectParams

type ObjectParams struct {
	ID        string `uri:"id" binding:"required"`
	ObjectKey string `uri:"object_key" binding:"required"`
}

type ObjectStorage

type ObjectStorage interface {
	// Started object storage server.
	Serve(lis net.Listener) error

	// Stop object storage server.
	Stop() error
}

ObjectStorage is the interface used for object storage server.

func New

func New(cfg *config.DaemonOption, dynconfig config.Dynconfig, peerTaskManager peer.TaskManager, storageManager storage.Manager, logDir string) (ObjectStorage, error)

New returns a new ObjectStorage instence.

type PutObjectRequset

type PutObjectRequset struct {
	Mode        uint                  `form:"mode,default=0" binding:"omitempty,gte=0,lte=2"`
	Filter      string                `form:"filter" binding:"omitempty"`
	MaxReplicas int                   `form:"maxReplicas" binding:"omitempty,gt=0,lte=100"`
	File        *multipart.FileHeader `form:"file" binding:"required"`
}