choreo

Nov 13, 2024

Changes in this version

type SnapshotManager

+ func (r *SnapshotManager) Result(_ *snapshotpb.Result_Request) (*snapshotpb.Result_Response, error)

Nov 11, 2024

Changes in this version

type BranchStore

+ func (r *BranchStore) UpdateBranchCtx(branchCtx *BranchCtx) error

type Choreo

+ GetClient func() resourceclient.Client

+ GetConfig func() *genericclioptions.ChoreoConfig

+ GetContext func() context.Context

+ GetStatus func() *Status

type Config

+ func (u *Config) GetConfigs() []any

+ type ConfigValidator struct

+ func NewConfigValidator(choreo Choreo) *ConfigValidator

+ type Node struct

+ func (r *Node) GetPlatformType() string

+ func (r *Node) GetProvider() string

+ func (r *Node) GetVersion() string

+ type NodeConfig struct

+ Configs []*unstructured.Unstructured

+ Node *Node

+ RunningConfig any

type Runner

+ Load func(ctx context.Context, bctx *BranchCtx) error

type Snapshot

+ RunResponse *runnerpb.Once_Response_RunResponse

Oct 15, 2024

Changes in this version

type ChildChoreoInstance

+ func (r *ChildChoreoInstance) CommitWorktree(msg string) (*choreopb.Commit_Response, error)

+ func (r *ChildChoreoInstance) PushBranch(branch string) (*choreopb.Push_Response, error)

type ChoreoInstance

+ CommitWorktree func(msg string) (*choreopb.Commit_Response, error)

+ PushBranch func(branch string) (*choreopb.Push_Response, error)

type RootChoreoInstance

+ func (r *RootChoreoInstance) CommitWorktree(msg string) (*choreopb.Commit_Response, error)

+ func (r *RootChoreoInstance) PushBranch(branch string) (*choreopb.Push_Response, error)

Oct 14, 2024

Changes in this version

type Choreo

+ GetRootChoreoInstance func() ChoreoInstance

+ SnapshotManager func() *SnapshotManager

type ChoreoInstance

+ func NewRootChoreoInstance(ctx context.Context, config *Config) (ChoreoInstance, error)

type ChoreoStatus

+ RootChoreoInstance ChoreoInstance

+ type RootChoreoInstance struct

+ func (r *RootChoreoInstance) Destroy() error

+ func (r *RootChoreoInstance) GetAPIClient() resourceclient.Client

+ func (r *RootChoreoInstance) GetAPIStore() *api.APIStore

+ func (r *RootChoreoInstance) GetAnnotationVal() string

+ func (r *RootChoreoInstance) GetCommit() *object.Commit

+ func (r *RootChoreoInstance) GetDBPath() string

+ func (r *RootChoreoInstance) GetFlags() *genericclioptions.ConfigFlags

+ func (r *RootChoreoInstance) GetName() string

+ func (r *RootChoreoInstance) GetPath() string

+ func (r *RootChoreoInstance) GetPathInRepo() string

+ func (r *RootChoreoInstance) GetRepo() repository.Repository

+ func (r *RootChoreoInstance) GetRepoPath() string

+ func (r *RootChoreoInstance) GetTempPath() string

+ func (r *RootChoreoInstance) LoadInternalAPIs() error

+ type Snapshot struct

+ APIResources []*discoverypb.APIResource

+ CreatedAt time.Time

+ ID string

+ Inventory inventory.Inventory

+ type SnapshotManager struct

+ func NewSnapshotManager() *SnapshotManager

+ func (r *SnapshotManager) Create(id string, apiResources []*discoverypb.APIResource, ...)

+ func (r *SnapshotManager) Delete(req *snapshotpb.Delete_Request) (*snapshotpb.Delete_Response, error)

+ func (r *SnapshotManager) Diff(req *snapshotpb.Diff_Request) (*snapshotpb.Diff_Response, error)

+ func (r *SnapshotManager) Get(req *snapshotpb.Get_Request) (*snapshotpb.Get_Response, error)

+ func (r *SnapshotManager) List(req *snapshotpb.List_Request) (*snapshotpb.List_Response, error)

+ type SnapshotNode struct

Oct 12, 2024

Changes in this version

+ const DummyBranch

+ func HasAPIResource(apiResources []*discoverypb.APIResource, gvk schema.GroupVersionKind) bool

+ func PrintAPIResource(apiResources []*discoverypb.APIResource) bool

type BranchStore

+ func (r *BranchStore) GetCheckedOut() (*BranchCtx, error)

type ChildChoreoInstance

+ func (r *ChildChoreoInstance) Destroy() error

type Choreo

+ Apply func(ctx context.Context, req *choreopb.Apply_Request) (*choreopb.Apply_Response, error)

+ Destroy func(obj runtime.Unstructured) error

