amqp

type AmqpClient interface {
	Close() error
	PublishOnQueue(queueName QueueName, data func() []byte) (err error)
	SubscribeToQueue(ctx context.Context, logger log.Logger, call func(ctx context.Context, data string) error)
}

type BuildPublishData struct {
	Name           string `json:"name"`             // name
	Namespace      string `json:"namespace"`        // namespace
	JenkinJobName  string `json:"jenkin_job_name"`  // jenkins job name
	BuildId        int64  `json:"build_id"`         // build id
	JenkinsBuildId int64  `json:"jenkins_build_id"` // jenkins build id
	Builder        int64  `json:"builder"`          // 操作人
	Timestamp      int64  `json:"timestamp"`        //创建时间的时间戳
	Version        string `json:"version"`
}

type PublishData struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
}

type QueueName string