shared

Documentation

Index

• func SanitizePath(path string) string
• func SetBuildStepsOnBuild(build *model.Build, buildItems []*BuildItem) *model.Build
• func UpdateProcStatus(store UpdateProcStore, proc model.Proc, state rpc.State, started int64) (*model.Proc, error)
• func UpdateProcStatusToDone(store UpdateProcStore, proc model.Proc, state rpc.State) (*model.Proc, error)
• func UpdateProcToStatusKilled(store UpdateProcStore, proc model.Proc) (*model.Proc, error)
• func UpdateProcToStatusSkipped(store UpdateProcStore, proc model.Proc, stopped int64) (*model.Proc, error)
• func UpdateProcToStatusStarted(store UpdateProcStore, proc model.Proc, state rpc.State) (*model.Proc, error)
• func UpdateStatusToDone(store UpdateBuildStore, build model.Build, status model.StatusValue, ...) (*model.Build, error)
• func UpdateToStatusDeclined(store UpdateBuildStore, build model.Build, reviewer string) (*model.Build, error)
• func UpdateToStatusError(store UpdateBuildStore, build model.Build, err error) (*model.Build, error)
• func UpdateToStatusKilled(store UpdateBuildStore, build model.Build) (*model.Build, error)
• func UpdateToStatusPending(store UpdateBuildStore, build model.Build, reviewer string) (*model.Build, error)
• func UpdateToStatusRunning(store UpdateBuildStore, build model.Build, started int64) (*model.Build, error)
• type BuildItem
• type ConfigFetcher
  • func NewConfigFetcher(remote remote.Remote, user *model.User, repo *model.Repo, build *model.Build) ConfigFetcher
• type FilterFunc
  • func NamespaceFilter(namespaces map[string]bool) FilterFunc
• type ProcBuilder
  • func (b *ProcBuilder) Build() ([]*BuildItem, error)
• type Syncer
  • func (s *Syncer) SetFilter(fn FilterFunc)
  • func (s *Syncer) Sync(ctx context.Context, user *model.User, flatPermissions bool) error
• type UpdateBuildStore
• type UpdateProcStore
• type UserSyncer

Functions

func SanitizePath

func SanitizePath(path string) string

func SetBuildStepsOnBuild

func SetBuildStepsOnBuild(build *model.Build, buildItems []*BuildItem) *model.Build

func UpdateProcStatus

func UpdateProcStatus(store UpdateProcStore, proc model.Proc, state rpc.State, started int64) (*model.Proc, error)

func UpdateProcStatusToDone

func UpdateProcStatusToDone(store UpdateProcStore, proc model.Proc, state rpc.State) (*model.Proc, error)

func UpdateProcToStatusKilled

func UpdateProcToStatusKilled(store UpdateProcStore, proc model.Proc) (*model.Proc, error)

func UpdateProcToStatusSkipped

func UpdateProcToStatusSkipped(store UpdateProcStore, proc model.Proc, stopped int64) (*model.Proc, error)

func UpdateProcToStatusStarted

func UpdateProcToStatusStarted(store UpdateProcStore, proc model.Proc, state rpc.State) (*model.Proc, error)

func UpdateStatusToDone

func UpdateStatusToDone(store UpdateBuildStore, build model.Build, status model.StatusValue, stopped int64) (*model.Build, error)

func UpdateToStatusDeclined

func UpdateToStatusDeclined(store UpdateBuildStore, build model.Build, reviewer string) (*model.Build, error)

func UpdateToStatusError

func UpdateToStatusError(store UpdateBuildStore, build model.Build, err error) (*model.Build, error)

func UpdateToStatusKilled

func UpdateToStatusKilled(store UpdateBuildStore, build model.Build) (*model.Build, error)

func UpdateToStatusPending

func UpdateToStatusPending(store UpdateBuildStore, build model.Build, reviewer string) (*model.Build, error)

func UpdateToStatusRunning

func UpdateToStatusRunning(store UpdateBuildStore, build model.Build, started int64) (*model.Build, error)

Types

type BuildItem

type BuildItem struct {
	Proc      *model.Proc
	Platform  string
	Labels    map[string]string
	DependsOn []string
	RunsOn    []string
	Config    *backend.Config
}

type ConfigFetcher

type ConfigFetcher interface {
	Fetch(ctx context.Context) (files []*remote.FileMeta, err error)
}

func NewConfigFetcher

func NewConfigFetcher(remote remote.Remote, user *model.User, repo *model.Repo, build *model.Build) ConfigFetcher

type FilterFunc

type FilterFunc func(*model.Repo) bool

FilterFunc can be used to filter which repositories are synchronized with the local datastore.

func NamespaceFilter

func NamespaceFilter(namespaces map[string]bool) FilterFunc

type ProcBuilder

type ProcBuilder struct {
	Repo  *model.Repo
	Curr  *model.Build
	Last  *model.Build
	Netrc *model.Netrc
	Secs  []*model.Secret
	Regs  []*model.Registry
	Link  string
	Yamls []*remote.FileMeta
	Envs  map[string]string
}

ProcBuilder Takes the hook data and the yaml and returns in internal data model

func (*ProcBuilder) Build

func (b *ProcBuilder) Build() ([]*BuildItem, error)

type Syncer

type Syncer struct {
	Remote remote.Remote
	Store  store.Store
	Perms  model.PermStore
	Match  FilterFunc
}

func (*Syncer) SetFilter

func (s *Syncer) SetFilter(fn FilterFunc)

SetFilter sets the filter function.

func (*Syncer) Sync

func (s *Syncer) Sync(ctx context.Context, user *model.User, flatPermissions bool) error

type UpdateBuildStore

type UpdateBuildStore interface {
	UpdateBuild(*model.Build) error
}

type UpdateProcStore

type UpdateProcStore interface {
	ProcUpdate(*model.Proc) error
}

type UserSyncer

type UserSyncer interface {
	Sync(ctx context.Context, user *model.User) error
}

UserSyncer syncs the user repository and permissions.