control

type CommandMessage int

type FileStateStore struct {
	MemoryStateStore
	PreviousState model.TaskStatus
	FileError     error
	// contains filtered or unexported fields
}

type HttpServer struct {
	WebSocket *melody.Melody
	LogSocket *melody.Melody
	// contains filtered or unexported fields
}

type MemoryStateStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type PatchesRequest struct {
	SyncUUID string `uri:"uuid" binding:"required"`
	Offset   int    `uri:"offset" binding:"numeric"`
	Limit    int    `uri:"limit"`
}

type PatchesResponse struct {
	Patches []merger.Patch
}

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

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

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

type StateStore interface {
	LastState() common.SyncState
	BothConnected() bool
	TouchLastOpsTime(t ...time.Time)
	Close()

	UpdateConnection(c bool, i model.EndpointInfo) common.SyncState
	UpdateWatcherActivity(a bool, i model.EndpointInfo) common.SyncState
	UpdateEndpointStats(s *model.EndpointRootStat, i model.EndpointInfo) common.SyncState

	UpdateSyncStatus(s model.TaskStatus) common.SyncState
	UpdateProcessStatus(processStatus model.Status, status ...model.TaskStatus) common.SyncState
}

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

type Supervisor struct {
	sync.Mutex
	*suture.Supervisor
	// contains filtered or unexported fields
}

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

type TreeRequest struct {
	EndpointURI string
	Path        string
	// contains filtered or unexported fields
}

type TreeResponse struct {
	Node     *tree.Node
	Children []*tree.Node
}

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