workers

package

v1.0.4 Latest Latest Go to latest Published: Feb 9, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func Module(c *di.Container)

func NopCloner() *nopCLoner

func NopImporter() *nopImporter

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

func NewClonerQueue(
	logger *zap.Logger,
	queue queue.Queue,
	githubService *service_github.Service,
) *ClonerQueue

func (q *ClonerQueue) Enqueue(ctx context.Context, event *github.CloneRepositoryEvent) error

func (q *ClonerQueue) Start(ctx context.Context) error

type ImporterQueue interface {
	Start(ctx context.Context) error
	Enqueue(ctx context.Context, codebaseID, userID string) error
}

func NewImporterQueue(
	logger *zap.Logger,
	queue queue.Queue,
	gitHubService *service_github.Service,
) ImporterQueue

type PullRequestImportEvent struct {
	CodebaseID string `json:"codebase_id"`
	UserID     string `json:"user_id"`
}