Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

singularity

package

Go to main page

Versions in this module

v0

v0.2.3

Nov 9, 2023

Changes in this version

type Option

+ func WithMinFreeSpace(space int64) Option

v0.2.2

Nov 3, 2023

Changes in this version

type Option

+ func WithForcePackAfter(d time.Duration) Option

+ type Reader struct

+ func NewReader(client *singularityclient.SingularityAPI, fileID uint64, size int64) *Reader

+ func (r *Reader) Close() error

+ func (r *Reader) Read(p []byte) (int, error)

+ func (r *Reader) Seek(offset int64, whence int) (int64, error)

+ func (r *Reader) WriteTo(w io.Writer) (int64, error)

+ func (r *Reader) WriteToN(w io.Writer, readLen int64) (int64, error)

+ type Store struct

+ func (s *Store) Describe(ctx context.Context, id blob.ID) (*blob.Descriptor, error)

+ func (s *Store) Get(ctx context.Context, id blob.ID) (io.ReadSeekCloser, error)

+ func (s *Store) PassGet(w http.ResponseWriter, r *http.Request, id blob.ID)

+ func (s *Store) Put(ctx context.Context, reader io.ReadCloser) (*blob.Descriptor, error)

+ func (s *Store) Shutdown(ctx context.Context) error

+ func (s *Store) Start(ctx context.Context) error

v0.2.1

Oct 5, 2023

Changes in this version

+ const PutQueueSize

type Option

+ func WithCleanupInterval(v time.Duration) Option

+ func WithPreparationName(n string) Option

+ type SingularityReader struct

+ func (r *SingularityReader) Close() error

+ func (r *SingularityReader) Read(p []byte) (int, error)

+ func (r *SingularityReader) Seek(offset int64, whence int) (int64, error)

v0.2.0

Sep 8, 2023

Changes in this version

+ type Option func(*options) error

+ func WithDatasetName(n string) Option

+ func WithDealDuration(v abi.ChainEpoch) Option

+ func WithDealStartDelay(v abi.ChainEpoch) Option

+ func WithIPNIAnnounce(v bool) Option

+ func WithKeepUnsealed(v bool) Option

+ func WithMaxCarSize(s string) Option

+ func WithMaxPendingDealNumber(v int) Option

+ func WithMaxPendingDealSize(v string) Option

+ func WithPackThreshold(s int64) Option

+ func WithPricePerDeal(v abi.TokenAmount) Option

+ func WithPricePerGiB(v abi.TokenAmount) Option

+ func WithPricePerGiBEpoch(v abi.TokenAmount) Option

+ func WithReplicationFactor(r uint) Option

+ func WithScheduleCron(c string) Option

+ func WithScheduleCronPerpetual(v bool) Option

+ func WithScheduleDealNumber(n int) Option

+ func WithScheduleDealSize(v string) Option

+ func WithScheduleUrlTemplate(t string) Option

+ func WithSingularityClient(c client.Client) Option

+ func WithStorageProviders(sp ...address.Address) Option

+ func WithStoreDir(s string) Option

+ func WithTotalDealNumber(v int) Option

+ func WithTotalDealSize(v string) Option

+ func WithVerifiedDeal(v bool) Option

+ func WithWalletKey(wk string) Option

+ type SingularityStore struct

+ func NewStore(o ...Option) (*SingularityStore, error)

+ func (l *SingularityStore) Shutdown(ctx context.Context) error

+ func (l *SingularityStore) Start(ctx context.Context) error

+ func (s *SingularityStore) Describe(ctx context.Context, id blob.ID) (*blob.Descriptor, error)

+ func (s *SingularityStore) Get(ctx context.Context, id blob.ID) (io.ReadSeekCloser, error)

+ func (s *SingularityStore) Put(ctx context.Context, reader io.ReadCloser) (*blob.Descriptor, error)