Documentation ¶
Index ¶
- func NewRepoSet(sizeHint int) *repoSet
- type ChangeFetcher
- type ChangeFetcherNotificationComposer
- type ChangeScheduler
- type CloneMsg
- type Cloner
- type ClonerNotificationComposer
- type GitBranchCloneClient
- type GitBranchCredentialsCounterClient
- type GitFetchClient
- type GitGetParentsDiffClient
- type GitHubClient
- type GitHubOrganization
- type GitHubRepository
- type HeadCredentialCounter
- type NotificationComposer
- type NotificationComposerScanner
- type ObliviousHealthCheck
- type RepoChangeScheduler
- type RepoDiscoverer
- type RepoDiscovererGitHubClient
- type Rescanner
- type RescannerScanner
- type Scanner
- type ScheduleRunner
- type Scheduler
- type SchedulerChangeFetcher
- type Server
- func (s *Server) BoshBlobs(ctx context.Context, request *revokpb.BoshBlobsRequest) (*revokpb.BoshBlobsResponse, error)
- func (s *Server) GetCredentialCounts(ctx context.Context, in *revokpb.CredentialCountRequest) (*revokpb.CredentialCountResponse, error)
- func (s *Server) GetOrganizationCredentialCounts(ctx context.Context, in *revokpb.OrganizationCredentialCountRequest) (*revokpb.OrganizationCredentialCountResponse, error)
- func (s *Server) GetRepositoryCredentialCounts(ctx context.Context, in *revokpb.RepositoryCredentialCountRequest) (*revokpb.RepositoryCredentialCountResponse, error)
- func (s *Server) Search(query *revokpb.SearchQuery, stream revokpb.Revok_SearchServer) error
- type Sink
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRepoSet ¶
func NewRepoSet(sizeHint int) *repoSet
Types ¶
type ChangeFetcher ¶
type ChangeFetcher struct {
// contains filtered or unexported fields
}
func NewChangeFetcher ¶
func NewChangeFetcher( logger lager.Logger, gitClient GitFetchClient, notificationComposer ChangeFetcherNotificationComposer, repositoryRepository db.RepositoryRepository, fetchRepository db.FetchRepository, emitter metrics.Emitter, ) *ChangeFetcher
type ChangeScheduler ¶
type ChangeScheduler struct {
// contains filtered or unexported fields
}
func NewChangeScheduler ¶
func NewChangeScheduler(logger lager.Logger, repoRepo db.RepositoryRepository, scheduler Scheduler, fetcher SchedulerChangeFetcher) *ChangeScheduler
func (*ChangeScheduler) Run ¶
func (s *ChangeScheduler) Run(signals <-chan os.Signal, ready chan<- struct{}) error
func (*ChangeScheduler) ScheduleActiveRepos ¶
func (s *ChangeScheduler) ScheduleActiveRepos(logger lager.Logger) error
func (*ChangeScheduler) ScheduleRepo ¶
func (s *ChangeScheduler) ScheduleRepo(logger lager.Logger, repo db.Repository)
type Cloner ¶
type Cloner struct {
// contains filtered or unexported fields
}
func NewCloner ¶
func NewCloner( logger lager.Logger, workdir string, workCh chan CloneMsg, gitClient GitBranchCloneClient, repositoryRepository db.RepositoryRepository, notificationComposer ClonerNotificationComposer, emitter metrics.Emitter, scheduler RepoChangeScheduler, ) *Cloner
type GitBranchCloneClient ¶
type GitGetParentsDiffClient ¶
type GitHubClient ¶
type GitHubClient struct {
// contains filtered or unexported fields
}
func NewGitHubClient ¶
func NewGitHubClient( ghClient *github.Client, ) *GitHubClient
func (*GitHubClient) ListRepositoriesByOrg ¶
func (c *GitHubClient) ListRepositoriesByOrg(logger lager.Logger, orgName string) ([]GitHubRepository, error)
func (*GitHubClient) ListRepositoriesByUser ¶
func (c *GitHubClient) ListRepositoriesByUser(logger lager.Logger, userName string) ([]GitHubRepository, error)
type GitHubOrganization ¶
type GitHubOrganization struct {
Name string `json:"login"`
}
type GitHubRepository ¶
type HeadCredentialCounter ¶
type HeadCredentialCounter struct {
// contains filtered or unexported fields
}
func NewHeadCredentialCounter ¶
func NewHeadCredentialCounter( logger lager.Logger, branchRepository db.BranchRepository, repositoryRepository db.RepositoryRepository, clock clock.Clock, interval time.Duration, gitClient GitBranchCredentialsCounterClient, sniffer sniff.Sniffer, ) *HeadCredentialCounter
type NotificationComposer ¶
type NotificationComposer struct {
// contains filtered or unexported fields
}
func NewNotificationComposer ¶
func NewNotificationComposer( repositoryRepository db.RepositoryRepository, router notifications.Router, scanner NotificationComposerScanner, ) *NotificationComposer
type ObliviousHealthCheck ¶
type ObliviousHealthCheck struct{}
func NewObliviousHealthCheck ¶
func NewObliviousHealthCheck() *ObliviousHealthCheck
func (*ObliviousHealthCheck) ServeHTTP ¶
func (hc *ObliviousHealthCheck) ServeHTTP(w http.ResponseWriter, r *http.Request)
type RepoChangeScheduler ¶
type RepoChangeScheduler interface {
ScheduleRepo(lager.Logger, db.Repository)
}
type RepoDiscoverer ¶
type RepoDiscoverer struct {
// contains filtered or unexported fields
}
func NewRepoDiscoverer ¶
func NewRepoDiscoverer( logger lager.Logger, workdir string, cloneMsgCh chan CloneMsg, ghClient RepoDiscovererGitHubClient, clock clock.Clock, interval time.Duration, orgs []string, users []string, repositoryRepository db.RepositoryRepository, ) *RepoDiscoverer
type RepoDiscovererGitHubClient ¶
type RepoDiscovererGitHubClient interface { ListRepositoriesByOrg(lager.Logger, string) ([]GitHubRepository, error) ListRepositoriesByUser(lager.Logger, string) ([]GitHubRepository, error) }
type Rescanner ¶
type Rescanner struct {
// contains filtered or unexported fields
}
func NewRescanner ¶
func NewRescanner( logger lager.Logger, scanRepo db.ScanRepository, credRepo db.CredentialRepository, scanner RescannerScanner, router notifications.Router, emitter metrics.Emitter, ) *Rescanner
type RescannerScanner ¶
type Scanner ¶
type Scanner struct {
// contains filtered or unexported fields
}
func NewScanner ¶
func NewScanner( gitClient GitGetParentsDiffClient, repositoryRepository db.RepositoryRepository, scanRepository db.ScanRepository, credentialRepository db.CredentialRepository, sniffer sniff.Sniffer, ) *Scanner
type ScheduleRunner ¶
type ScheduleRunner struct {
// contains filtered or unexported fields
}
func NewScheduleRunner ¶
func NewScheduleRunner(logger lager.Logger) *ScheduleRunner
func (*ScheduleRunner) Run ¶
func (s *ScheduleRunner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
func (*ScheduleRunner) ScheduleWork ¶
func (s *ScheduleRunner) ScheduleWork(cron string, work func())
type SchedulerChangeFetcher ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer( logger lager.Logger, searcher search.Searcher, blobSearcher search.BlobSearcher, repositoryRepository db.RepositoryRepository, branchRepository db.BranchRepository, ) *Server
func (*Server) BoshBlobs ¶
func (s *Server) BoshBlobs(ctx context.Context, request *revokpb.BoshBlobsRequest) (*revokpb.BoshBlobsResponse, error)
func (*Server) GetCredentialCounts ¶
func (s *Server) GetCredentialCounts( ctx context.Context, in *revokpb.CredentialCountRequest, ) (*revokpb.CredentialCountResponse, error)
func (*Server) GetOrganizationCredentialCounts ¶
func (s *Server) GetOrganizationCredentialCounts( ctx context.Context, in *revokpb.OrganizationCredentialCountRequest, ) (*revokpb.OrganizationCredentialCountResponse, error)
func (*Server) GetRepositoryCredentialCounts ¶
func (s *Server) GetRepositoryCredentialCounts( ctx context.Context, in *revokpb.RepositoryCredentialCountRequest, ) (*revokpb.RepositoryCredentialCountResponse, error)
func (*Server) Search ¶
func (s *Server) Search(query *revokpb.SearchQuery, stream revokpb.Revok_SearchServer) error
type Sink ¶
type Sink struct { }
Sink is the type that represents the sink that will emit errors to Sentry.
func NewSentrySink ¶
NewSentrySink creates a new Sink for use with Lager.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.