Documentation ¶
Index ¶
- func SetLog(entty *logrus.Entry)
- func SetLogger(nLogger *logrus.Logger)
- type Agent
- func (agent *Agent) AddToES(data ElasticData) error
- func (agent *Agent) Close(w http.ResponseWriter, req *http.Request)
- func (agent *Agent) InitES() error
- func (agent *Agent) Log(w http.ResponseWriter, req *http.Request)
- func (agent *Agent) Meter(w http.ResponseWriter, req *http.Request)
- func (agent *Agent) Shutdown()
- func (agent *Agent) Trace(w http.ResponseWriter, req *http.Request)
- type Configuration
- type ElasticData
- type LogMessage
- type MeterMessage
- type TraceMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
func CreateAgent ¶
func CreateAgent(cnf Configuration) (*Agent, error)
func (*Agent) AddToES ¶
func (agent *Agent) AddToES(data ElasticData) error
type Configuration ¶
type Configuration struct { Port int //the port of this service IgnoreElastic bool //skip elastic validation only for testing.. ZipkinEndpoint string //zipkin endpoint Endpoint string // the vdc endpoint VDCName string // VDCName (used for the index name in elastic serach) ElasticSearchURL string //eleasticSerach endpoint ElasticBasicAuth bool //if active we use basic auth ElasticUser string ElasticPassword string // contains filtered or unexported fields }
type ElasticData ¶
type ElasticData struct { Timestamp time.Time `json:"@timestamp"` Meter *MeterMessage `json:"meter,omitempty"` Log *LogMessage `json:"log,omitempty"` }
type LogMessage ¶
type MeterMessage ¶
Click to show internal directories.
Click to hide internal directories.