v1

Documentation

Index

• func GenReqDefForCheckProductHealthy() *def.HttpRequestDef
• func GenReqDefForImportEvents() *def.HttpRequestDef
• func SaClientBuilder() *http_client.HcHttpClientBuilder
• type SaClient
  • func NewSaClient(hcClient *http_client.HcHttpClient) *SaClient
  • func (c *SaClient) CheckProductHealthy(request *model.CheckProductHealthyRequest) (*model.CheckProductHealthyResponse, error)
  • func (c *SaClient) ImportEvents(request *model.ImportEventsRequest) (*model.ImportEventsResponse, error)

Functions

func GenReqDefForCheckProductHealthy

func GenReqDefForCheckProductHealthy() *def.HttpRequestDef

func GenReqDefForImportEvents

func GenReqDefForImportEvents() *def.HttpRequestDef

func SaClientBuilder

func SaClientBuilder() *http_client.HcHttpClientBuilder

Types

type SaClient

type SaClient struct {
	HcClient *http_client.HcHttpClient
}

func NewSaClient

func NewSaClient(hcClient *http_client.HcHttpClient) *SaClient

func (*SaClient) CheckProductHealthy

func (c *SaClient) CheckProductHealthy(request *model.CheckProductHealthyRequest) (*model.CheckProductHealthyResponse, error)

SA提供心跳接口，集成产品定时（例如：每五分钟）发送心跳报文到SA，用来确认集成产品与SA之间的通路是否健康。

func (*SaClient) ImportEvents

func (c *SaClient) ImportEvents(request *model.ImportEventsRequest) (*model.ImportEventsResponse, error)

批量数据上报，每批次最多不超过50条。