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

array

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 ErrSystem

+ func AssembleFinalOutputs(ctx context.Context, assemblyQueue OutputAssembler, ...) (*arrayCore.State, error)

+ func CatalogBitsetToLiteralCollection(catalogResults *bitarray.BitSet, size int) *idlCore.LiteralCollection

+ func CheckTaskOutput(ctx context.Context, dataStore *storage.DataStore, ...) (core.Phase, error)

+ func ConstructCatalogReaderWorkItems(ctx context.Context, taskReader core.TaskReader, inputs []io.InputReader, ...) ([]catalog.DownloadRequest, error)

+ func ConstructCatalogUploadRequests(keyId idlCore.Identifier, taskExecId idlCore.TaskExecutionIdentifier, ...) ([]catalog.UploadRequest, error)

+ func ConstructInputReaders(ctx context.Context, dataStore *storage.DataStore, ...) ([]io.InputReader, error)

+ func ConstructOutputReader(ctx context.Context, dataStore *storage.DataStore, ...) (io.OutputReader, error)

+ func ConstructOutputReaders(ctx context.Context, dataStore *storage.DataStore, ...) ([]io.OutputReader, error)

+ func ConstructOutputWriter(ctx context.Context, dataStore *storage.DataStore, ...) (io.OutputWriter, error)

+ func ConstructOutputWriters(ctx context.Context, dataStore *storage.DataStore, ...) ([]io.OutputWriter, error)

+ func DetermineDiscoverability(ctx context.Context, tCtx core.TaskExecutionContext, state *arrayCore.State) (*arrayCore.State, error)

+ func NewLiteralScalarOfInteger(number int64) *idlCore.Literal

+ func RunArrayTestsEndToEnd(t *testing.T, executor core.Plugin, iter AdvanceIteration)

+ func WriteToCatalog(ctx context.Context, ownerSignal core.SignalAsync, ...) (bool, error)

+ func WriteToDiscovery(ctx context.Context, tCtx core.TaskExecutionContext, state *arrayCore.State, ...) (*arrayCore.State, error)

+ type AdvanceIteration func(ctx context.Context, tCtx core.TaskExecutionContext) error

+ type OutputAssembler struct

+ func NewErrorAssembler(maxErrorMessageLength int, workQueueConfig workqueue.Config, ...) (OutputAssembler, error)

+ func NewOutputAssembler(workQueueConfig workqueue.Config, scope promutils.Scope) (OutputAssembler, error)

+ func (o OutputAssembler) Queue(ctx context.Context, id workqueue.WorkItemID, item *outputAssembleItem) error