initialization

Documentation

Index

• func GenerateAllKeys() (domain.CryptoKeys, error)
• func GenerateExecutorName() string
• func GeneratePasscode() (string, error)
• func GenerateX25519KeyPair() (privateKeyBase64, publicKeyBase64 string, err error)
• func GetDefaultAPIURL() string
• func GetVerificationURL(apiURL string) string
• func RegisterExecutor(executorName, address string, keys domain.CryptoKeys, apiBaseURL string) (string, error)
• func RunFirstTimeSetup(ctx context.Context, params RunFirstTimeSetupParams) error
• type ExecutorContainer
  • func NewExecutorContainer() (*ExecutorContainer, error)
  • func (c *ExecutorContainer) BuildExecutorDependencies(ctx context.Context, config ExecutorDependencyConfig) (*ExecutorDependencies, error)
  • func (c *ExecutorContainer) GetConfigManager() domain.ConfigManager
  • func (c *ExecutorContainer) GetWorkspaceRegistrationManager() domain.WorkspaceRegistrationManager
• type ExecutorDependencies
• type ExecutorDependencyConfig
• type RunFirstTimeSetupParams
• type WaitForVerificationParams
• type WaitForVerificationResult
  • func WaitForVerification(params WaitForVerificationParams) (WaitForVerificationResult, error)

Functions

func GenerateAllKeys

func GenerateAllKeys() (domain.CryptoKeys, error)

func GenerateExecutorName

func GenerateExecutorName() string

func GeneratePasscode

func GeneratePasscode() (string, error)

func GenerateX25519KeyPair

func GenerateX25519KeyPair() (privateKeyBase64, publicKeyBase64 string, err error)

func GetDefaultAPIURL

func GetDefaultAPIURL() string

func GetVerificationURL

func GetVerificationURL(apiURL string) string

func RegisterExecutor

func RegisterExecutor(executorName, address string, keys domain.CryptoKeys, apiBaseURL string) (string, error)

RegisterExecutor registers the executor with the API and returns verification code

func RunFirstTimeSetup

func RunFirstTimeSetup(ctx context.Context, params RunFirstTimeSetupParams) error

Types

type ExecutorContainer

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

func NewExecutorContainer

func NewExecutorContainer() (*ExecutorContainer, error)

func (*ExecutorContainer) BuildExecutorDependencies

func (c *ExecutorContainer) BuildExecutorDependencies(ctx context.Context, config ExecutorDependencyConfig) (*ExecutorDependencies, error)

func (*ExecutorContainer) GetConfigManager

func (c *ExecutorContainer) GetConfigManager() domain.ConfigManager

func (*ExecutorContainer) GetWorkspaceRegistrationManager

func (c *ExecutorContainer) GetWorkspaceRegistrationManager() domain.WorkspaceRegistrationManager

type ExecutorDependencies

type ExecutorDependencies struct {
	FlowbakerClient         *flowbaker.Client
	IntegrationSelector     domain.IntegrationSelector
	WorkflowExecutorService executor.WorkflowExecutorService
	ExecutorController      *controllers.ExecutorController
}

type ExecutorDependencyConfig

type ExecutorDependencyConfig struct {
	FlowbakerClient *flowbaker.Client
	ExecutorID      string
	Config          domain.ExecutorConfig
}

type RunFirstTimeSetupParams

type RunFirstTimeSetupParams struct {
	ConfigManager       domain.ConfigManager
	RegistrationManager domain.WorkspaceRegistrationManager
}

type WaitForVerificationParams

type WaitForVerificationParams struct {
	ExecutorName                 string
	VerificationCode             string
	Keys                         domain.CryptoKeys
	APIBaseURL                   string
	WorkspaceRegistrationManager domain.WorkspaceRegistrationManager
	EnableStaticPasscode         bool
	StaticPasscode               string
}

type WaitForVerificationResult

type WaitForVerificationResult struct {
	ExecutorID          string
	WorkspaceAssignment domain.WorkspaceAssignment
}

func WaitForVerification

func WaitForVerification(params WaitForVerificationParams) (WaitForVerificationResult, error)