core

Documentation

Index

• Constants
• Variables
• func CreateBitbucketTable(DB *sql.DB) error
• func CreateCgitTables(DB *sql.DB) error
• func CreateGithubTable(DB *sql.DB) error
• func DropTables(DB *sql.DB, names ...string) error
• type PersistFN
• type RepoProvider
• type Watcher
  • func NewWatcher(providers []RepoProvider, persist PersistFN, timeToSleep time.Duration, ...) *Watcher
  • func (w *Watcher) Start()

Constants

const (
	GithubProviderName    = "github"
	CgitProviderName      = "cgit"
	BitbucketProviderName = "bitbucket"
)

Variables

var (
	Config *config = &config{}
)

var (
	NoErrStopProvider = errors.New("this provider will not return more mentions")
)

Functions

func CreateBitbucketTable

func CreateBitbucketTable(DB *sql.DB) error

TODO temporal method to create bitbucket table

func CreateCgitTables

func CreateCgitTables(DB *sql.DB) error

TODO temporal method to create cgit tables

func CreateGithubTable

func CreateGithubTable(DB *sql.DB) error

TODO temporal method to create github table

func DropTables

func DropTables(DB *sql.DB, names ...string) error

Types

type PersistFN

type PersistFN func(*model.Mention) error

type RepoProvider

type RepoProvider interface {
	Next() (*model.Mention, error)
	Ack(error) error
	Close() error
	Name() string
}

type Watcher

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

func NewWatcher

func NewWatcher(providers []RepoProvider, persist PersistFN,
	timeToSleep time.Duration, timeToRetryAck time.Duration) *Watcher

func (*Watcher) Start

func (w *Watcher) Start()