service

Documentation

Index

• Constants
• type Agent
  • func NewRemoteScriptService(cfg *env.Properties) (*Agent, error)
  • func (p *Agent) Execute(script *rpc.RemoteScript, reply *string) error
  • func (p *Agent) Init() error
• type AppService
  • func (p *AppService) Update(name string, attrs []string, values []interface{}) error
• type DBService
  • func (p *DBService) Dispose() error
  • func (p *DBService) Init() error
• type HttpService
  • func (p *HttpService) Init() error
• type LogConfigService
  • func (p *LogConfigService) Add(file string) error
  • func (p *LogConfigService) Handle(event string, data interface{})
  • func (p *LogConfigService) Init() error
  • func (p *LogConfigService) Remove(file string) error
• type RemoteScriptServiceFactory
  • func (p *RemoteScriptServiceFactory) New() interface{}

Constants

const (
	FileBeatIndexDir = "../../data/filebeat"
	FileBeatIndex    = "../../data/filebeat/config_index.json"
	FileBeatConfig   = "../../log/config/filebeat.yml"
)

Types

type Agent

type Agent struct {
	AppRoot string //the root path of app
	// contains filtered or unexported fields
}

RemoteScriptService execute the method of app

func NewRemoteScriptService

func NewRemoteScriptService(cfg *env.Properties) (*Agent, error)

func (*Agent) Execute

func (p *Agent) Execute(script *rpc.RemoteScript, reply *string) error

Execute a script in the host of the agent

func (*Agent) Init

func (p *Agent) Init() error

type AppService

type AppService struct {
	brick.Trigger
}

AppService

func (*AppService) Update

func (p *AppService) Update(name string, attrs []string, values []interface{}) error

type DBService

type DBService struct {
}

func (*DBService) Dispose

func (p *DBService) Dispose() error

func (*DBService) Init

func (p *DBService) Init() error

type HttpService

type HttpService struct {
	Controller *rest.RestController `inject:"RestController"`
}

func (*HttpService) Init

func (p *HttpService) Init() error

type LogConfigService

type LogConfigService struct {
	AppService *AppService `inject:"App"`
}

LogConfigService merge all filebeat's configs into one

func (*LogConfigService) Add

func (p *LogConfigService) Add(file string) error

Add a filebeat config of app

func (*LogConfigService) Handle

func (p *LogConfigService) Handle(event string, data interface{})

func (*LogConfigService) Init

func (p *LogConfigService) Init() error

func (*LogConfigService) Remove

func (p *LogConfigService) Remove(file string) error

Remove a filebeat config of app

type RemoteScriptServiceFactory

type RemoteScriptServiceFactory struct {
}

RemoteScriptServiceFactory

func (*RemoteScriptServiceFactory) New

func (p *RemoteScriptServiceFactory) New() interface{}