Versions in this module Expand all Collapse all v1 v1.0.0 Jul 17, 2018 Changes in this version + const MonitoringUpdateEventName + const StateUpdateEventName + const SyncWatchRevisionPrefix + func GetSchema(s *schema.Schema, authorization schema.Authorization) (result *schema.Resource, err error) + func MapNamespacesRoutes(route martini.Router) + func MapRouteBySchema(server *Server, dataStore db.DB, s *schema.Schema) + func MapRouteBySchemas(server *Server, dataStore db.DB) + func Resync(dbConn db.DB, sync sync.Sync) (err error) + func RunServer(configFile string) + type DbSyncWrapper struct + func (sw *DbSyncWrapper) Begin() (transaction.Transaction, error) + func (sw *DbSyncWrapper) BeginTx(ctx context.Context, options *transaction.TxOptions) (transaction.Transaction, error) + type Server struct + func NewServer(configFile string) (*Server, error) + func (server *Server) Address() string + func (server *Server) GetSync() sync.Sync + func (server *Server) NewEnvironmentForPath(name string, path string) (env extension.Environment, err error) + func (server *Server) Queue() *job.Queue + func (server *Server) Router() http.Handler + func (server *Server) SetRunning(running bool) + func (server *Server) Start() (err error) + func (server *Server) Stop() + type StateWatcher struct + func NewStateWatcher(sync gohan_sync.Sync, db db.DB, identity middleware.IdentityService) *StateWatcher + func NewStateWatcherFromServer(server *Server) *StateWatcher + func (watcher *StateWatcher) MonitoringUpdate(event *gohan_sync.Event) error + func (watcher *StateWatcher) Run(ctx context.Context) error + func (watcher *StateWatcher) StateUpdate(event *gohan_sync.Event) error + type SyncWatcher struct + func NewSyncWatcher(sync gohan_sync.Sync, keys []string, events []string, ...) *SyncWatcher + func NewSyncWatcherFromServer(server *Server) *SyncWatcher + func (watcher *SyncWatcher) Run(ctx context.Context) error + type SyncWriter struct + func NewSyncWriter(sync gohan_sync.Sync, db db.DB) *SyncWriter + func NewSyncWriterFromServer(server *Server) *SyncWriter + func (writer *SyncWriter) Run(ctx context.Context) error + func (writer *SyncWriter) Sync() (synced int, err error)