implementation

Documentation

Index

• Variables
• type Auth
• type FileKind
• type Gitops
  • func New(definition *v1.GitopsDefinition) *Gitops
  • func (gitops *Gitops) Clone(auth transport.AuthMethod) error
  • func (gitops *Gitops) Drift(client *client.Http, user *authentication.User, definitionsOrdered []FileKind) (bool, error)
  • func (gitops *Gitops) Fetch() error
  • func (gitops *Gitops) GenerateHttpAuth(definition *v1.HttpAuthDefinition) (transport.AuthMethod, error)
  • func (gitops *Gitops) GenerateSshAuth(definition *v1.CertKeyDefinition) (transport.AuthMethod, error)
  • func (gitops *Gitops) PathExists() bool
  • func (gitops *Gitops) Prepare(client *client.Http, user *authentication.User) error
  • func (gitops *Gitops) Pull(auth transport.AuthMethod) error
  • func (gitops *Gitops) ReadDefinitions(relations *relations.RelationRegistry) ([]FileKind, error)
  • func (gitops *Gitops) RemoteHead() (plumbing.Hash, error)
  • func (gitops *Gitops) Sync(logger *zap.Logger, client *client.Http, user *authentication.User, ...) ([]*common.Request, error)

Variables

var (
	ErrPoolingInterval = errors.New("sleep interval didn't pass")
)

Types

type Auth

type Auth struct {
	CertKeyRef  v1.GitopsCertKeyRef
	HttpAuthRef v1.GitopsHttpauthRef
}

type FileKind

type FileKind struct {
	File string
	Kind string
}

type Gitops

type Gitops struct {
	RepoURL         string
	Revision        string
	DirectoryPath   string
	PoolingInterval string
	LastPoll        time.Time
	ForcePoll       bool
	AutomaticSync   bool
	ManualSync      bool
	Commit          *object.Commit
	Path            string
	Status          *status.Status
	Auth            *Auth
	AuthResolved    transport.AuthMethod `json:"-"`
	API             string
	Context         string
	Definition      *v1.GitopsDefinition
	Definitions     []common.Request
}

func New

func New(definition *v1.GitopsDefinition) *Gitops

func (*Gitops) Clone

func (gitops *Gitops) Clone(auth transport.AuthMethod) error

func (*Gitops) Drift

func (gitops *Gitops) Drift(client *client.Http, user *authentication.User, definitionsOrdered []FileKind) (bool, error)

func (*Gitops) Fetch

func (gitops *Gitops) Fetch() error

func (*Gitops) GenerateHttpAuth

func (gitops *Gitops) GenerateHttpAuth(definition *v1.HttpAuthDefinition) (transport.AuthMethod, error)

func (*Gitops) GenerateSshAuth

func (gitops *Gitops) GenerateSshAuth(definition *v1.CertKeyDefinition) (transport.AuthMethod, error)

func (*Gitops) PathExists

func (gitops *Gitops) PathExists() bool

func (*Gitops) Prepare

func (gitops *Gitops) Prepare(client *client.Http, user *authentication.User) error

func (*Gitops) Pull

func (gitops *Gitops) Pull(auth transport.AuthMethod) error

func (*Gitops) ReadDefinitions

func (gitops *Gitops) ReadDefinitions(relations *relations.RelationRegistry) ([]FileKind, error)

func (*Gitops) RemoteHead

func (gitops *Gitops) RemoteHead() (plumbing.Hash, error)

func (*Gitops) Sync

func (gitops *Gitops) Sync(logger *zap.Logger, client *client.Http, user *authentication.User, definitionsOrdered []FileKind) ([]*common.Request, error)