service

package

v0.0.0-...-0985497 Latest Latest Go to latest Published: Mar 20, 2024 License: GPL-3.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/infomark-org/infomark

Documentation ¶

Index ¶

type Config
- func NewConfig(config *configuration.RabbitMQConfiguration) *Config
type Consumer
- func NewConsumer(cfg *Config, handleFunc func(body []byte) error, instanceID int) (*Consumer, error)
type DockerService
- func NewDockerServiceWithTimeout(timeout time.Duration) (*DockerService, error)
type Producer
- func NewProducer(cfg *Config) (*Producer, error)
- func (c *Producer) Publish(body []byte) error
type Worker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Tag          string
	Connection   string
	Exchange     string
	ExchangeType string
	Queue        string
	Key          string
}

Config contains the settings for AMPQ

func NewConfig ¶

func NewConfig(config *configuration.RabbitMQConfiguration) *Config

type Consumer ¶

type Consumer struct {
	Config *Config
	// contains filtered or unexported fields
}

Consumer is an object which can act on AMPQ messages

func NewConsumer ¶

func NewConsumer(cfg *Config, handleFunc func(body []byte) error, instanceID int) (*Consumer, error)

NewConsumer creates new consumer which can act on AMPQ messages

func (*Consumer) HandleLoop ¶

func (c *Consumer) HandleLoop(deliveries <-chan amqp.Delivery)

HandleLoop is the message loop of a consumer

func (*Consumer) Setup ¶

func (c *Consumer) Setup() (<-chan amqp.Delivery, error)

Setup connects a consumer to the AMPQ queue from the config

func (*Consumer) Shutdown ¶

func (c *Consumer) Shutdown() error

Shutdown will gracefully stop a consumer

type DockerService ¶

type DockerService struct {
	Client  *client.Client
	Timeout time.Duration
}

DockerService contains all settings to talk to the docker api

func NewDockerServiceWithTimeout ¶

func NewDockerServiceWithTimeout(timeout time.Duration) (*DockerService, error)

func (*DockerService) ListContainers ¶

func (ds *DockerService) ListContainers()

ListContainers lists all docker containers

func (*DockerService) ListImages ¶

func (ds *DockerService) ListImages()

ListImages lists all docker images

func (*DockerService) Pull ¶

func (ds *DockerService) Pull(image string) (string, error)

Pull pulls a docker image

func (*DockerService) Run ¶

func (ds *DockerService) Run(
	imageName string,
	submissionZipFile string,
	frameworkZipFile string,
	DockerMemoryBytes int64,
) (string, int64, error)

Run executes a docker container and waits for the output

type Producer ¶

type Producer struct {
	Config *Config
	// contains filtered or unexported fields
}

Producer is an object which can emit a AMPQ messages

func NewProducer ¶

func NewProducer(cfg *Config) (*Producer, error)

NewProducer creates a new producer which can emit AMPQ messages

func (*Producer) Publish ¶

func (c *Producer) Publish(body []byte) error

Publish emits an AMPQ message

type Worker ¶

type Worker interface {
	Setup() error
	Shutdown() error
	HandleLoop(deliveries <-chan amqp.Delivery)
}

Worker is a description for an object getting messages over AMPQ

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL