package
0.0.0-20240816234238-c0d581acaa8c
Repository: https://github.com/leaf-ai/studio-go-runner.git
Documentation: pkg.go.dev
# Functions
No description provided by the author
EntryPoint enables both test and standard production infrastructure to invoke this server.
FromProjectContext returns the User value stored in ctx, if any.
GetRqstSigs returns the signing public key struct for methods related to signature selection etc.
GetRspnsSigs returns the encryption public key struct for methods related to signature selection etc.
HandleMsg takes a message describing a queued task and handles the request, running and validating it in a blocking fashion.
Main is a production style main that will invoke the server as a go routine to allow a very simple supervisor and a test wrapper to coexist in terms of our logic.
NewProjectContext returns a new Context that carries a value for the project associated with the context.
NewQueuer will create a new task queue that will process the queue using the returned qr receiver.
NewTaskQueue is used to initiate processing for any of the types of queues the runner supports.
No description provided by the author
# Constants
ExecPythonVEnv indicates we are using the python virtualenv packaging.
ExecUnknown is an unused guard value.
# Variables
CacheActive is set to true if or when the caching system has been configured and is activated.
No description provided by the author
Spew contains the process wide configuration preferences for the structure dumping package.
TestMode will be set to true if the test flag is set during a build when the exe runs.
# Structs
Projects is used across several queuing modules for example the rabbitMQ server.
Queuer stores the data associated with a runner instances of a queue worker at the level of the queue itself.
No description provided by the author
SubRequest encapsulates the simple access details for a subscription.
SubsBusy is used to track subscriptions and queues that are currently being actively serviced by this runner.
Subscription is used to encapsulate the details of a single queue subscription including the resources that subscription has requested for its work in the past and how many instances of work units are currently being processed by this server
.
Subscriptions stores the known activate queues/subscriptions that this runner has observed
.
# Interfaces
Executor is an interface that defines a job handling worker implementation.