inventory

type ChangePage struct {
	domain.Page[forge.Change]
	SnapshotState     string     `json:"snapshot_state"`
	ObservedAt        *time.Time `json:"observed_at,omitempty"`
	ConnectionVersion int64      `json:"connection_version"`
}

type Decoder func(string, string, http.Header, []byte) (forge.Event, error)

type ImportInput struct {
	All       bool     `json:"all"`
	NativeIDs []string `json:"native_ids"`
	TeamIDs   []string `json:"team_ids"`
}

type IssuedWebhook struct {
	Webhook
	Secret string `json:"secret"`
}

type Job struct {
	ID                string     `json:"id"`
	OrgID             string     `json:"org_id"`
	ConnectionID      string     `json:"connection_id"`
	ConnectionVersion int64      `json:"connection_version"`
	Namespace         string     `json:"namespace"`
	Kind              string     `json:"kind"`
	RepositoryID      string     `json:"repository_id,omitempty"`
	ParentID          string     `json:"parent_id,omitempty"`
	RequestedBy       string     `json:"-"`
	Input             []byte     `json:"-"`
	State             string     `json:"state"`
	Reason            string     `json:"reason,omitempty"`
	Cursor            string     `json:"-"`
	Phase             string     `json:"-"`
	Pages             int        `json:"pages"`
	Processed         int        `json:"processed"`
	Failures          int        `json:"failures"`
	Fence             int64      `json:"-"`
	LeaseOwner        string     `json:"-"`
	LeaseUntil        *time.Time `json:"-"`
	AvailableAt       time.Time  `json:"available_at"`
	Version           int64      `json:"version"`
	CreatedAt         time.Time  `json:"created_at"`
	UpdatedAt         time.Time  `json:"updated_at"`
}

type Reader interface {
	Read(context.Context, string, string, privateconnector.Operation, func(context.Context, pgx.Tx, connections.Connection) error) (privateconnector.Result, error)
}

type Repository struct {
	domain.Repository
	SyncState         string     `json:"sync_state"`
	SyncReason        string     `json:"sync_reason,omitempty"`
	ConnectionVersion int64      `json:"connection_version"`
	ChangesObservedAt *time.Time `json:"changes_observed_at,omitempty"`
	PauseVersion      int64      `json:"pause_version"`
}

type RepositoryFilter struct {
	Query    string
	Provider string
	TeamID   string
	Status   string
}

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

type SyncInput struct {
	ConnectionID string `json:"connection_id"`
	Namespace    string `json:"namespace"`
}

type Webhook struct {
	ID           string `json:"id"`
	ConnectionID string `json:"connection_id"`
	Version      int64  `json:"version"`
	Path         string `json:"path"`
	Revoked      bool   `json:"revoked"`
}