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

backend

package

Go to main page

Versions in this module

v0

v0.0.17

Jun 23, 2024

v0.0.16

Nov 23, 2023

v0.0.15

Oct 16, 2023

v0.0.14

Oct 5, 2023

Changes in this version

+ const RunnerHigh

+ const RunnerLabelDetector

+ const RunnerRegular

+ const StreamPrefix

+ func CollectConsumerInfo(nc *nats.Conn, streamName string) ([]*jetstream.ConsumerInfo, error)

+ func CollectStreamInfo(nc *nats.Conn, names []string) ([]*jetstream.StreamInfo, error)

+ func ConvertToHumanReadableDateType(timestamp *time.Time) string

+ func RenderConsumerInfo(consumers []*jetstream.ConsumerInfo) []byte

+ func RenderStreamInfo(streams []*jetstream.StreamInfo) []byte

+ func ReportStatus(nc *nats.Conn, name string, s Status, comments ...string)

+ func RunsOnSelfHosted(e *github.WorkflowJobEvent) (string, bool)

+ func UseHighPriorityRunner(gh *github.Client, org string, private bool) string

+ func UseRegularRunner(gh *github.Client, org string, private bool) string

+ type MachineStatus struct

+ Comment string

+ Name string

+ Status Status

+ Timestamp time.Time

+ func (ms MachineStatus) Strings() []string

type Manager

+ func (mgr *Manager) EnsureStreams(jsOpts ...jetstream.JetStreamOpt) error

+ func (mgr *Manager) ProcessCompletedJobs() error

+ func (mgr *Manager) ProcessCompletedJobs__() error

+ func (mgr *Manager) RunVMs()

+ type Status string

+ const StatusPicked

+ const StatusStarted

+ const StatusStarting

+ const StatusStopped

+ const StatusStopping

+ const StatusWaiting

+ type StatusReporter struct

+ func NewStatusReporter(nc *nats.Conn) (*StatusReporter, error)

+ func (sp *StatusReporter) GenerateHTMLReport() (string, error)

+ func (sp *StatusReporter) GenerateMarkdownReport() ([]byte, error)

v0.0.13

Aug 8, 2023

v0.0.12

May 29, 2023

v0.0.11

Mar 15, 2023

Changes in this version

+ const NatsConnectionRetryInterval

+ const NatsConnectionTimeout

+ const NatsRequestTimeout

+ const StreamName

+ func DefaultJobLabel(gh *github.Client, org string, private bool) string

+ func ErrorToAPIStatus(err error) *metav1.Status

+ func GRPCCode(err error) gcerrors.ErrorCode

+ func HTTPStatusFromCode(code gcerrors.ErrorCode) int32

+ func NewConnection(addr, credFile string) (nc *nats.Conn, err error)

+ func SubmitPayload(gh *github.Client, nc *nats.Conn, stream string, numMachines uint64, ...) error

+ type Manager struct

+ MachineID int

+ Provider api.Interface

+ func New(nc *nats.Conn, opts Options) *Manager

+ func (mgr *Manager) EnsureStream(jsmOpts ...nats.JSOpt) (nats.JetStreamContext, error)

+ func (mgr *Manager) ProcessCompletedMsg(payload []byte) (*github.WorkflowJobEvent, error)

+ func (mgr *Manager) ProcessQueuedMsg(slot any, payload []byte) (*github.WorkflowJobEvent, error)

+ func (mgr *Manager) Start(ctx context.Context, jsmOpts ...nats.JSOpt) error

+ type NATSOptions struct

+ Addr string

+ CredFile string

+ func NewNATSOptions() *NATSOptions

+ func (opts *NATSOptions) AddFlags(fs *pflag.FlagSet)

+ type Options struct

+ AckWait time.Duration

+ MachineID int

+ Name string

+ NumWorkers int

+ Provider string

+ Stream string

+ func DefaultOptions() Options

+ func (opts *Options) AddFlags(fs *pflag.FlagSet)