heartbeatmemory

Documentation

Index

• Constants
• type HeartbeatRecord
• type MemoryHealthChecker
  • func (r *MemoryHealthChecker) BatchQuery(ctx context.Context, request *plugin.BatchQueryRequest) (*plugin.BatchQueryResponse, error)
  • func (r *MemoryHealthChecker) Check(request *plugin.CheckRequest) (*plugin.CheckResponse, error)
  • func (r *MemoryHealthChecker) DebugHandlers() []model.DebugHandler
  • func (r *MemoryHealthChecker) Delete(ctx context.Context, id string) error
  • func (r *MemoryHealthChecker) Destroy() error
  • func (r *MemoryHealthChecker) Initialize(c *plugin.ConfigEntry) error
  • func (r *MemoryHealthChecker) Name() string
  • func (r *MemoryHealthChecker) Query(ctx context.Context, request *plugin.QueryRequest) (*plugin.QueryResponse, error)
  • func (r *MemoryHealthChecker) Report(ctx context.Context, request *plugin.ReportRequest) error
  • func (r *MemoryHealthChecker) Suspend()
  • func (r *MemoryHealthChecker) SuspendTimeSec() int64
  • func (r *MemoryHealthChecker) Type() plugin.HealthCheckType

Constants

const (
	// PluginName plugin name
	PluginName = "heartbeatMemory"
)

把操作记录记录到日志文件中

Types

type HeartbeatRecord

type HeartbeatRecord struct {
	Server     string
	CurTimeSec int64
	Count      int64
}

HeartbeatRecord record for heartbeat

type MemoryHealthChecker

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

MemoryHealthChecker memory health checker

func (*MemoryHealthChecker) BatchQuery

func (r *MemoryHealthChecker) BatchQuery(ctx context.Context, request *plugin.BatchQueryRequest) (*plugin.BatchQueryResponse, error)

func (*MemoryHealthChecker) Check

func (r *MemoryHealthChecker) Check(request *plugin.CheckRequest) (*plugin.CheckResponse, error)

Check Report process the instance check

func (*MemoryHealthChecker) DebugHandlers

func (r *MemoryHealthChecker) DebugHandlers() []model.DebugHandler

func (*MemoryHealthChecker) Delete

func (r *MemoryHealthChecker) Delete(ctx context.Context, id string) error

Delete delete the id

func (*MemoryHealthChecker) Destroy

func (r *MemoryHealthChecker) Destroy() error

Destroy plugin destruction

func (*MemoryHealthChecker) Initialize

func (r *MemoryHealthChecker) Initialize(c *plugin.ConfigEntry) error

Initialize initialize plugin

func (*MemoryHealthChecker) Name

func (r *MemoryHealthChecker) Name() string

Name return plugin name

func (*MemoryHealthChecker) Query

func (r *MemoryHealthChecker) Query(ctx context.Context, request *plugin.QueryRequest) (*plugin.QueryResponse, error)

Query queries the heartbeat time

func (*MemoryHealthChecker) Report

func (r *MemoryHealthChecker) Report(ctx context.Context, request *plugin.ReportRequest) error

Report process heartbeat info report

func (*MemoryHealthChecker) Suspend

func (r *MemoryHealthChecker) Suspend()

func (*MemoryHealthChecker) SuspendTimeSec

func (r *MemoryHealthChecker) SuspendTimeSec() int64

SuspendTimeSec get suspend time in seconds

func (*MemoryHealthChecker) Type

func (r *MemoryHealthChecker) Type() plugin.HealthCheckType

Type for health check plugin, only one same type plugin is allowed