service

Documentation

Index

• Constants
• Variables
• func AddModuleInputFiles(config *model.Config, basePath string, readFile func(string) ([]byte, error), ...)
• func AddStepsFilesFromBucket(config *model.Config, bucket model.Bucket)
• func AddStepsFilesFromFolder(config *model.Config, basePath string)
• func GetBaseConfig(prefix, configFile string, bucket model.Bucket) model.Config
• func GetCloudProvider(ctx context.Context, flags *common.Flags) model.CloudProvider
• func GetFullConfig(ssm model.SSM, prefix, configFile string, bucket model.Bucket) model.Config
• func GetLocalConfig(ssm model.SSM, prefix, configFile string, bucket model.Bucket, addInputs bool) model.Config
• func GetModuleState(stepState *model.StateStep, moduleName string) *model.StateModule
• func GetProviderPrefix(flags *common.Flags) string
• func GetRemoteConfig(ssm model.SSM, prefix string, bucket model.Bucket, addInputs bool) model.Config
• func GetStepState(state *model.State, stepName string) *model.StateStep
• func ProcessConfig(config *model.Config, providerType model.ProviderType)
• func PutAdditionalFiles(bucket model.Bucket, steps []model.Step)
• func PutConfig(bucket model.Bucket, config model.Config)
• func ValidateConfig(config model.Config, state *model.State)
• type Agent
  • func NewAgent(resources model.Resources) Agent
• type Deleter
  • func NewDeleter(ctx context.Context, flags *common.Flags) Deleter
• type LocalPipeline
  • func NewLocalPipeline(resources model.Resources, flags common.Pipeline) *LocalPipeline
• type Updater
  • func NewUpdater(ctx context.Context, flags *common.Flags) Updater

Constants

const (
	StableVersion = "stable"
	IncludeFormat = "config/%s/include"
	ConfigFile    = "config.yaml"
	EntigoSource  = "github.com/entigolabs/entigo-infralib-release"
)

Variables

var ReservedAppsFiles = model.ToSet([]string{"argocd.yaml"})

var ReservedTFFiles = model.ToSet([]string{"main.tf", "provider.tf", "backend.conf"})

Functions

func AddModuleInputFiles

func AddModuleInputFiles(config *model.Config, basePath string, readFile func(string) ([]byte, error), addInputs bool)

func AddStepsFilesFromBucket

func AddStepsFilesFromBucket(config *model.Config, bucket model.Bucket)

func AddStepsFilesFromFolder

func AddStepsFilesFromFolder(config *model.Config, basePath string)

func GetBaseConfig

func GetBaseConfig(prefix, configFile string, bucket model.Bucket) model.Config

func GetCloudProvider

func GetCloudProvider(ctx context.Context, flags *common.Flags) model.CloudProvider

func GetFullConfig

func GetFullConfig(ssm model.SSM, prefix, configFile string, bucket model.Bucket) model.Config

func GetLocalConfig

func GetLocalConfig(ssm model.SSM, prefix, configFile string, bucket model.Bucket, addInputs bool) model.Config

func GetModuleState

func GetModuleState(stepState *model.StateStep, moduleName string) *model.StateModule

func GetProviderPrefix

func GetProviderPrefix(flags *common.Flags) string

func GetRemoteConfig

func GetRemoteConfig(ssm model.SSM, prefix string, bucket model.Bucket, addInputs bool) model.Config

func GetStepState

func GetStepState(state *model.State, stepName string) *model.StateStep

func ProcessConfig

func ProcessConfig(config *model.Config, providerType model.ProviderType)

func PutAdditionalFiles

func PutAdditionalFiles(bucket model.Bucket, steps []model.Step)

func PutConfig

func PutConfig(bucket model.Bucket, config model.Config)

func ValidateConfig

func ValidateConfig(config model.Config, state *model.State)

Types

type Agent

type Agent interface {
	CreatePipeline(version string) error
	UpdateProjectImage(version string, cmd common.Command) error
}

func NewAgent

func NewAgent(resources model.Resources) Agent

type Deleter

type Deleter interface {
	Delete()
	Destroy() bool
}

func NewDeleter

func NewDeleter(ctx context.Context, flags *common.Flags) Deleter

type LocalPipeline

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

func NewLocalPipeline

func NewLocalPipeline(resources model.Resources, flags common.Pipeline) *LocalPipeline

type Updater

type Updater interface {
	Run()
	Update()
}

func NewUpdater

func NewUpdater(ctx context.Context, flags *common.Flags) Updater