events

type AssessmentData struct {
	ID         string          `json:"id"`
	SnapshotID uint            `json:"snapshot_id,omitempty"`
	Name       string          `json:"name,omitempty"`
	OrgID      string          `json:"org_id,omitempty"`
	Username   string          `json:"username,omitempty"`
	SourceType string          `json:"source_type,omitempty"`
	PartnerID  *string         `json:"partner_id,omitempty"`
	Location   *string         `json:"location,omitempty"`
	Inventory  json.RawMessage `json:"inventory,omitempty"`
	CreatedAt  time.Time       `json:"created_at,omitempty"`
	UpdatedAt  *time.Time      `json:"updated_at,omitempty"`
	DeletedAt  *time.Time      `json:"deleted_at,omitempty"`
}

type AssessmentEventPayload struct {
	Assessment AssessmentData `json:"assessment"`
}

type ComplexityActionData struct {
	AssessmentID string `json:"assessment_id"`
}

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

type NoOpWriter struct{}

type OVADownloadActionData struct {
	SourceID string `json:"source_id"`
}

type PartnerCustomerData struct {
	ID               string     `json:"id"`
	CustomerUsername string     `json:"customer_username"`
	PartnerID        string     `json:"partner_id"`
	RequestStatus    string     `json:"request_status"`
	Location         string     `json:"location"`
	AcceptedAt       *time.Time `json:"accepted_at,omitempty"`
	TerminatedAt     *time.Time `json:"terminated_at,omitempty"`
	CreatedAt        time.Time  `json:"created_at"`
}

type PartnerCustomerEventPayload struct {
	PartnerCustomer PartnerCustomerData `json:"partner_customer"`
}

type ShareAssessmentActionData struct {
	AssessmentID string `json:"assessment_id"`
	PartnerID    string `json:"partner_id"`
}

type SizingActionData struct {
	AssessmentID string `json:"assessment_id"`
}

type TimeEstimationActionData struct {
	AssessmentID string `json:"assessment_id"`
}

type UnshareAssessmentActionData struct {
	AssessmentID string `json:"assessment_id"`
}

type UserActionData struct {
	Username  string    `json:"username"`
	Timestamp time.Time `json:"timestamp"`
	Data      any       `json:"data"`
}

type UserActionEventPayload struct {
	UserAction UserActionData `json:"user_action"`
}

type VisitorActionData struct {
	OrgID string `json:"org_id"`
}

type Writer interface {
	Write(ctx context.Context, topic string, data []byte) error
}