microserver

Documentation

Index

• Variables
• type PalaceConn
  • func NewPalaceConn(c *houyiconf.Bootstrap) (*PalaceConn, func(), error)
  • func (l *PalaceConn) Heartbeat(ctx context.Context, in *api.HeartbeatRequest, opts ...microserver.Option) (*api.HeartbeatReply, error)
  • func (l *PalaceConn) PushAlarm(ctx context.Context, in *api.AlarmItem, opts ...microserver.Option) (*api.HookReply, error)
  • func (l *PalaceConn) PushMetric(ctx context.Context, in *datasourceapi.SyncMetricRequest, ...) (*datasourceapi.SyncMetricReply, error)

Variables

var ProviderSetRPCConn = wire.NewSet(
	NewPalaceConn,
)

ProviderSetRPCConn wire set

Types

type PalaceConn

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

PalaceConn Palace服务连接

func NewPalaceConn

func NewPalaceConn(c *houyiconf.Bootstrap) (*PalaceConn, func(), error)

NewPalaceConn 创建一个palace rpc连接

func (*PalaceConn) Heartbeat

func (l *PalaceConn) Heartbeat(ctx context.Context, in *api.HeartbeatRequest, opts ...microserver.Option) (*api.HeartbeatReply, error)

Heartbeat 向palace发送心跳

func (*PalaceConn) PushAlarm

func (l *PalaceConn) PushAlarm(ctx context.Context, in *api.AlarmItem, opts ...microserver.Option) (*api.HookReply, error)

PushAlarm 向palace推送告警数据

func (*PalaceConn) PushMetric

func (l *PalaceConn) PushMetric(ctx context.Context, in *datasourceapi.SyncMetricRequest, opts ...microserver.Option) (*datasourceapi.SyncMetricReply, error)

PushMetric 向palace推送指标数据