object_storage

package
v1.128.0 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2026 License: MIT Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ObjectStorageMaxFileSizeBytes = 31 << 26

Functions

This section is empty.

Types

type DXObjectStorage 

type DXObjectStorage struct {
	Owner             *DXObjectStorageManager
	NameId            string
	ObjectStorageType DXObjectStorageType
	IsConfigured      bool
	Address           string
	UserName          string
	HasUserName       bool
	Password          string
	HasPassword       bool
	BasePath          string
	UseSSL            bool
	BucketName        string
	IsConnectAtStart  bool
	MustConnected     bool
	Connected         bool
	Context           context.Context
	Client            *minio.Client
}

func (*DXObjectStorage) ApplyFromConfiguration 

func (r *DXObjectStorage) ApplyFromConfiguration() (err error)

func (*DXObjectStorage) Connect 

func (r *DXObjectStorage) Connect() (err error)

func (*DXObjectStorage) Disconnect 

func (r *DXObjectStorage) Disconnect() (err error)

func (*DXObjectStorage) DownloadStream 

func (r *DXObjectStorage) DownloadStream(ctx context.Context, objectName string) (*minio.Object, error)

func (*DXObjectStorage) ReceiveStreamObject 

func (r *DXObjectStorage) ReceiveStreamObject(aepr *api.DXAPIEndPointRequest, filename string) (err error)

func (*DXObjectStorage) SendStreamObject 

func (r *DXObjectStorage) SendStreamObject(aepr *api.DXAPIEndPointRequest, filename string) (err error)

func (*DXObjectStorage) UploadStream 

func (r *DXObjectStorage) UploadStream(ctx context.Context, reader io.Reader, objectName string, originalFilename string, contentType string, disableMultipart bool, objectSize int64) (uploadInfo *minio.UploadInfo, err error)

type DXObjectStorageManager 

type DXObjectStorageManager struct {
	ObjectStorages map[string]*DXObjectStorage
}
var Manager DXObjectStorageManager

func (*DXObjectStorageManager) ConnectAll 

func (osm *DXObjectStorageManager) ConnectAll() (err error)

func (*DXObjectStorageManager) ConnectAllAtStart 

func (osm *DXObjectStorageManager) ConnectAllAtStart() (err error)

func (*DXObjectStorageManager) DisconnectAll 

func (osm *DXObjectStorageManager) DisconnectAll() (err error)

func (*DXObjectStorageManager) FindObjectStorageAndReceiveObject 

func (osm *DXObjectStorageManager) FindObjectStorageAndReceiveObject(aepr *api.DXAPIEndPointRequest, nameid string, filename string) (err error)

func (*DXObjectStorageManager) FindObjectStorageAndSendObject 

func (osm *DXObjectStorageManager) FindObjectStorageAndSendObject(aepr *api.DXAPIEndPointRequest, nameid string, filename string) (err error)

func (*DXObjectStorageManager) LoadFromConfiguration 

func (osm *DXObjectStorageManager) LoadFromConfiguration(configurationNameId string) (err error)

func (*DXObjectStorageManager) NewObjectStorage 

func (osm *DXObjectStorageManager) NewObjectStorage(nameId string, isConnectAtStart, mustConnected bool) *DXObjectStorage

type DXObjectStorageType 

type DXObjectStorageType int64
const (
	UnknownObjectStorageType DXObjectStorageType = iota
	Minio
)

func StringToDXObjectStorageType 

func StringToDXObjectStorageType(v string) DXObjectStorageType

func (DXObjectStorageType) String 

func (t DXObjectStorageType) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.