service

Documentation

Index

• Constants
• func NewServiceModule(log *zap.Logger, config *config.Config, services storage.ServiceStorage, ...) error
• func NewStorage(connection *pgxpool.Pool) (storage.ServiceStorage, storage.InstanceStorage, error)
• func Routes(route *gin.RouterGroup, log *zap.Logger, config *config.Config, ...) (routes, error)
• type Container
  • func NewContainer(log *zap.Logger) (Container, error)
• type ContainerStatus
• type IngestBacktestPayload
• type InitialResponse
• type InstanceRunningPayload
• type ServiceCreatedPayload
• type StartInstancePayload
• type StopInstancePayload

Constants

const (
	ErrNoSuchImage = fbError.Error("no such image found")
)

const IngestBacktestTopic = "service.IngestBacktest"

const InstanceRunningTopic = "service.InstanceRunning"

const InstanceStartedTopic = "service.InstanceStarted"

const ServiceCreatedTopic = "service.ServiceCreated"

const StartInstanceTopic = "service.StartInstance"

const StopInstanceTopic = "service.StopInstance"

Functions

func NewServiceModule

func NewServiceModule(log *zap.Logger, config *config.Config, services storage.ServiceStorage,
	instances storage.InstanceStorage, container Container, stream stream.Stream, lc fx.Lifecycle) error

func NewStorage

func NewStorage(connection *pgxpool.Pool) (storage.ServiceStorage, storage.InstanceStorage, error)

func Routes

func Routes(route *gin.RouterGroup, log *zap.Logger, config *config.Config, services storage.ServiceStorage,
	instances storage.InstanceStorage,
	container Container, stream stream.Stream) (routes, error)

Types

type Container

type Container interface {
	Start(ctx context.Context, config *config.Config, serviceName, image string) (string, error)
	SaveImage(ctx context.Context, containerID, name string) error
	Stop(ctx context.Context, containerID string, remove bool) error
}

func NewContainer

func NewContainer(log *zap.Logger) (Container, error)

type ContainerStatus

type ContainerStatus struct {
	ID  string
	Err error
}

type IngestBacktestPayload

type IngestBacktestPayload struct {
	Service string               `json:"service_name"`
	Config  storage.IngestConfig `json:"config"`
}

type InitialResponse

type InitialResponse struct {
	Type    string `json:"type"`
	Version string `json:"version"`
}

type InstanceRunningPayload

type InstanceRunningPayload struct {
	Service   string `json:"service_name"`
	ID        string `json:"ID"`
	Execution string `json:"execution"`
}

type ServiceCreatedPayload

type ServiceCreatedPayload struct {
	Name string `json:"name"`
}

type StartInstancePayload

type StartInstancePayload struct {
	Service   string `json:"service_name"`
	Execution string `json:"execution"`
}

type StopInstancePayload

type StopInstancePayload struct {
	ID     string `json:"ID"`
	Remove bool   `json:"remove"`
}