Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

agent

package

Go to main page

Versions in this module

v1

v1.1.1

Jan 5, 2018

v1.1.0

Jan 5, 2018

v1.0.1

Jan 5, 2018

v1.0.0

Jan 5, 2018

Changes in this version

+ type APIService struct

+ func NewAPIV1(ctx *Context) *APIService

+ func (s *APIService) AddXdsServer(cfg xdsconfig.XDSServerConf) (*XdsServer, error)

+ func (s *APIService) DelXdsServer(id string) error

+ func (s *APIService) Stop()

+ type ClientSession struct

+ ID string

+ IOSocket *socketio.Socket

+ MaxAge int64

+ WSID string

type Context

+ LogLevelSilly bool

+ LogSillyf func(format string, args ...interface{})

+ func (ctx *Context) Run() (int, error)

+ type EventCB func(privData interface{}, evtData interface{}) error

+ type EventDef struct

+ type Events struct

+ func NewEvents(ctx *Context) *Events

+ func (e *Events) Emit(evName string, data interface{}, fromSid string) error

+ func (e *Events) GetList() []string

+ func (e *Events) Register(evName, sessionID string) error

+ func (e *Events) UnRegister(evName, sessionID string) error

+ type IPROJECT interface

+ Add func(cfg xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ Delete func() error

+ GetProject func() *xaapiv1.ProjectConfig

+ GetServer func() *XdsServer

+ IsInSync func() (bool, error)

+ Setup func(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ Sync func() error

+ Update func(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ type OnConnectedCB func(svr *XdsServer) error

+ type PathMap struct

+ func NewProjectPathMap(ctx *Context, svr *XdsServer) *PathMap

+ func (p *PathMap) Add(cfg xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ func (p *PathMap) Delete() error

+ func (p *PathMap) GetProject() *xaapiv1.ProjectConfig

+ func (p *PathMap) GetServer() *XdsServer

+ func (p *PathMap) IsInSync() (bool, error)

+ func (p *PathMap) Setup(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ func (p *PathMap) Sync() error

+ func (p *PathMap) Update(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ type Projects struct

+ SThg *st.SyncThing

+ func NewProjects(ctx *Context, st *st.SyncThing) *Projects

+ func (p *Projects) Add(newP xaapiv1.ProjectConfig, fromSid, requestURL string) (*xaapiv1.ProjectConfig, error)

+ func (p *Projects) Delete(id, fromSid string) (xaapiv1.ProjectConfig, error)

+ func (p *Projects) ForceSync(id string) error

+ func (p *Projects) Get(id string) *IPROJECT

+ func (p *Projects) GetProjectArr() []xaapiv1.ProjectConfig

+ func (p *Projects) GetProjectArrUnsafe() []xaapiv1.ProjectConfig

+ func (p *Projects) Init(server *XdsServer) error

+ func (p *Projects) IsProjectInSync(id string) (bool, error)

+ func (p *Projects) ResolveID(id string) (string, error)

+ func (p *Projects) Update(id string, prj xaapiv1.ProjectConfig, fromSid string) (*xaapiv1.ProjectConfig, error)

+ type STProject struct

+ func NewProjectST(ctx *Context, svr *XdsServer) *STProject

+ func (p *STProject) Add(cfg xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ func (p *STProject) Delete() error

+ func (p *STProject) GetProject() *xaapiv1.ProjectConfig

+ func (p *STProject) GetServer() *XdsServer

+ func (p *STProject) IsInSync() (bool, error)

+ func (p *STProject) Setup(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ func (p *STProject) Sync() error

+ func (p *STProject) Update(prj xaapiv1.ProjectConfig) (*xaapiv1.ProjectConfig, error)

+ type Sessions struct

+ func NewClientSessions(ctx *Context, cookieMaxAge string) *Sessions

+ func (s *Sessions) Get(c *gin.Context) *ClientSession

+ func (s *Sessions) GetID(c *gin.Context) string

+ func (s *Sessions) IOSocketGet(sid string) *socketio.Socket

+ func (s *Sessions) Middleware() gin.HandlerFunc

+ func (s *Sessions) Stop()

+ func (s *Sessions) UpdateIOSocket(sid string, so *socketio.Socket) error

+ type WebServer struct

+ func NewWebServer(ctx *Context) *WebServer

+ func (s *WebServer) Serve() error

+ func (s *WebServer) Stop()

+ type XdsServer struct

+ APIURL string

+ BaseURL string

+ CBOnDisconnect func(error)

+ CBOnError func(error)

+ ConnRetry int

+ Connected bool

+ Disabled bool

+ ID string

+ PartialURL string

+ ServerConfig *xsapiv1.APIConfig

+ func NewXdsServer(ctx *Context, conf xdsconfig.XDSServerConf) *XdsServer

+ func (xs *XdsServer) Close() error

+ func (xs *XdsServer) CommandAdd(cmdID string, data interface{}) error

+ func (xs *XdsServer) CommandDelete(cmdID string) error

+ func (xs *XdsServer) CommandExec(args *xsapiv1.ExecArgs, res *xsapiv1.ExecResult) error

+ func (xs *XdsServer) CommandGet(cmdID string) interface{}

+ func (xs *XdsServer) CommandSignal(args *xsapiv1.ExecSignalArgs, res *xsapiv1.ExecSigResult) error

+ func (xs *XdsServer) Connect() error

+ func (xs *XdsServer) ConnectOn(f OnConnectedCB) error

+ func (xs *XdsServer) EventEmit(message string, args ...interface{}) error

+ func (xs *XdsServer) EventOff(evName string, id uuid.UUID) error

+ func (xs *XdsServer) EventOn(evName string, privData interface{}, f EventCB) (uuid.UUID, error)

+ func (xs *XdsServer) EventRegister(evName string, filter string) error

+ func (xs *XdsServer) FolderAdd(fld *xsapiv1.FolderConfig, res interface{}) error

+ func (xs *XdsServer) FolderDelete(id string) error

+ func (xs *XdsServer) FolderSync(id string) error

+ func (xs *XdsServer) FolderToProject(fPrj xsapiv1.FolderConfig) xaapiv1.ProjectConfig

+ func (xs *XdsServer) FolderUpdate(fld *xsapiv1.FolderConfig, resFld *xsapiv1.FolderConfig) error

+ func (xs *XdsServer) GetFolders(folders *[]xsapiv1.FolderConfig) error

+ func (xs *XdsServer) GetVersion(res interface{}) error

+ func (xs *XdsServer) IsTempoID() bool

+ func (xs *XdsServer) PassthroughDelete(url string)

+ func (xs *XdsServer) PassthroughGet(url string)

+ func (xs *XdsServer) PassthroughPost(url string)

+ func (xs *XdsServer) ProjectToFolder(pPrj xaapiv1.ProjectConfig) *xsapiv1.FolderConfig

+ func (xs *XdsServer) SendCommand(cmd string, body []byte, res interface{}) error

+ func (xs *XdsServer) SetAPIRouterGroup(r *gin.RouterGroup)

+ func (xs *XdsServer) SetLoggerOutput(out io.Writer)

v1.0.0-rc2

Dec 22, 2017

v1.0.0-rc1

Nov 30, 2017

v0

v0.3.0-rc1

Oct 20, 2017

v0.2.0

Oct 16, 2017

Changes in this version

+ type Context struct

+ Config *xdsconfig.Config

+ Exit chan os.Signal

+ Log *logrus.Logger

+ ProgName string

+ SThg *st.SyncThing

+ SThgCmd *exec.Cmd

+ SThgInotCmd *exec.Cmd

+ WWWServer *webserver.ServerService

+ func NewAgent(cliCtx *cli.Context) *Context

v0.0.1-alpha

May 31, 2017