crafter

Documentation

Index

• Variables
• func LoadSchema(pathOrURI string) (*schemaapi.CraftingSchema, error)
• type CommitRemote
• type Crafter
  • func NewCrafter(stateManager StateManager, opts ...NewOpt) (*Crafter, error)
  • func (c *Crafter) AddMaterial(ctx context.Context, attestationID, key, value string, ...) error
  • func (c *Crafter) AlreadyInitialized(ctx context.Context, stateID string) (bool, error)
  • func (c *Crafter) Init(ctx context.Context, opts *InitOpts) error
  • func (c *Crafter) LoadCraftingState(ctx context.Context, attestationID string) error
  • func (c *Crafter) Reset(ctx context.Context, stateID string) error
  • func (c *Crafter) ResolveEnvVars(ctx context.Context, attestationID string) error
  • func (c *Crafter) ValidateAttestation() error
• type HeadCommit
• type InitOpts
• type NewOpt
  • func WithLogger(l *zerolog.Logger) NewOpt
  • func WithOCIAuth(server, username, password string) NewOpt
  • func WithWorkingDirPath(path string) NewOpt
• type RunnerM
• type StateManager
• type SupportedRunner
  • func DiscoverAndEnforceRunner(enforcedRunnerType schemaapi.CraftingSchema_Runner_RunnerType, dryRun bool, ...) (SupportedRunner, error)
  • func NewRunner(t schemaapi.CraftingSchema_Runner_RunnerType) SupportedRunner

Variables

var ErrAttestationStateNotLoaded = errors.New("crafting state not loaded")

var ErrRunnerContextNotFound = errors.New("the runner environment doesn't match the required runner type")

var RunnersMap = map[schemaapi.CraftingSchema_Runner_RunnerType]SupportedRunner{
	schemaapi.CraftingSchema_Runner_GITHUB_ACTION:   runners.NewGithubAction(),
	schemaapi.CraftingSchema_Runner_GITLAB_PIPELINE: runners.NewGitlabPipeline(),
	schemaapi.CraftingSchema_Runner_AZURE_PIPELINE:  runners.NewAzurePipeline(),
	schemaapi.CraftingSchema_Runner_JENKINS_JOB:     runners.NewJenkinsJob(),
	schemaapi.CraftingSchema_Runner_CIRCLECI_BUILD:  runners.NewCircleCIBuild(),
	schemaapi.CraftingSchema_Runner_DAGGER_PIPELINE: runners.NewDaggerPipeline(),
}

Functions

func LoadSchema

func LoadSchema(pathOrURI string) (*schemaapi.CraftingSchema, error)

Types

type CommitRemote

type CommitRemote struct {
	Name, URL string
}

type Crafter

type Crafter struct {
	CraftingState *api.CraftingState
	Runner        SupportedRunner
	// contains filtered or unexported fields
}

func NewCrafter

func NewCrafter(stateManager StateManager, opts ...NewOpt) (*Crafter, error)

Create a completely new crafter

func (*Crafter) AddMaterial

func (c *Crafter) AddMaterial(ctx context.Context, attestationID, key, value string, casBackend *casclient.CASBackend, runtimeAnnotations map[string]string) error

Inject material to attestation state

func (*Crafter) AlreadyInitialized

func (c *Crafter) AlreadyInitialized(ctx context.Context, stateID string) (bool, error)

func (*Crafter) Init

func (c *Crafter) Init(ctx context.Context, opts *InitOpts) error

Initialize the crafter with a remote or local schema

func (*Crafter) LoadCraftingState

func (c *Crafter) LoadCraftingState(ctx context.Context, attestationID string) error

func (*Crafter) Reset

func (c *Crafter) Reset(ctx context.Context, stateID string) error

Reset removes the current crafting state

func (*Crafter) ResolveEnvVars

func (c *Crafter) ResolveEnvVars(ctx context.Context, attestationID string) error

ResolveEnvVars will iterate on the env vars in the allow list and resolve them from the system context strict indicates if it should fail if any env variable can not be found

func (*Crafter) ValidateAttestation

func (c *Crafter) ValidateAttestation() error

type HeadCommit

type HeadCommit struct {
	// hash of the commit
	Hash string
	// When did the commit happen
	Date time.Time
	// Author of the commit
	AuthorEmail, AuthorName string
	// Commit Message
	Message string
	Remotes []*CommitRemote
}

type InitOpts

type InitOpts struct {
	// Control plane workflow metadata
	WfInfo *api.WorkflowMetadata
	// already marshaled schema
	SchemaV1 *schemaapi.CraftingSchema
	// do not record, upload or push attestation
	DryRun bool
	// Identifier of the attestation state
	AttestationID string
	Runner        SupportedRunner
}

type NewOpt

type NewOpt func(c *Crafter) error

func WithLogger

func WithLogger(l *zerolog.Logger) NewOpt

func WithOCIAuth

func WithOCIAuth(server, username, password string) NewOpt

func WithWorkingDirPath

func WithWorkingDirPath(path string) NewOpt

type RunnerM

type RunnerM map[schemaapi.CraftingSchema_Runner_RunnerType]SupportedRunner

type StateManager

type StateManager interface {
	// Check if the state is already initialized
	Initialized(ctx context.Context, key string) (bool, error)
	// Write the state to the manager backend
	Write(ctx context.Context, key string, state *api.CraftingState) error
	// Read the state from the manager backend
	Read(ctx context.Context, key string, state *api.CraftingState) error
	// Reset/Delete the state
	Reset(ctx context.Context, key string) error
	// String returns a string representation of the state manager
	Info(ctx context.Context, key string) string
}

StateManager is an interface for managing the state of the crafting process

type SupportedRunner

type SupportedRunner interface {
	// Whether the attestation is happening in this environment
	CheckEnv() bool

	// List the env variables registered
	ListEnvVars() []*runners.EnvVarDefinition

	// Return the list of env vars associated with this runner already resolved
	ResolveEnvVars() (map[string]string, []*error)

	// uri to the running job/workload
	RunURI() string

	// ID returns the runner type
	ID() schemaapi.CraftingSchema_Runner_RunnerType
}

func DiscoverAndEnforceRunner

func DiscoverAndEnforceRunner(enforcedRunnerType schemaapi.CraftingSchema_Runner_RunnerType, dryRun bool, logger zerolog.Logger) (SupportedRunner, error)

func NewRunner

func NewRunner(t schemaapi.CraftingSchema_Runner_RunnerType) SupportedRunner

Load a specific runner