domain

package
v0.0.46 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 19, 2023 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var SkippedAbortedEarlier = fmt.Errorf("skipped: job aborted earlier")

Functions

func SkippedNotValid

func SkippedNotValid(cause error) error

func TraverseDeepAppTree

func TraverseDeepAppTree(
	path string,
	ctx model.TraverseAppTreeContext,
) error

Types

type DeployService

type DeployService interface {
	DeployAll(
		ctx context.Context,
		path string,
		deployCfg model.DeployConfig,
	) (model.DeployResult, error)

	DeployAppFromInlineConfig(
		ctx context.Context,
		deployCfg model.DeployConfig,
		cfg model.AppConfig,
	) (model.SingleAppDeploySuccessType, error)

	DeployAppFromFolder(
		ctx context.Context,
		path string,
		deployCfg model.DeployConfig,
		preCalculatedAppConfig *model.PreCalculatedAppConfig,
	) (model.SingleAppDeploySuccessType, error)
}

DeployService We have multiple consumers of this interface from day 1, so it's prob ok to declare it here

func NewDeployService

func NewDeployService(flyClient fly_client.FlyClient) DeployService

type DeployServiceImpl

type DeployServiceImpl struct {
	// contains filtered or unexported fields
}

func (DeployServiceImpl) DeployAll

func (d DeployServiceImpl) DeployAll(ctx context.Context, path string, deployCfg model.DeployConfig) (model.DeployResult, error)

func (DeployServiceImpl) DeployAppFromFolder

func (d DeployServiceImpl) DeployAppFromFolder(
	ctx context.Context,
	path string,
	deployCfg model.DeployConfig,
	preCalculatedAppConfig *model.PreCalculatedAppConfig,
) (model.SingleAppDeploySuccessType, error)

func (DeployServiceImpl) DeployAppFromInlineConfig

func (d DeployServiceImpl) DeployAppFromInlineConfig(ctx context.Context, deployCfg model.DeployConfig, cfg model.AppConfig) (model.SingleAppDeploySuccessType, error)

type WebHookService

type WebHookService interface {
	HandleGithubWebhook(payload github.PushWebhookPayload, path string) <-chan error
	Start(ctx context.Context) error
	CloseJobQueue()
	EnqueueJob(job func())
}

func NewWebHookService

func NewWebHookService(deployService DeployService) WebHookService

type WebHookServiceImpl

type WebHookServiceImpl struct {
	// contains filtered or unexported fields
}

func (*WebHookServiceImpl) CloseJobQueue added in v0.0.43

func (w *WebHookServiceImpl) CloseJobQueue()

Stop An alternative to cancelling the context itself

func (*WebHookServiceImpl) EnqueueJob added in v0.0.43

func (w *WebHookServiceImpl) EnqueueJob(job func())

func (*WebHookServiceImpl) HandleGithubWebhook

func (w *WebHookServiceImpl) HandleGithubWebhook(payload github.PushWebhookPayload, path string) <-chan error

func (*WebHookServiceImpl) Start

func (w *WebHookServiceImpl) Start(ctx context.Context) error

Start Starts the internal worker

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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