Documentation
¶
Index ¶
- Constants
- func RegisterProjections(pe projections.StreamProjectionEngine)
- type CommitActivityProjections
- type CommitActivityState
- type EventsActivityProjections
- type EventsActivityState
- type ForksActivityProjections
- type ForksActivityState
- type IssueCommentsActivityProjections
- type IssueCommentsActivityState
- type IssuesActivityProjections
- type IssuesActivityState
- type IssuesAgeProjections
- type IssuesAgeState
- type PullRequestActivityProjections
- type PullRequestActivityState
- type PullRequestAgeProjections
- type PullRequestAgeState
- type PullRequestCommentsActivityProjections
- type PullRequestCommentsActivityState
- type PullRequestOpenedToMergedProjections
- type PullRequestOpenedToMergedState
- type ReleaseAnnotationProjections
- type ReleaseAnnotationState
- type SplitByEventTypeProjections
- type StargazersActivityProjections
- type StargazersActivityState
Constants ¶
View Source
const ( DailyCommitActivityStream = "d_commits" WeeklyCommitActivityStream = "w_commits" MonthlyCommitActivityStream = "m_commits" QuarterlyCommitActivityStream = "q_commits" YearlyCommitActivityStream = "y_commits" SevenDaysMovingAverageCommitActivityStream = "d7_commits" TwentyFourHoursMovingAverageCommitActivityStream = "h24_commits" CommitActivityStream = "all_commits" )
View Source
const ( DailyEventsActivityStream = "d_events" WeeklyEventsActivityStream = "w_events" MonthlyEventsActivityStream = "m_events" QuarterlyEventsActivityStream = "q_events" YearlyEventsActivityStream = "y_events" SevenDaysMovingAverageEventsActivityStream = "d7_events" EventsActivityStream = "all_events" )
View Source
const ( DailyForksActivityStream = "d_forks" WeeklyForksActivityStream = "w_forks" MonthlyForksActivityStream = "m_forks" QuarterlyForksActivityStream = "q_forks" YearlyForksActivityStream = "y_forks" ForksActivityStream = "all_forks" )
View Source
const ( DailyIssueCommentsActivityStream = "d_issue_comments" WeeklyIssueCommentsActivityStream = "w_issue_comments" MonthlyIssueCommentsActivityStream = "m_issue_comments" QuarterlyIssueCommentsActivityStream = "q_issue_comments" YearlyIssueCommentsActivityStream = "y_issue_comments" SevenDaysMovingAverageIssueCommentsActivityStream = "d7_issue_comments" IssueCommentsActivityStream = "all_issue_comments" )
View Source
const ( DailyIssuesActivityStream = "d_issues" WeeklyIssuesActivityStream = "w_issues" MonthlyIssuesActivityStream = "m_issues" QuarterlyIssuesActivityStream = "q_issues" YearlyIssuesActivityStream = "y_issues" SevenDaysMovingAverageIssuesActivityStream = "d7_issues" IssuesActivityStream = "all_issues" )
View Source
const ( DailyIssuesAgeStream = "d_issues_age" WeeklyIssuesAgeStream = "w_issues_age" MonthlyIssuesAgeStream = "m_issues_age" QuarterlyIssuesAgeStream = "q_issues_age" YearlyIssuesAgeStream = "y_issues_age" SevenDaysMovingAverageIssuesAgeStream = "d7_issues_age" IssuesAgeStream = "all_issues_age" )
View Source
const ( DailyPullRequestActivityStream = "d_prs" WeeklyPullRequestActivityStream = "w_prs" MonthlyPullRequestActivityStream = "m_prs" QuarterlyPullRequestActivityStream = "q_prs" YearlyPullRequestActivityStream = "y_prs" SevenDaysMovingAveragePullRequestActivityStream = "d7_prs" PullRequestActivityStream = "all_prs" )
View Source
const ( DailyPullRequestAgeStream = "d_pr_age" WeeklyPullRequestAgeStream = "w_pr_age" MonthlyPullRequestAgeStream = "m_pr_age" QuarterlyPullRequestAgeStream = "q_pr_age" YearlyPullRequestAgeStream = "y_pr_age" SevenDaysMovingAveragePullRequestAgeStream = "d7_pr_age" PullRequestAgeStream = "all_pr_age" )
View Source
const ( DailyPullRequestOpenedToMergedStream = "d_pr_otm" WeeklyPullRequestOpenedToMergedStream = "w_pr_otm" MonthlyPullRequestOpenedToMergedStream = "m_pr_otm" QuarterlyPullRequestOpenedToMergedStream = "q_pr_otm" YearlyPullRequestOpenedToMergedStream = "y_pr_otm" SevenDaysMovingAveragePullRequestOpenedToMergedStream = "d7_pr_otm" PullRequestOpenedToMergedStream = "all_pr_otm" )
View Source
const ( DailyPullRequestCommentsActivityStream = "d_pr_comments" WeeklyPullRequestCommentsActivityStream = "w_pr_comments" MonthlyPullRequestCommentsActivityStream = "m_pr_comments" QuarterlyPullRequestCommentsActivityStream = "q_pr_comments" YearlyPullRequestCommentsActivityStream = "y_pr_comments" SevenDaysMovingAveragePullRequestCommentsActivityStream = "d7_pr_comments" PullRequestCommentsActivityStream = "all_pr_comments" )
View Source
const ( GithubEventStream = "github_events" IssuesEventStream = "IssuesEvent" PullRequestEventStream = "PullRequestEvent" IssueCommentEventStream = "IssueCommentEvent" PushEventStream = "PushEvent" ReleaseEventStream = "ReleaseEvent" ForkEventStream = "ForkEvent" WatchEventStream = "WatchEvent" )
View Source
const ( DailyStargazersActivityStream = "d_stars" WeeklyStargazersActivityStream = "w_stars" MonthlyStargazersActivityStream = "m_stars" QuarterlyStargazersActivityStream = "q_stars" YearlyStargazersActivityStream = "y_stars" StargazersActivityStream = "all_stars" )
Variables ¶
This section is empty.
Functions ¶
func RegisterProjections ¶
func RegisterProjections(pe projections.StreamProjectionEngine)
Types ¶
type CommitActivityProjections ¶
type CommitActivityProjections struct {
// contains filtered or unexported fields
}
func NewCommitActivityProjections ¶
func NewCommitActivityProjections() *CommitActivityProjections
func (*CommitActivityProjections) Register ¶
func (p *CommitActivityProjections) Register(engine projections.StreamProjectionEngine)
type CommitActivityState ¶
type EventsActivityProjections ¶
type EventsActivityProjections struct {
// contains filtered or unexported fields
}
func NewEventsActivityProjections ¶
func NewEventsActivityProjections() *EventsActivityProjections
func (*EventsActivityProjections) Register ¶
func (p *EventsActivityProjections) Register(engine projections.StreamProjectionEngine)
type EventsActivityState ¶
type ForksActivityProjections ¶
type ForksActivityProjections struct {
// contains filtered or unexported fields
}
func NewForksActivityProjections ¶
func NewForksActivityProjections() *ForksActivityProjections
func (*ForksActivityProjections) Register ¶
func (p *ForksActivityProjections) Register(engine projections.StreamProjectionEngine)
type ForksActivityState ¶
type IssueCommentsActivityProjections ¶
type IssueCommentsActivityProjections struct {
// contains filtered or unexported fields
}
func NewIssueCommentsActivityProjections ¶
func NewIssueCommentsActivityProjections() *IssueCommentsActivityProjections
func (*IssueCommentsActivityProjections) Register ¶
func (p *IssueCommentsActivityProjections) Register(engine projections.StreamProjectionEngine)
type IssuesActivityProjections ¶
type IssuesActivityProjections struct {
// contains filtered or unexported fields
}
func NewIssuesActivityProjections ¶
func NewIssuesActivityProjections() *IssuesActivityProjections
func (*IssuesActivityProjections) Register ¶
func (p *IssuesActivityProjections) Register(engine projections.StreamProjectionEngine)
type IssuesActivityState ¶
type IssuesAgeProjections ¶
type IssuesAgeProjections struct { ViewProjections *issuesViewProjections // contains filtered or unexported fields }
func NewIssuesAgeProjections ¶
func NewIssuesAgeProjections() *IssuesAgeProjections
func (*IssuesAgeProjections) Register ¶
func (p *IssuesAgeProjections) Register(engine projections.StreamProjectionEngine)
type IssuesAgeState ¶
type PullRequestActivityProjections ¶
type PullRequestActivityProjections struct {
// contains filtered or unexported fields
}
func NewPullRequestActivityProjections ¶
func NewPullRequestActivityProjections() *PullRequestActivityProjections
func (*PullRequestActivityProjections) Register ¶
func (p *PullRequestActivityProjections) Register(engine projections.StreamProjectionEngine)
type PullRequestActivityState ¶
type PullRequestActivityState struct { Time time.Time `persist:",primarykey"` Period string `persist:",primarykey"` Repo string `persist:",primarykey"` ProposedBy string `persist:"proposed_by,primarykey"` Opened float64 Merged float64 ClosedWithUnmergedCommits float64 `persist:"closed_with_unmerged_commits"` }
type PullRequestAgeProjections ¶
type PullRequestAgeProjections struct { ViewProjections *pullRequestViewProjections // contains filtered or unexported fields }
func NewPullRequestAgeProjections ¶
func NewPullRequestAgeProjections() *PullRequestAgeProjections
func (*PullRequestAgeProjections) Register ¶
func (p *PullRequestAgeProjections) Register(engine projections.StreamProjectionEngine)
type PullRequestAgeState ¶
type PullRequestCommentsActivityProjections ¶
type PullRequestCommentsActivityProjections struct {
// contains filtered or unexported fields
}
func NewPullRequestCommentsActivityProjections ¶
func NewPullRequestCommentsActivityProjections() *PullRequestCommentsActivityProjections
func (*PullRequestCommentsActivityProjections) Register ¶
func (p *PullRequestCommentsActivityProjections) Register(engine projections.StreamProjectionEngine)
type PullRequestOpenedToMergedProjections ¶
type PullRequestOpenedToMergedProjections struct { ViewProjections *pullRequestViewProjections // contains filtered or unexported fields }
func NewPullRequestOpenedToMergedProjections ¶
func NewPullRequestOpenedToMergedProjections() *PullRequestOpenedToMergedProjections
func (*PullRequestOpenedToMergedProjections) Register ¶
func (p *PullRequestOpenedToMergedProjections) Register(engine projections.StreamProjectionEngine)
type PullRequestOpenedToMergedState ¶
type PullRequestOpenedToMergedState struct { Time time.Time `persist:",primarykey"` Period string `persist:",primarykey"` Repo string `persist:",primarykey"` ProposedBy string `persist:"proposed_by,primarykey"` Percentile15 float64 `persist:"p15"` Percentile50 float64 `persist:"p50"` Percentile85 float64 `persist:"p85"` // contains filtered or unexported fields }
type ReleaseAnnotationProjections ¶
type ReleaseAnnotationProjections struct {
// contains filtered or unexported fields
}
func NewReleaseAnnotationProjections ¶
func NewReleaseAnnotationProjections() *ReleaseAnnotationProjections
func (*ReleaseAnnotationProjections) Register ¶
func (p *ReleaseAnnotationProjections) Register(engine projections.StreamProjectionEngine)
type ReleaseAnnotationState ¶
type SplitByEventTypeProjections ¶
type SplitByEventTypeProjections struct {
// contains filtered or unexported fields
}
func NewSplitByEventTypeProjections ¶
func NewSplitByEventTypeProjections() *SplitByEventTypeProjections
func (*SplitByEventTypeProjections) Register ¶
func (p *SplitByEventTypeProjections) Register(engine projections.StreamProjectionEngine)
type StargazersActivityProjections ¶
type StargazersActivityProjections struct {
// contains filtered or unexported fields
}
func NewStargazersActivityProjections ¶
func NewStargazersActivityProjections() *StargazersActivityProjections
func (*StargazersActivityProjections) Register ¶
func (p *StargazersActivityProjections) Register(engine projections.StreamProjectionEngine)
Click to show internal directories.
Click to hide internal directories.