engine

Documentation

Index

• func NormalizePaths(workdir, configPath string) (string, string, error)
• func Start(ctx context.Context, startOpts *Config, fn StartCallback) error
• type AnyDirSource
  • func (AnyDirSource) LookupDir(name string) (filesync.SyncedDir, bool)
• type Config
• type NamedSocketProviders
• type SocketProvider
  • func (m SocketProvider) CheckAgent(ctx context.Context, req *sshforward.CheckAgentRequest) (*sshforward.CheckAgentResponse, error)
  • func (m SocketProvider) ForwardAgent(stream sshforward.SSH_ForwardAgentServer) error
  • func (m SocketProvider) Register(server *grpc.Server)
• type StartCallback

Functions

func NormalizePaths

func NormalizePaths(workdir, configPath string) (string, string, error)

func Start

func Start(ctx context.Context, startOpts *Config, fn StartCallback) error

Types

type AnyDirSource

type AnyDirSource struct{}

func (AnyDirSource) LookupDir

func (AnyDirSource) LookupDir(name string) (filesync.SyncedDir, bool)

type Config

type Config struct {
	Workdir    string
	ConfigPath string
	// If true, do not load project extensions
	NoExtensions  bool
	LogOutput     io.Writer
	DisableHostRW bool
	RunnerHost    string
	SessionToken  string

	// WARNING: this is currently exposed directly but will be removed or
	// replaced with something incompatible in the future.
	RawBuildkitStatus chan *bkclient.SolveStatus
}

type NamedSocketProviders

type NamedSocketProviders map[string]sshforward.SSHServer

type SocketProvider

type SocketProvider struct {
	Named NamedSocketProviders

	EnableHostNetworkAccess bool
}

Map of id -> handler for that id.

func (SocketProvider) CheckAgent

func (m SocketProvider) CheckAgent(ctx context.Context, req *sshforward.CheckAgentRequest) (*sshforward.CheckAgentResponse, error)

func (SocketProvider) ForwardAgent

func (m SocketProvider) ForwardAgent(stream sshforward.SSH_ForwardAgentServer) error

func (SocketProvider) Register

func (m SocketProvider) Register(server *grpc.Server)

type StartCallback

type StartCallback func(context.Context, *router.Router) error