+ Get func(ctx context.Context, req *choreopb.Get_Request) (*choreopb.Get_Response, error)

+ Runner func() Runner

+ Store func(obj runtime.Unstructured) error

type ChoreoInstance

+ Destroy func() error

+ type ChoreoStatus struct

+ ChoreoCtx *choreopb.ChoreoContext

+ MainChoreoInstance ChoreoInstance

+ Reason string

+ Status bool

+ func Failed(msg string) ChoreoStatus

+ func Initializing() ChoreoStatus

+ func Success(c ChoreoInstance, choreoCtx *choreopb.ChoreoContext) ChoreoStatus

+ type Config struct

+ Commit *object.Commit

+ Flags *genericclioptions.ConfigFlags

+ Path string

+ PathInRepo string

+ Repo repository.Repository

type MainChoreoInstance

+ func (r *MainChoreoInstance) Destroy() error

+ type Runner interface

+ AddResourceClientAndContext func(ctx context.Context, client resourceclient.Client)

+ RunOnce func(ctx context.Context, bctx *BranchCtx) (*choreopb.Once_Response, error)

+ Start func(ctx context.Context, bctx *BranchCtx) (*choreopb.Start_Response, error)

+ Stop func()

+ func NewRunner(choreo Choreo) Runner

+ type RunnerStatus int

+ const RunnerStatus_Once

+ const RunnerStatus_Running

+ const RunnerStatus_Stopped

+ func (rs RunnerStatus) String() string

+ type Status struct

+ func (r *Status) Changed(newChoreoCtx *choreopb.ChoreoContext) bool

+ func (r *Status) Get() ChoreoStatus

+ func (r *Status) Set(s ChoreoStatus)

Sep 30, 2024

Changes in this version

+ func EnsureDir(dirname string) error

+ func Exists(filepath string) bool

+ type BranchCtx struct

+ APIStore *api.APIStore

+ Branch string

+ State State

+ type BranchStore struct

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

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

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

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

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

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

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

+ type CheckedOut struct

+ ChildChoreoInstances []ChoreoInstance

+ Choreo *choreo

+ Client resourceclient.Client

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

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

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

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

+ func (r *CheckedOut) String() string

+ type ChildChoreoInstance struct

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

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

+ func (r *ChildChoreoInstance) GetAnnotationVal() string

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

+ func (r *ChildChoreoInstance) GetDBPath() string

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

+ func (r *ChildChoreoInstance) GetName() string

+ func (r *ChildChoreoInstance) GetPath() string

+ func (r *ChildChoreoInstance) GetPathInRepo() string

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

+ func (r *ChildChoreoInstance) GetRepoPath() string

+ func (r *ChildChoreoInstance) GetTempPath() string

+ func (r *ChildChoreoInstance) LoadInternalAPIs() error

+ type Choreo interface

+ GetBranchStore func() *BranchStore

+ GetMainChoreoInstance func() ChoreoInstance

+ Start func(ctx context.Context)

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

+ type ChoreoInstance interface

+ GetAPIClient func() resourceclient.Client

+ GetAPIStore func() *api.APIStore

+ GetAnnotationVal func() string

+ GetCommit func() *object.Commit

+ GetDBPath func() string

+ GetFlags func() *genericclioptions.ConfigFlags

+ GetName func() string

+ GetPath func() string

+ GetPathInRepo func() string

+ GetRepo func() repository.Repository

+ GetRepoPath func() string

+ GetTempPath func() string

+ func NewChildChoreoInstance(ctx context.Context, repo repository.Repository, pathInRepo string, ...) (ChoreoInstance, error)

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

+ type Event int

+ const Activate

+ const DeActivate

+ func (r Event) String() string

+ type MainChoreoInstance struct

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

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

+ func (r *MainChoreoInstance) GetAnnotationVal() string

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

+ func (r *MainChoreoInstance) GetDBPath() string

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

+ func (r *MainChoreoInstance) GetName() string

+ func (r *MainChoreoInstance) GetPath() string

+ func (r *MainChoreoInstance) GetPathInRepo() string

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

+ func (r *MainChoreoInstance) GetRepoPath() string

+ func (r *MainChoreoInstance) GetTempPath() string

+ func (r *MainChoreoInstance) LoadInternalAPIs() error

+ type NotCheckedOut struct

+ Choreo *choreo

+ Client resourceclient.Client

+ Commit *object.Commit

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

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

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

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

+ func (r *NotCheckedOut) String() string

+ type Reconciler interface

+ Start func(ctx context.Context)

+ Stop func()

+ func NewAPIReconciler(choreoInstance ChoreoInstance, client resourceclient.Client, branch string, ...) Reconciler

+ type State interface

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

+ DeActivate func(ctx context.Context, branchCtx *BranchCtx) error

+ GetCommit func() *object.Commit

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

+ String func() string