caboose

Aug 24, 2023

Changes in this version

+ const DefaultSaturnMirrorRequestTimeout

type ErrInvalidResponse

+ Message string

+ func (e ErrInvalidResponse) Error() string

Jul 11, 2023

Changes in this version

+ const DefaultComplianceCidPeriod

type Config

+ ComplianceCidPeriod int64

+ OrchestratorOverride []tieredhashing.NodeInfo

+ type ErrInvalidResponse error

May 24, 2023

Changes in this version

+ const BackendOverrideKey

+ const DefaultMirrorFraction

+ const SaturnEnvKey

type Config

+ MirrorFraction float64

May 2, 2023

Changes in this version

+ const DefaultFetchKeyCoolDownDuration

+ const DefaultLoggingInterval

+ const DefaultMaxFetchFailures

+ const DefaultMaxRetries

+ const DefaultOrchestratorEndpoint

+ const DefaultPoolRefreshInterval

+ const DefaultSaturnBlockRequestTimeout

+ const DefaultSaturnCarRequestTimeout

+ const DefaultSaturnNodeCoolOff

+ const DefaultSaturnOrchestratorRequestTimeout

+ const EnvironmentKey

+ var CabooseMetrics = prometheus.NewRegistry()

+ var ErrBackendFailed error = errors.New("saturn backend failed")

+ var ErrContentProviderNotFound error = errors.New("saturn failed to find content providers")

+ var ErrNoBackend error = errors.New("no available saturn backend")

+ var ErrNotImplemented error = errors.New("not implemented")

+ var ErrSaturnTimeout error = errors.New("saturn backend timed out")

+ type Caboose struct

+ func NewCaboose(config *Config) (*Caboose, error)

+ func (c *Caboose) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

+ func (c *Caboose) Close()

+ func (c *Caboose) DeleteBlock(context.Context, cid.Cid) error

+ func (c *Caboose) Fetch(ctx context.Context, path string, cb DataCallback) error

+ func (c *Caboose) Get(ctx context.Context, it cid.Cid) (blocks.Block, error)

+ func (c *Caboose) GetPoolPerf() map[string]*tieredhashing.NodePerf

+ func (c *Caboose) GetSize(ctx context.Context, it cid.Cid) (int, error)

+ func (c *Caboose) Has(ctx context.Context, it cid.Cid) (bool, error)

+ func (c *Caboose) HashOnRead(enabled bool)

+ func (c *Caboose) Put(context.Context, blocks.Block) error

+ func (c *Caboose) PutMany(context.Context, []blocks.Block) error

+ type Config struct

+ AffinityKey string

+ DoValidation bool

+ ExtraHeaders *http.Header

+ FetchKeyCoolDownDuration time.Duration

+ LoggingClient *http.Client

+ LoggingEndpoint url.URL

+ LoggingInterval time.Duration

+ MaxFetchFailuresBeforeCoolDown int

+ MaxRetrievalAttempts int

+ OrchestratorClient *http.Client

+ OrchestratorEndpoint *url.URL

+ PoolRefresh time.Duration

+ SaturnClient *http.Client

+ SaturnNodeCoolOff time.Duration

+ TieredHashingOpts []tieredhashing.Option

+ type DataCallback func(resource string, reader io.Reader) error

+ type ErrCoolDown struct

+ Cid cid.Cid

+ Path string

+ func (e *ErrCoolDown) Error() string

+ func (e *ErrCoolDown) RetryAfter() time.Duration

+ type ErrPartialResponse struct

+ StillNeed []string

+ func (epr ErrPartialResponse) Error() string

+ type ErrSaturnTooManyRequests struct

+ Node string

+ func (e *ErrSaturnTooManyRequests) Error() string

+ func (e *ErrSaturnTooManyRequests) RetryAfter() time.Duration

+ type TrackingReader struct

+ func (tr *TrackingReader) Read(buf []byte) (int, error)