connector

type CodeOwners struct {
	// Path is a CODEOWNERS file or a repo root to search for one.
	Path string
}

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

type ConfluenceOptions struct {
	// Spaces scopes the search to these space keys.
	Spaces []string
	// CQL overrides the query entirely when set.
	CQL string
	// MaxPages caps pages read; zero uses a default.
	MaxPages int
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

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

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

type GitHubOptions struct {
	// Repos is a list of "owner/name" repositories to index.
	Repos []string
	// Org, when set, adds the org's repositories.
	Org string
	// MaxRepos caps repositories taken from the org; zero means all returned.
	MaxRepos int
	// ResolveEmails fetches each user's profile to join by email.
	ResolveEmails bool
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

type GitOptions struct {
	// Paths are local repository roots to read.
	Paths []string
	// SinceDays bounds how far back to read history; zero means one year.
	SinceDays int
	// MaxCommits caps commits read per repository; zero means 2000.
	MaxCommits int
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

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

type JiraOptions struct {
	// Projects scopes the search to these project keys.
	Projects []string
	// JQL overrides the query entirely when set.
	JQL string
	// MaxIssues caps issues read; zero uses a default.
	MaxIssues int
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

type Kind int

type OrgCSV struct {
	// Path is the CSV file path.
	Path string
	// TopicSep splits the topics column into individual topics; default ";".
	TopicSep string
}

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

type PagerDutyOptions struct {
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

type Record struct {
	// Kind classifies the record; the zero value is KindPerson.
	Kind Kind
	// PersonID is a stable per-source identifier; empty derives one from email.
	PersonID string
	// Name is the person's display name.
	Name string
	// Email is the person's work email.
	Email string
	// Title is the person's job title.
	Title string
	// Team is the person's team name.
	Team string
	// Org is the person's organization name.
	Org string
	// Manager is the manager's email or identifier, if known.
	Manager string
	// Topics are explicit expertise tags for the person or channel.
	Topics []string
	// Members lists person references active in a KindChannel record.
	Members []string
	// Text is free-form text attributed to the person or channel, mined for topics.
	Text string
	// Source names the origin connector, e.g. "org-csv".
	Source string
	// Weight scales this record's affinity contribution; zero means one.
	Weight float64
	// Time is when the described activity happened. The zero value marks the
	// record as a current fact that never decays.
	Time time.Time
}

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

type SlackOptions struct {
	// IncludePrivate also ingests private channels the token can read.
	IncludePrivate bool
	// SinceDays bounds history age; zero uses the default.
	SinceDays int
	// MaxMessages caps messages per channel; zero uses the default.
	MaxMessages int
	// MaxChannels caps channels processed; zero means all.
	MaxChannels int
	// Log receives progress lines; nil discards them.
	Log io.Writer
}

type Source interface {
	// Fetch returns the records this source currently provides.
	Fetch(ctx context.Context) ([]Record, error)
}

type SourceFunc func(ctx context.Context) ([]Record, error)