Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EndWithCause ¶
Types ¶
type Metric ¶
type Metric struct {
Endpoint string `json:"endpoint" avro:"endpoint"`
Fn string `json:"fn" avro:"fn"`
Latency int64 `json:"latency" avro:"latency"`
Succeed bool `json:"succeed" avro:"succeed"`
ErrorCode int `json:"errorCode" avro:"errorCode"`
ErrorName string `json:"errorName" avro:"errorName"`
DeviceId string `json:"deviceId" avro:"deviceId"`
DeviceIp string `json:"deviceIp" avro:"deviceIp"`
// contains filtered or unexported fields
}
Metric use @metric to enable in fn
type ReportTask ¶ added in v1.3.0
type ReportTask struct {
// contains filtered or unexported fields
}
func (*ReportTask) Execute ¶ added in v1.3.0
func (task *ReportTask) Execute(_ sc.Context)
func (*ReportTask) Name ¶ added in v1.3.0
func (task *ReportTask) Name() (name string)
type ReporterComponent ¶ added in v1.3.0
type ReporterComponent struct {
// contains filtered or unexported fields
}
func (*ReporterComponent) Construct ¶ added in v1.3.0
func (c *ReporterComponent) Construct(options services.Options) (err error)
func (*ReporterComponent) Name ¶ added in v1.3.0
func (c *ReporterComponent) Name() (name string)
func (*ReporterComponent) Report ¶ added in v1.3.0
func (c *ReporterComponent) Report(ctx context.Context, metric Metric)
func (*ReporterComponent) Shutdown ¶ added in v1.3.0
func (c *ReporterComponent) Shutdown(ctx context.Context)
Click to show internal directories.
Click to hide internal directories.