server

Documentation

Index

• func MapNamespacesRoutes(route martini.Router)
• func MapRouteBySchema(server *Server, dataStore db.DB, s *schema.Schema)
• func MapRouteBySchemas(server *Server, dataStore db.DB)
• func MonitoringUpdate(response *gohan_sync.Event, server *Server) error
• func RunServer(configFile string)
• func StateUpdate(response *gohan_sync.Event, server *Server) error
• type DbSyncWrapper
  • func (sw *DbSyncWrapper) Begin() (transaction.Transaction, error)
• type Server
  • func NewServer(configFile string) (*Server, error)
  • func (server *Server) Start() (err error)
  • func (server *Server) Stop()
  • func (server *Server) Sync() error

Functions

func MapNamespacesRoutes

func MapNamespacesRoutes(route martini.Router)

MapNamespacesRoutes maps routes for all namespaces

func MapRouteBySchema

func MapRouteBySchema(server *Server, dataStore db.DB, s *schema.Schema)

MapRouteBySchema setup api route by schema

func MapRouteBySchemas

func MapRouteBySchemas(server *Server, dataStore db.DB)

MapRouteBySchemas setup route for all loaded schema

func MonitoringUpdate

func MonitoringUpdate(response *gohan_sync.Event, server *Server) error

MonitoringUpdate updates the state in the db based on the sync event

func RunServer

func RunServer(configFile string)

RunServer runs gohan api server

func StateUpdate

func StateUpdate(response *gohan_sync.Event, server *Server) error

StateUpdate updates the state in the db based on the sync event

Types

type DbSyncWrapper

type DbSyncWrapper struct {
	db.DB
}

DbSyncWrapper wraps db.DB so it logs events in database on every transaction.

func (*DbSyncWrapper) Begin

func (sw *DbSyncWrapper) Begin() (transaction.Transaction, error)

Begin wraps transaction object with sync

type Server

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

Server is a struct for GohanAPIServer

func NewServer

func NewServer(configFile string) (*Server, error)

NewServer returns new GohanAPIServer

func (*Server) Start

func (server *Server) Start() (err error)

Start starts GohanAPIServer

func (*Server) Stop

func (server *Server) Stop()

Stop stops GohanAPIServer

func (*Server) Sync

func (server *Server) Sync() error

Sync to sync backend database table