choreo

package
v0.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 4, 2024 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnsureDir 

func EnsureDir(dirname string) error

func Exists 

func Exists(filepath string) bool

Types

type BranchCtx 

type BranchCtx struct {
	State    State
	Branch   string
	APIStore *api.APIStore
}

type BranchStore 

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

func NewBranchStore 

func NewBranchStore(choreo *choreo) (*BranchStore, error)

func (*BranchStore) Delete 

func (r *BranchStore) Delete(ctx context.Context, branchSet repository.BranchSet) error

func (*BranchStore) GetStore 

func (r *BranchStore) GetStore() store.Storer[*BranchCtx]

func (*BranchStore) LoadData 

func (r *BranchStore) LoadData(ctx context.Context, branch string) error

func (*BranchStore) Update 

func (r *BranchStore) Update(ctx context.Context, branches []*branchpb.BranchObject) error

func (*BranchStore) WatchAPIResources 

func (r *BranchStore) WatchAPIResources(ctx context.Context, opts ...resourceclient.ListOption) (watch.WatchInterface[*api.ResourceContext], error)

func (*BranchStore) WatchBranches 

func (r *BranchStore) WatchBranches(ctx context.Context, opts ...store.ListOption) (watch.WatchInterface[*BranchCtx], error)

type CheckedOut 

type CheckedOut struct {
	Choreo               *choreo
	Client               resourceclient.Client
	ChildChoreoInstances []ChoreoInstance
}

func (*CheckedOut) Activate 

func (r *CheckedOut) Activate(ctx context.Context, branchCtx *BranchCtx) error

func (*CheckedOut) DeActivate 

func (r *CheckedOut) DeActivate(_ context.Context, branchCtx *BranchCtx) error

func (*CheckedOut) GetCommit 

func (r *CheckedOut) GetCommit() *object.Commit

func (*CheckedOut) LoadData 

func (r *CheckedOut) LoadData(ctx context.Context, branchCtx *BranchCtx) error

func (*CheckedOut) String 

func (r *CheckedOut) String() string

type ChildChoreoInstance 

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

func (*ChildChoreoInstance) GetAPIClient 

func (r *ChildChoreoInstance) GetAPIClient() resourceclient.Client

func (*ChildChoreoInstance) GetAPIStore 

func (r *ChildChoreoInstance) GetAPIStore() *api.APIStore

func (*ChildChoreoInstance) GetAnnotationVal 

func (r *ChildChoreoInstance) GetAnnotationVal() string

func (*ChildChoreoInstance) GetCommit 

func (r *ChildChoreoInstance) GetCommit() *object.Commit

func (*ChildChoreoInstance) GetDBPath 

func (r *ChildChoreoInstance) GetDBPath() string

func (*ChildChoreoInstance) GetFlags 

func (r *ChildChoreoInstance) GetFlags() *genericclioptions.ConfigFlags

func (*ChildChoreoInstance) GetName 

func (r *ChildChoreoInstance) GetName() string

func (*ChildChoreoInstance) GetPath 

func (r *ChildChoreoInstance) GetPath() string

func (*ChildChoreoInstance) GetPathInRepo 

func (r *ChildChoreoInstance) GetPathInRepo() string

func (*ChildChoreoInstance) GetRepo 

func (r *ChildChoreoInstance) GetRepo() repository.Repository

func (*ChildChoreoInstance) GetRepoPath 

func (r *ChildChoreoInstance) GetRepoPath() string

func (*ChildChoreoInstance) GetTempPath 

func (r *ChildChoreoInstance) GetTempPath() string

func (*ChildChoreoInstance) LoadInternalAPIs 

func (r *ChildChoreoInstance) LoadInternalAPIs() error

type Choreo 

type Choreo interface {
	Start(ctx context.Context)
	GetMainChoreoInstance() ChoreoInstance
	GetBranchStore() *BranchStore
}

func New 

func New(ctx context.Context, path string, flags *genericclioptions.ConfigFlags) (Choreo, error)

type ChoreoInstance 

type ChoreoInstance interface {
	GetName() string
	GetRepo() repository.Repository
	GetRepoPath() string
	GetPath() string
	GetTempPath() string
	GetPathInRepo() string
	GetDBPath() string
	GetFlags() *genericclioptions.ConfigFlags
	GetAPIStore() *api.APIStore // provides the internal apistore
	GetCommit() *object.Commit
	GetAPIClient() resourceclient.Client
	GetAnnotationVal() string
}

func NewChildChoreoInstance 

func NewChildChoreoInstance(ctx context.Context, repo repository.Repository, pathInRepo string, flags *genericclioptions.ConfigFlags, commit *object.Commit, annotationVal string) (ChoreoInstance, error)

func NewMainChoreoInstance 

func NewMainChoreoInstance(ctx context.Context, path string, flags *genericclioptions.ConfigFlags) (ChoreoInstance, error)

type Event 

type Event int
const (
	Activate Event = iota
	DeActivate
)

func (Event) String 

func (r Event) String() string

type MainChoreoInstance 

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

func (*MainChoreoInstance) GetAPIClient 

func (r *MainChoreoInstance) GetAPIClient() resourceclient.Client

func (*MainChoreoInstance) GetAPIStore 

func (r *MainChoreoInstance) GetAPIStore() *api.APIStore

func (*MainChoreoInstance) GetAnnotationVal 

func (r *MainChoreoInstance) GetAnnotationVal() string

func (*MainChoreoInstance) GetCommit 

func (r *MainChoreoInstance) GetCommit() *object.Commit

func (*MainChoreoInstance) GetDBPath 

func (r *MainChoreoInstance) GetDBPath() string

func (*MainChoreoInstance) GetFlags 

func (r *MainChoreoInstance) GetFlags() *genericclioptions.ConfigFlags

func (*MainChoreoInstance) GetName 

func (r *MainChoreoInstance) GetName() string

func (*MainChoreoInstance) GetPath 

func (r *MainChoreoInstance) GetPath() string

func (*MainChoreoInstance) GetPathInRepo 

func (r *MainChoreoInstance) GetPathInRepo() string

func (*MainChoreoInstance) GetRepo 

func (r *MainChoreoInstance) GetRepo() repository.Repository

func (*MainChoreoInstance) GetRepoPath 

func (r *MainChoreoInstance) GetRepoPath() string

func (*MainChoreoInstance) GetTempPath 

func (r *MainChoreoInstance) GetTempPath() string

func (*MainChoreoInstance) LoadInternalAPIs 

func (r *MainChoreoInstance) LoadInternalAPIs() error

type NotCheckedOut 

type NotCheckedOut struct {
	Commit *object.Commit
	Choreo *choreo
	Client resourceclient.Client
}

func (*NotCheckedOut) Activate 

func (r *NotCheckedOut) Activate(ctx context.Context, branchCtx *BranchCtx) error

func (*NotCheckedOut) DeActivate 

func (r *NotCheckedOut) DeActivate(_ context.Context, branchCtx *BranchCtx) error

func (*NotCheckedOut) GetCommit 

func (r *NotCheckedOut) GetCommit() *object.Commit

func (*NotCheckedOut) LoadData 

func (r *NotCheckedOut) LoadData(_ context.Context, branchCtx *BranchCtx) error

func (*NotCheckedOut) String 

func (r *NotCheckedOut) String() string

type Reconciler 

type Reconciler interface {
	Start(ctx context.Context)
	Stop()
}

No longer used, we decided that apis should always be loaded through files/git

func NewAPIReconciler 

func NewAPIReconciler(
	choreoInstance ChoreoInstance,
	client resourceclient.Client,
	branch string,
	apiStore *api.APIStore,
) Reconciler

type State 

type State interface {
	String() string
	Activate(ctx context.Context, branchCtx *BranchCtx) error
	DeActivate(ctx context.Context, branchCtx *BranchCtx) error
	LoadData(ctx context.Context, branchCtx *BranchCtx) error
	GetCommit() *object.Commit
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.