proxy.golang.org : github.com/mongodb/amboy : v0.0.0-20230531003022-893b6e6ffe79
Package amboy provides basic infrastructure for running and describing jobs and job workflows with, potentially, minimal overhead and additional complexity. Amboy works with 4 basic logical objects: jobs representing work; runners, which are responsible for executing jobs; queues, that represent pipelines and offline workflows of jobs (i.e. not real time, processes that run outside of the primary execution path of a program); and dependencies that represent relationships between jobs. The inspiration for amboy was to be able to provide a unified way to define and run jobs, that would feel equally "native" for distributed applications and distributed web application, and move easily between different architectures. While amboy users will generally implement their own Job and dependency implementations, Amboy itself provides several example Queue implementations, as well as several generic examples and prototypes of Job and dependency.Manager objects. Generally speaking you should be able to use included amboy components to provide the queue and runner components, in conjunction with custom and generic job and dependency variations. Consider the following example: The amboy package proves a number of generic methods that, using the Queue.Stats() method, block until all jobs are complete. They provide different semantics, which may be useful in different circumstances. All of the Wait* functions wait until the total number of jobs submitted to the queue is equal to the number of completed jobs, and as a result these methods don't prevent other threads from adding jobs to the queue after beginning to wait. As a special case, retryable queues will also wait until there are no retrying jobs remaining. Additionally, there are a set of methods, WaitJob*, that allow callers to wait for a specific job to complete.
Registry -
Documentation -
Download -
JSON -
codemeta.json
purl: pkg:golang/github.com/mongodb/amboy@v0.0.0-20230531003022-893b6e6ffe79
Published:
Indexed:
- github.com/PuerkitoBio/rehttp v1.1.0
- github.com/VividCortex/ewma v1.2.0
- github.com/andygrunwald/go-jira v1.14.0
- github.com/aws/aws-sdk-go v1.44.127
- github.com/bluele/slack v0.0.0-20180528010058-b4b4d354a079
- github.com/cheynewallace/tabby v1.1.1
- github.com/coreos/go-systemd v0.0.0-20191104093116-d3cd4ed1dbcf
- github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d
- github.com/davecgh/go-spew v1.1.1
- github.com/dghubble/oauth1 v0.7.1
- github.com/evergreen-ci/aviation v0.0.0-20220405151811-ff4a78a4297c
- github.com/evergreen-ci/birch v0.0.0-20220401151432-c792c3d8e0eb
- github.com/evergreen-ci/gimlet v0.0.0-20220401151443-33c830c51cee
- github.com/evergreen-ci/negroni v1.0.1-0.20211028183800-67b6d7c2c035
- github.com/evergreen-ci/pail v0.0.0-20220405154537-920afff49d92
- github.com/evergreen-ci/poplar v0.0.0-20220405164038-0cfe3198c320
- github.com/evergreen-ci/utility v0.0.0-20230519193518-4d91d64f59fb
- github.com/fatih/structs v1.1.0
- github.com/fsnotify/fsnotify v1.5.1
- github.com/fuyufjh/splunk-hec-go v0.3.4-0.20210909061418-feecd03924b7
- github.com/go-logr/logr v1.2.4
- github.com/go-logr/stdr v1.2.2
- github.com/go-ole/go-ole v1.2.6
- github.com/golang-jwt/jwt v3.2.2+incompatible
- github.com/golang/protobuf v1.5.2
- github.com/golang/snappy v0.0.4
- github.com/google/go-github v17.0.0+incompatible
- github.com/google/go-querystring v1.1.0
- github.com/google/uuid v1.3.0
- github.com/gorilla/mux v1.8.0
- github.com/jmespath/go-jmespath v0.4.0
- github.com/jpillora/backoff v1.0.0
- github.com/klauspost/compress v1.13.6
- github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0
- github.com/mattn/go-xmpp v0.0.0-20211029151415-912ba614897a
- github.com/mongodb/ftdc v0.0.0-20220401165013-13e4af55e809
- github.com/mongodb/grip v0.0.0-20220401165023-6a1d9bb90c21
- github.com/montanaflynn/stats v0.0.0-20180911141734-db72e6cae808
- github.com/papertrail/go-tail v0.0.0-20180509224916-973c153b0431
- github.com/phyber/negroni-gzip v1.0.0
- github.com/pkg/errors v0.9.1
- github.com/pmezard/go-difflib v1.0.0
- github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c
- github.com/rs/cors v1.8.2
- github.com/russross/blackfriday/v2 v2.0.1
- github.com/sabhiram/go-gitignore v0.0.0-20210923224102-525f6e181f06
- github.com/shirou/gopsutil/v3 v3.22.3
- github.com/shurcooL/sanitized_anchor_name v1.0.0
- github.com/stretchr/testify v1.8.2
- github.com/tklauser/go-sysconf v0.3.10
- github.com/tklauser/numcpus v0.4.0
- github.com/trivago/tgo v1.0.7
- github.com/urfave/cli v1.22.10
- github.com/urfave/negroni v1.0.0
- github.com/xdg-go/pbkdf2 v1.0.0
- github.com/xdg-go/scram v1.1.1
- github.com/xdg-go/stringprep v1.0.3
- github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a
- github.com/yusufpapurcu/wmi v1.2.2
- go.mongodb.org/mongo-driver v1.11.1
- go.opentelemetry.io/otel v1.15.1
- go.opentelemetry.io/otel/sdk v1.15.1
- go.opentelemetry.io/otel/trace v1.15.1
- golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d
- golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd
- golang.org/x/oauth2 v0.0.0-20211028175245-ba495a64dcb5
- golang.org/x/sync v0.0.0-20210220032951-036812b2e83c
- golang.org/x/sys v0.7.0
- golang.org/x/text v0.3.7
- google.golang.org/appengine v1.6.7
- google.golang.org/genproto v0.0.0-20211101144312-62acf1d99145
- google.golang.org/grpc v1.45.0
- google.golang.org/protobuf v1.28.0
- gopkg.in/mgo.v2 v2.0.0-20190816093944-a6b53ec6cb22
- gopkg.in/yaml.v2 v2.4.0
- gopkg.in/yaml.v3 v3.0.1