mcmhub

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

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

type EqualSub func(*subv1.Subscription, *subv1.Subscription) bool

type FormatFunc func(ansiblejob.AnsibleJob) string

type GitOps interface {
	//DownloadAnsibleHookResource downloads the ansible job from the git and marshal
	//the resource to
	DownloadAnsibleHookResource(*subv1.Subscription) error

	HasHookFolders(*subv1.Subscription) bool

	// GetHooks returns the ansiblejob from a given folder, if the folder is
	// inaccessible, then os.Error is returned
	GetHooks(*subv1.Subscription, string) ([]ansiblejob.AnsibleJob, error)

	// RegisterBranch to git watcher and do a initial download for other
	// components to consume
	RegisterBranch(*subv1.Subscription) error

	// DeregisterBranch
	DeregisterBranch(types.NamespacedName)

	//helper for test
	GetRepoRecords() map[string]*RepoRegistery
	GetSubRecords() map[types.NamespacedName]string

	//GetLatestCommitID will output the latest commit id from local git record
	GetLatestCommitID(*subv1.Subscription) (string, error)
	//ResolveLocalGitFolder is used to open a local folder for downloading the
	//repo branch
	ResolveLocalGitFolder(*subv1.Subscription) string

	GetRepoRootDirctory(*subv1.Subscription) string

	//Runnable
	Start(context.Context) error
}

type HookOps func(*AnsibleHooks)

type HookProcessor interface {
	// register subsription to the HookProcessor
	RegisterSubscription(*subv1.Subscription, bool, string) error
	DeregisterSubscription(types.NamespacedName) error

	//SetSuffixFunc let user reset the suffixFunc rule of generating the suffix
	//of hook instance name
	SetSuffixFunc(SuffixFunc)
	ResetGitOps(GitOps)
	//ApplyPreHook returns a type.NamespacedName of the preHook
	ApplyPreHooks(types.NamespacedName) error
	IsPreHooksCompleted(types.NamespacedName) (bool, error)
	ApplyPostHooks(types.NamespacedName) error
	IsPostHooksCompleted(types.NamespacedName) (bool, error)

	HasHooks(string, types.NamespacedName) bool
	//WriteStatusToSubscription gets the status at the entry of the reconcile,
	//also the procssed subscription(which should carry all the update status on
	//the given reconciel), then  WriteStatusToSubscription will append the hook
	//status info and make a update to the cluster
	AppendStatusToSubscription(*subv1.Subscription) subv1.SubscriptionStatus

	AppendPreHookStatusToSubscription(*subv1.Subscription) subv1.SubscriptionStatus

	GetLastAppliedInstance(types.NamespacedName) AppliedInstance
}

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

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

type HubGitOption func(*HubGitOps)

type Job struct {
	Original ansiblejob.AnsibleJob
	Instance []ansiblejob.AnsibleJob
	// track the create instance
	InstanceSet map[types.NamespacedName]struct{}
	// contains filtered or unexported fields
}

type JobInstances map[types.NamespacedName]*Job

type ManageClusters struct {
	Cluster        string
	IsLocalCluster bool
}

type Option func(*ReconcileSubscription)

type ReconcileSubscription struct {
	client.Client
	// contains filtered or unexported fields
}

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

type SuffixFunc func(GitOps, *subv1.Subscription) string