worker

Documentation

Index

• func Module(c *di.Container)
• type Queue
  • func New(logger *zap.Logger, queue queue.Queue, snapshotter snapshotter.Snapshotter) Queue
  • func NewSync(snapshotter snapshotter.Snapshotter) Queue
• type SnapshotQueueEntry

Functions

func Module

func Module(c *di.Container)

Types

type Queue

type Queue interface {
	Enqueue(ctx context.Context, codebaseID, viewID, workspaceID string, paths []string, action snapshots.Action) error
	Start(ctx context.Context) error
}

func New

func New(
	logger *zap.Logger,
	queue queue.Queue,
	snapshotter snapshotter.Snapshotter,
) Queue

func NewSync

func NewSync(snapshotter snapshotter.Snapshotter) Queue

type SnapshotQueueEntry

type SnapshotQueueEntry struct {
	CodebaseID   string           `json:"codebase_id"`
	ViewID       string           `json:"view_id"`
	WorkspaceID  string           `json:"workspace_id"`
	ChangedFiles []string         `json:"changed_files"`
	Action       snapshots.Action `json:"action"`
}