deep

Documentation

Index

• func NewIssueCommentSyncJob(owner, name string, id int64) (*queue.Job, error)
• func NewIssueSyncJob(owner, name string, number int) (*queue.Job, error)
• func NewPullRequestCommentSyncJob(owner, name string, id int64) (*queue.Job, error)
• func NewPullRequestReviewSyncJob(owner, name string, number int, id int64) (*queue.Job, error)
• func NewPullRequestSyncJob(owner, name string, number int) (*queue.Job, error)
• func NewRepositorySyncJob(owner, name string) (*queue.Job, error)
• func NewUserSyncJob(login string) (*queue.Job, error)
• type IssueCommentSyncPayload
• type IssueCommentsSyncer
  • func NewIssueCommentsSyncer(db *sql.DB, c *github.Client) *IssueCommentsSyncer
  • func (s *IssueCommentsSyncer) Sync(owner string, repo string, commentID int64) error
  • func (s *IssueCommentsSyncer) SyncIssue(owner, repo string, number int) error
  • func (s *IssueCommentsSyncer) SyncRepository(owner, repo string) error
• type IssueSyncPayload
• type IssueSyncer
  • func NewIssueSyncer(db *sql.DB, c *github.Client) *IssueSyncer
  • func (s *IssueSyncer) QueueRepository(q queue.Queue, owner, repo string) error
  • func (s *IssueSyncer) Sync(owner string, repo string, number int) error
• type OrganizationSyncer
  • func NewOrganizationSyncer(db *sql.DB, c *github.Client) *OrganizationSyncer
  • func (s *OrganizationSyncer) Sync(login string) error
• type PullRequestCommentSyncer
  • func NewPullRequestCommentSyncer(db *sql.DB, c *github.Client) *PullRequestCommentSyncer
  • func (s *PullRequestCommentSyncer) Sync(owner string, repo string, commentID int64) error
  • func (s *PullRequestCommentSyncer) SyncPullRequest(owner, repo string, number int) error
  • func (s *PullRequestCommentSyncer) SyncRepository(owner, repo string) error
• type PullRequestReviewSyncPayload
• type PullRequestReviewSyncer
  • func NewPullRequestReviewSyncer(db *sql.DB, c *github.Client) *PullRequestReviewSyncer
  • func (s *PullRequestReviewSyncer) Sync(owner string, repo string, number int, reviewID int64) error
  • func (s *PullRequestReviewSyncer) SyncPullRequest(owner, repo string, number int) error
• type PullRequestSyncer
  • func NewPullRequestSyncer(db *sql.DB, c *github.Client) *PullRequestSyncer
  • func (s *PullRequestSyncer) QueueRepository(q queue.Queue, owner, repo string) error
  • func (s *PullRequestSyncer) Sync(owner string, repo string, number int) error
• type RepositorySyncPayload
• type RepositorySyncer
  • func NewRepositorySyncer(db *sql.DB, c *github.Client) *RepositorySyncer
  • func (s *RepositorySyncer) QueueOrganization(q queue.Queue, owner string) error
  • func (s *RepositorySyncer) Sync(owner, name string) error
• type SyncTaskType
• type SyncTasks
• type Syncer
  • func NewSyncer(db *sql.DB, c *github.Client, q queue.Queue) *Syncer
  • func (s *Syncer) DoOrganization(org string) error
  • func (s *Syncer) Wait() error
• type UserSyncPayload
• type UserSyncer
  • func NewUserSyncer(db *sql.DB, c *github.Client) *UserSyncer
  • func (s *UserSyncer) QueueOrganization(q queue.Queue, org string) error
  • func (s *UserSyncer) Sync(login string) error

Functions

func NewIssueCommentSyncJob

func NewIssueCommentSyncJob(owner, name string, id int64) (*queue.Job, error)

func NewIssueSyncJob

func NewIssueSyncJob(owner, name string, number int) (*queue.Job, error)

func NewPullRequestCommentSyncJob

func NewPullRequestCommentSyncJob(owner, name string, id int64) (*queue.Job, error)

func NewPullRequestReviewSyncJob

func NewPullRequestReviewSyncJob(owner, name string, number int, id int64) (*queue.Job, error)

func NewPullRequestSyncJob

func NewPullRequestSyncJob(owner, name string, number int) (*queue.Job, error)

func NewRepositorySyncJob

func NewRepositorySyncJob(owner, name string) (*queue.Job, error)

func NewUserSyncJob

func NewUserSyncJob(login string) (*queue.Job, error)

Types

type IssueCommentSyncPayload

type IssueCommentSyncPayload struct {
	Owner     string
	Name      string
	CommentID uint64
}

type IssueCommentsSyncer

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

func NewIssueCommentsSyncer

func NewIssueCommentsSyncer(db *sql.DB, c *github.Client) *IssueCommentsSyncer

func (*IssueCommentsSyncer) Sync

func (s *IssueCommentsSyncer) Sync(owner string, repo string, commentID int64) error

func (*IssueCommentsSyncer) SyncIssue

