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

catalog

package

Go to main page

Versions in this module

v0

v0.2.2

Nov 16, 2019

v0.2.1

Nov 13, 2019

v0.2.0

Nov 11, 2019

Changes in this version

+ const ErrResponseNotReady

+ const ErrSystemError

+ func IsNotFound(err error) bool

+ func NewWriterProcessor(catalogClient Client) workqueue.Processor

+ type AsyncClient interface

+ Download func(ctx context.Context, requests ...DownloadRequest) (outputFuture DownloadFuture, err error)

+ Upload func(ctx context.Context, requests ...UploadRequest) (putFuture UploadFuture, err error)

+ type AsyncClientImpl struct

+ Reader workqueue.IndexedWorkQueue

+ Writer workqueue.IndexedWorkQueue

+ func NewAsyncClient(client Client, cfg Config, scope promutils.Scope) (AsyncClientImpl, error)

+ func (c AsyncClientImpl) Download(ctx context.Context, requests ...DownloadRequest) (outputFuture DownloadFuture, err error)

+ func (c AsyncClientImpl) Start(ctx context.Context) error

+ func (c AsyncClientImpl) Upload(ctx context.Context, requests ...UploadRequest) (putFuture UploadFuture, err error)

+ type Client interface

+ Get func(ctx context.Context, key Key) (io.OutputReader, error)

+ Put func(ctx context.Context, key Key, reader io.OutputReader, metadata Metadata) error

+ type Config struct

+ ReaderWorkqueueConfig workqueue.Config

+ WriterWorkqueueConfig workqueue.Config

+ func GetConfig() *Config

+ func (cfg Config) GetPFlagSet(prefix string) *pflag.FlagSet

+ type DownloadFuture interface

+ GetResponse func() (DownloadResponse, error)

+ type DownloadRequest struct

+ Key Key

+ Target io.OutputWriter

+ type DownloadResponse interface

+ GetCachedCount func() int

+ GetCachedResults func() *bitarray.BitSet

+ GetResultsSize func() int

+ type Future interface

+ GetResponseError func() error

+ GetResponseStatus func() ResponseStatus

+ OnReady func(handler ReadyHandler)

+ type Key struct

+ CacheVersion string

+ Identifier core.Identifier

+ InputReader io.InputReader

+ TypedInterface core.TypedInterface

+ func (k Key) String() string

+ type Metadata struct

+ NodeExecutionIdentifier *core.NodeExecutionIdentifier

+ TaskExecutionIdentifier *core.TaskExecutionIdentifier

+ WorkflowExecutionIdentifier *core.WorkflowExecutionIdentifier

+ type ReaderProcessor struct

+ func NewReaderProcessor(catalogClient Client) ReaderProcessor

+ func (p ReaderProcessor) Process(ctx context.Context, workItem workqueue.WorkItem) (workqueue.WorkStatus, error)

+ type ReaderWorkItem struct

+ func NewReaderWorkItem(key Key, outputsWriter io.OutputWriter) *ReaderWorkItem

+ func (item ReaderWorkItem) IsCached() bool

+ type ReadyHandler func(ctx context.Context, future Future)

+ type ResponseStatus uint8

+ const ResponseStatusNotReady

+ const ResponseStatusReady

+ type UploadFuture interface

+ type UploadRequest struct

+ ArtifactData io.OutputReader

+ ArtifactMetadata Metadata

+ Key Key

+ type WriterWorkItem struct

+ func NewWriterWorkItem(key Key, data io.OutputReader, metadata Metadata) *WriterWorkItem