control

package

Go to main page

Versions in this module

v0

v0.9.2

Sep 10, 2020

v0.9.2-dev.20191219

Dec 19, 2019

v0.9.1

Nov 6, 2019

v0.9.0

Oct 23, 2019

v0.8.0

Oct 11, 2019

Changes in this version

+ type FileStateStore struct

+ FileError error

+ PreviousState model.TaskStatus

+ func NewFileStateStore(config *config.Task, folderPath string) *FileStateStore

+ func (f *FileStateStore) Close()

+ func (f *FileStateStore) UpdateProcessStatus(processStatus model.Status, status ...model.TaskStatus) common.SyncState

+ func (f *FileStateStore) UpdateSyncStatus(s model.TaskStatus) common.SyncState

type HttpServer

+ func (h *HttpServer) ListenAuthorities()

type MemoryStateStore

+ func (b *MemoryStateStore) Close()

+ type SpawnedService struct

+ func NewSpawnedService(name string, args []string) *SpawnedService

+ func (c *SpawnedService) Serve()

+ func (c *SpawnedService) Stop()

type StateStore

+ Close func()

v0.2.0

Aug 21, 2019

Changes in this version

+ const MessageDisable

+ const MessageEnable

+ const MessageHalt

+ const MessageHaltClean

+ const MessageInterrupt

+ const MessagePause

+ const MessagePublishState

+ const MessagePublishStore

+ const MessageRestart

+ const MessageRestartClean

+ const MessageResume

+ const MessageResync

+ const MessageResyncDry

+ const MessageSyncLoop

+ const TopicGlobal

+ const TopicState

+ const TopicStore_

+ const TopicSyncAll

+ const TopicSync_

+ const TopicUpdate

+ func GetBus() *pubsub.PubSub

+ func MessageFromString(text string) (int, error)

+ type CommandMessage int

+ type HttpServer struct

+ LogSocket *melody.Melody

+ WebSocket *melody.Melody

+ func NewHttpServer() *HttpServer

+ func (h *HttpServer) InitHandlers()

+ func (h *HttpServer) ListenStatus()

+ func (h *HttpServer) Serve()

+ func (h *HttpServer) Stop()

+ func (h *HttpServer) Sync() error

+ func (h *HttpServer) Write(p []byte) (n int, err error)

+ type MemoryStateStore struct

+ func NewMemoryStateStore(config *config.Task) *MemoryStateStore

+ func (b *MemoryStateStore) BothConnected() bool

+ func (b *MemoryStateStore) LastState() common.SyncState

+ func (b *MemoryStateStore) TouchLastOpsTime(t ...time.Time)

+ func (b *MemoryStateStore) UpdateConnection(c bool, i model.EndpointInfo) common.SyncState

+ func (b *MemoryStateStore) UpdateEndpointStats(s *model.EndpointRootStat, i model.EndpointInfo) common.SyncState

+ func (b *MemoryStateStore) UpdateProcessStatus(processStatus model.Status, status ...model.TaskStatus) common.SyncState

+ func (b *MemoryStateStore) UpdateSyncStatus(s model.TaskStatus) common.SyncState

+ func (b *MemoryStateStore) UpdateWatcherActivity(a bool, i model.EndpointInfo) common.SyncState

+ type PatchesRequest struct

+ Limit int

+ Offset int

+ SyncUUID string

+ type PatchesResponse struct

+ Patches []merger.Patch

+ type Profiler struct

+ func (p *Profiler) Serve()

+ func (p *Profiler) Stop()

+ type Scheduler struct

+ func NewScheduler(tasks []*config.Task) *Scheduler

+ func (s *Scheduler) Serve()

+ func (s *Scheduler) Stop()

+ type StateStore interface

+ BothConnected func() bool

+ LastState func() common.SyncState

+ TouchLastOpsTime func(t ...time.Time)

+ UpdateConnection func(c bool, i model.EndpointInfo) common.SyncState

+ UpdateEndpointStats func(s *model.EndpointRootStat, i model.EndpointInfo) common.SyncState

+ UpdateProcessStatus func(processStatus model.Status, status ...model.TaskStatus) common.SyncState

+ UpdateSyncStatus func(s model.TaskStatus) common.SyncState

+ UpdateWatcherActivity func(a bool, i model.EndpointInfo) common.SyncState

+ type StdInner struct

+ func (s *StdInner) Serve()

+ func (s *StdInner) Stop()

+ type Supervisor struct

+ func NewSupervisor() *Supervisor

+ func (s *Supervisor) Serve() error

+ type Syncer struct

+ func NewSyncer(conf *config.Task) (syncer *Syncer)

+ func (s *Syncer) Serve()

+ func (s *Syncer) Stop()

+ type TreeRequest struct

+ EndpointURI string

+ Path string

+ type TreeResponse struct

+ Children []*tree.Node

+ Node *tree.Node

+ func (l *TreeResponse) MarshalJSON() ([]byte, error)

+ func (l *TreeResponse) ProtoMessage()

+ func (l *TreeResponse) Reset()

+ func (l *TreeResponse) String() string

+ type Updater struct

+ func NewUpdater() *Updater

+ func (u *Updater) ApplyUpdate(ctx context.Context, p *update.Package, dryRun bool, busTopic string)

+ func (u *Updater) LoadUpdates(ctx context.Context, busTopic string) (packages []*update.Package, outErr error)

+ func (u *Updater) Serve()

+ func (u *Updater) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL