github

type CreateEvent ¶

type CreateEvent struct {
	RefType string `json:"ref_type"`
}

type Event ¶

type Event struct {
	CreatedAt github.Timestamp `json:"created_at"`
	Payload   json.RawMessage  `json:"payload"`
	Repo      struct {
		Name string `json:"name"`
	} `json:"repo"`
	Type string `json:"type"`
}

type ForkEvent ¶

type ForkEvent struct {
	Forkee struct {
		FullName string `json:"full_name"`
	} `json:"forkee"`
}

type Repo ¶

type Repo struct {
	Stars       int
	Parent      string
	LastUpdated time.Time
}

func (z Repo) MarshalMsg(b []byte) (o []byte, err error)

func (z Repo) Msgsize() (s int)

func (z *Repo) UnmarshalMsg(bts []byte) (o []byte, err error)

type StarTracker ¶

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

StarTracker keeps track of how many stars a repository has. It is backed by a db on disk, goes to GitHub for never-seen-before, and it assumes it will be told about every WatchEvent ever since so that it can keep the number accurate without ever going to the network again.

A StarTracker is not safe to use by multiple goroutines at the same time, and it assumes WatchEvents and Gets are submited sequentially anyway. However, it is fully idempotent.

func NewStarTracker(db *bolt.DB, gitHubToken string) *StarTracker

func (s *StarTracker) CreateEvent(name, parent string, created time.Time) error

func (s *StarTracker) Expvar() *expvar.Map

func (s *StarTracker) Get(name string) (stars int, parent string, err error)

func (s *StarTracker) WatchEvent(name string, created time.Time) error

type TimelineArchiveReader ¶

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

TimelineArchiveReader reads a .json.gz like those offered by githubarchive.org

func NewTimelineArchiveReader(r io.Reader) (*TimelineArchiveReader, error)

func (t *TimelineArchiveReader) Close() error

func (t *TimelineArchiveReader) Read(e *Event) error