package stat

import (
	"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/requests"
	"golib.gaore.com/GaoreGo/gaore-common-sdk-go/sdk/responses"
)

type KafkaEventReq = requests.JsonRequest

type KafkaEventResp struct {
	*responses.BaseResponse
	Code int    `json:"code"`
	Msg  string `json:"msg"`
}

func CreateKafkaEventReq(param map[string]any) *KafkaEventReq {
	req := &requests.JsonRequest{}
	req.InitWithApiInfo(HOST, VERSION, "/event_track/kafka")
	req.Method = requests.POST
	req.JsonParams = param
	return req
}

func CreateKafkaEventResp() *KafkaEventResp {
	return &KafkaEventResp{
		BaseResponse: &responses.BaseResponse{},
	}
}