func (s *IssueCommentsSyncer) SyncIssue(owner, repo string, number int) error

func (*IssueCommentsSyncer) SyncRepository

func (s *IssueCommentsSyncer) SyncRepository(owner, repo string) error

type IssueSyncPayload

type IssueSyncPayload struct {
	Owner  string
	Name   string
	Number uint64
}

type IssueSyncer

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

func NewIssueSyncer

func NewIssueSyncer(db *sql.DB, c *github.Client) *IssueSyncer

func (*IssueSyncer) QueueRepository

func (s *IssueSyncer) QueueRepository(q queue.Queue, owner, repo string) error

func (*IssueSyncer) Sync

func (s *IssueSyncer) Sync(owner string, repo string, number int) error

type OrganizationSyncer

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

func NewOrganizationSyncer

func NewOrganizationSyncer(db *sql.DB, c *github.Client) *OrganizationSyncer

func (*OrganizationSyncer) Sync

func (s *OrganizationSyncer) Sync(login string) error

type PullRequestCommentSyncer

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

func NewPullRequestCommentSyncer

func NewPullRequestCommentSyncer(db *sql.DB, c *github.Client) *PullRequestCommentSyncer

func (*PullRequestCommentSyncer) Sync

func (s *PullRequestCommentSyncer) Sync(owner string, repo string, commentID int64) error

func (*PullRequestCommentSyncer) SyncPullRequest

func (s *PullRequestCommentSyncer) SyncPullRequest(owner, repo string, number int) error

func (*PullRequestCommentSyncer) SyncRepository

func (s *PullRequestCommentSyncer) SyncRepository(owner, repo string) error

type PullRequestReviewSyncPayload

type PullRequestReviewSyncPayload struct {
	Owner    string
	Name     string
	Number   uint64
	ReviewID uint64
}

type PullRequestReviewSyncer

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

func NewPullRequestReviewSyncer

func NewPullRequestReviewSyncer(db *sql.DB, c *github.Client) *PullRequestReviewSyncer

func (*PullRequestReviewSyncer) Sync

func (s *PullRequestReviewSyncer) Sync(owner string, repo string, number int, reviewID int64) error

func (*PullRequestReviewSyncer) SyncPullRequest

func (s *PullRequestReviewSyncer) SyncPullRequest(owner, repo string, number int) error

type PullRequestSyncer

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

func NewPullRequestSyncer

func NewPullRequestSyncer(db *sql.DB, c *github.Client) *PullRequestSyncer

func (*PullRequestSyncer) QueueRepository

func (s *PullRequestSyncer) QueueRepository(q queue.Queue, owner, repo string) error

func (*PullRequestSyncer) Sync

func (s *PullRequestSyncer) Sync(owner string, repo string, number int) error

type RepositorySyncPayload

type RepositorySyncPayload struct {
	Owner string
	Name  string
}

type RepositorySyncer

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

func NewRepositorySyncer

func NewRepositorySyncer(db *sql.DB, c *github.Client) *RepositorySyncer

func (*RepositorySyncer) QueueOrganization

func (s *RepositorySyncer) QueueOrganization(q queue.Queue, owner string) error

func (*RepositorySyncer) Sync

func (s *RepositorySyncer) Sync(owner, name string) error

type SyncTaskType

type SyncTaskType string

const (
	RepositorySyncTask         SyncTaskType = "repository"
	UserSyncTask               SyncTaskType = "user"
	IssueSyncTask              SyncTaskType = "issue"
	IssueCommentSyncTask       SyncTaskType = "issue-comment"
	PullRequestSyncTask        SyncTaskType = "pull-request"
	PullRequestCommentSyncTask SyncTaskType = "pull-request-comment"
	PullRequestReviewSyncTask  SyncTaskType = "pull-request-review"
)

type SyncTasks

type SyncTasks struct {
	Type    SyncTaskType
	Payload interface{}
}

type Syncer

type Syncer struct {
	Organization       *OrganizationSyncer
	User               *UserSyncer
	Repository         *RepositorySyncer
	Issues             *IssueSyncer
	IssueComment       *IssueCommentsSyncer
	PullRequest        *PullRequestSyncer
	PullRequestComment *PullRequestCommentSyncer
	PullRequestReview  *PullRequestReviewSyncer
	// contains filtered or unexported fields
}

func NewSyncer

func NewSyncer(db *sql.DB, c *github.Client, q queue.Queue) *Syncer

func (*Syncer) DoOrganization

func (s *Syncer) DoOrganization(org string) error

func (*Syncer) Wait

func (s *Syncer) Wait() error

type UserSyncPayload

type UserSyncPayload struct {
	Login string
}

type UserSyncer

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

func NewUserSyncer

func NewUserSyncer(db *sql.DB, c *github.Client) *UserSyncer

func (*UserSyncer) QueueOrganization

func (s *UserSyncer) QueueOrganization(q queue.Queue, org string) error

func (*UserSyncer) Sync

func (s *UserSyncer) Sync(login string) error