rpc

Documentation

Index

• func Start()
• type Judge
  • func (this *Judge) Ping(req model.NullRpcRequest, resp *model.SimpleRpcResponse) error
  • func (this *Judge) Send(items []*model.JudgeItem, resp *model.SimpleRpcResponse) error
  • func (this *Judge) UnionJudge(event *model.Event, resp *model.SimpleRpcResponse) error

Functions

func Start

func Start()

Types

type Judge

type Judge int

func (*Judge) Ping

func (this *Judge) Ping(req model.NullRpcRequest, resp *model.SimpleRpcResponse) error

func (*Judge) Send

func (this *Judge) Send(items []*model.JudgeItem, resp *model.SimpleRpcResponse) error

transfer调度了send

func (*Judge) UnionJudge

func (this *Judge) UnionJudge(event *model.Event, resp *model.SimpleRpcResponse) error

接收组合报警中的item