Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

goseaweedfs

package module

Go to main page

Versions in this module

v0

v0.1.6

May 17, 2022

v0.1.5

Mar 10, 2020

v0.1.4

Nov 26, 2019

v0.1.3

Nov 20, 2019

Changes in this version

+ type AssignResult struct

+ Count uint64

+ Error string

+ FileID string

+ PublicURL string

+ URL string

+ type ChunkInfo struct

+ Fid string

+ Offset int64

+ Size int64

+ type ChunkManifest struct

+ Chunks []*ChunkInfo

+ Mime string

+ Name string

+ Size int64

+ func (c *ChunkManifest) Marshal() ([]byte, error)

+ type ClusterStatus struct

+ IsLeader bool

+ Leader string

+ Peers []string

+ type DataCenter struct

+ Free int

+ Max int

+ Racks []*Rack

+ type DataNode struct

+ Free int

+ Max int

+ PublicURL string

+ URL string

+ Volumes int

+ type FilePart struct

+ Collection string

+ FileID string

+ FileName string

+ FileSize int64

+ MimeType string

+ ModTime int64

+ Reader io.ReadCloser

+ Server string

+ TTL string

+ func NewFilePart(fullPathFilename string) (*FilePart, error)

+ func NewFilePartFromReader(reader io.ReadCloser, fileName string, fileSize int64) *FilePart

+ func NewFileParts(fullPathFilenames []string) (ret []*FilePart, err error)

+ func (f *FilePart) Close() (err error)

+ type Filer struct

+ func NewFiler(u string, client *http.Client) (f *Filer, err error)

+ func (f *Filer) Close() (err error)

+ func (f *Filer) Delete(path string, args url.Values) (err error)

+ func (f *Filer) Download(path string, args url.Values, callback func(io.Reader) error) (err error)

+ func (f *Filer) Get(path string, args url.Values, header map[string]string) (data []byte, statusCode int, err error)

+ func (f *Filer) Upload(localFilePath, newPath, collection, ttl string) (result *FilerUploadResult, err error)

+ func (f *Filer) UploadFile(content io.Reader, fileSize int64, newPath, collection, ttl string) (result *FilerUploadResult, err error)

+ type FilerUploadResult struct

+ Error string

+ FileID string

+ FileURL string

+ Name string

+ Size int64

+ type Layout struct

+ Replication string

+ Writables []uint64

+ type LookupResult struct

+ Error string

+ VolumeLocations VolumeLocations

+ type Rack struct

+ DataNodes []*DataNode

+ Free int

+ Max int

type Seaweed

+ func (c *Seaweed) Close() (err error)

+ func (c *Seaweed) Download(fileID string, args url.Values, callback func(io.Reader) error) (fileName string, err error)

+ type SubmitResult struct

+ Error string

+ FileID string

+ FileName string

+ FileURL string

+ Size int64

+ type SystemStatus struct

+ Error string

+ Topology Topology

+ Version string

+ type Topology struct

+ DataCenters []*DataCenter

+ Free int

+ Layouts []*Layout

+ Max int

+ type UploadResult struct

+ Error string

+ Name string

+ Size int64

+ type VolumeLocation struct

+ PublicURL string

+ URL string

+ type VolumeLocations []*VolumeLocation

+ func (c VolumeLocations) Head() *VolumeLocation

+ func (c VolumeLocations) RandomPickForRead() *VolumeLocation

v0.1.1

Feb 7, 2019

Changes in this version

+ const ParamAssignCount

+ const ParamAssignDataCenter

+ const ParamAssignReplication

+ const ParamCollection

+ const ParamCount

+ const ParamGrowCollection

+ const ParamGrowCount

+ const ParamGrowDataCenter

+ const ParamGrowReplication

+ const ParamGrowTTL

+ const ParamLookupCollection

+ const ParamLookupPretty

+ const ParamLookupVolumeID

+ const ParamTTL

+ const ParamVacuumGarbageThreshold

+ var ErrFileNotFound = fmt.Errorf("File not found")

+ type Seaweed struct

+ ChunkSize int64

+ Client *libs.HTTPClient

+ Filers []*model.Filer

+ Master string

+ Scheme string

+ func NewSeaweed(scheme string, master string, filers []string, chunkSize int64, ...) *Seaweed

+ func (c *Seaweed) Assign(args url.Values) (result *model.AssignResult, err error)

+ func (c *Seaweed) BatchUploadFileParts(files []*model.FilePart, collection string, ttl string) ([]*model.SubmitResult, error)

+ func (c *Seaweed) BatchUploadFiles(files []string, collection, ttl string) ([]*model.SubmitResult, error)

+ func (c *Seaweed) ClusterStatus() (result *model.ClusterStatus, err error)

+ func (c *Seaweed) DeleteChunks(cm *model.ChunkManifest, args url.Values) (err error)

+ func (c *Seaweed) DeleteFile(fileID string, args url.Values) (err error)

+ func (c *Seaweed) DownloadFile(fileID string, args url.Values) (string, []byte, error)

+ func (c *Seaweed) GC(threshold float64) (err error)

+ func (c *Seaweed) Grow(count int, collection, replication, dataCenter string) error

+ func (c *Seaweed) GrowArgs(args url.Values) (err error)

+ func (c *Seaweed) Lookup(volID string, args url.Values) (result *model.LookupResult, err error)

+ func (c *Seaweed) LookupFileID(fileID string, args url.Values, readonly bool) (fullURL string, err error)

+ func (c *Seaweed) LookupNoCache(volID string, args url.Values) (result *model.LookupResult, err error)

+ func (c *Seaweed) LookupServerByFileID(fileID string, args url.Values, readonly bool) (server string, err error)

+ func (c *Seaweed) LookupVolumeIDs(volIDs []string) (result map[string]*model.LookupResult, err error)

+ func (c *Seaweed) Replace(fileID string, fileReader io.Reader, fileName string, size int64, ...) (err error)

+ func (c *Seaweed) ReplaceFile(fileID, filePath string, deleteFirst bool) error

+ func (c *Seaweed) ReplaceFilePart(f *model.FilePart, deleteFirst bool) (fileID string, err error)

+ func (c *Seaweed) Status() (result *model.SystemStatus, err error)

+ func (c *Seaweed) Submit(filePath string, collection, ttl string) (result *model.SubmitResult, err error)

+ func (c *Seaweed) SubmitFilePart(f *model.FilePart, args url.Values) (result *model.SubmitResult, err error)

+ func (c *Seaweed) Upload(fileReader io.Reader, fileName string, size int64, collection, ttl string) (fp *model.FilePart, fileID string, err error)

+ func (c *Seaweed) UploadFile(filePath string, collection, ttl string) (cm *model.ChunkManifest, fp *model.FilePart, fileID string, err error)

+ func (c *Seaweed) UploadFilePart(f *model.FilePart) (cm *model.ChunkManifest, fileID string, err error)