poller

Documentation

Index

• Constants
• func FindMasterRef(refs []*plumbing.Reference) plumbing.Reference
• func HasNewRevision(refs []*plumbing.Reference, previousHash string) (bool, string)
• type GitRemote
• type GitRemoteDelegator
  • func (d GitRemoteDelegator) ListReferences(s storage.Storer, c *config.RemoteConfig, o *git.ListOptions) (rfs []*plumbing.Reference, err error)
• type RepoPoller
  • func NewRepoPoller(repoKey string, repo *repo.Repo, repoStatusManager status.RepoStatusManager, ...) *RepoPoller
  • func (poller *RepoPoller) CheckForNewRevisions()
  • func (poller *RepoPoller) Start()
  • func (poller *RepoPoller) Stop()

Constants

const POLLING_FREQUENCY_SECONDS = 30

Functions

func FindMasterRef

func FindMasterRef(refs []*plumbing.Reference) plumbing.Reference

func HasNewRevision

func HasNewRevision(refs []*plumbing.Reference, previousHash string) (bool, string)

Types

type GitRemote

type GitRemote interface {
	ListReferences(
		s storage.Storer,
		c *config.RemoteConfig,
		o *git.ListOptions,
	) (rfs []*plumbing.Reference, err error)
}

type GitRemoteDelegator

type GitRemoteDelegator struct {
}

func (GitRemoteDelegator) ListReferences

func (d GitRemoteDelegator) ListReferences(
	s storage.Storer,
	c *config.RemoteConfig,
	o *git.ListOptions,
) (rfs []*plumbing.Reference, err error)

type RepoPoller

type RepoPoller struct {
	RepoKey string
	Repo    *repo.Repo
	Ticker  *time.Ticker
	Done    chan bool
	// contains filtered or unexported fields
}

func NewRepoPoller

func NewRepoPoller(repoKey string,
	repo *repo.Repo,
	repoStatusManager status.RepoStatusManager,
	gitRemote GitRemote) *RepoPoller

func (*RepoPoller) CheckForNewRevisions

func (poller *RepoPoller) CheckForNewRevisions()

func (*RepoPoller) Start

func (poller *RepoPoller) Start()

func (*RepoPoller) Stop

func (poller *RepoPoller) Stop()